邓　辉，钟文杰，付映雪，王　锋，卫守林

(1. 广州大学天体物理中心，广东 广州　510006；2. 昆明理工大学云南省计算机技术应用重点实验室，云南 昆明　650500)

天文望远镜伴随着观测手段的多样化和制造工艺的提升，以及高精度、大视场观测的需求，望远镜的结构正朝着巨型化、智能化的趋势发展，观测设备的功能越来越强，控制也越来越复杂。基于人工实现操作与控制进行观测越来越困难，自动控制系统已成为望远镜系统中不可缺少的重要部分。

望远镜观测控制系统需要同时对多种类型的设备进行控制，这些不同的设备通常都需要一个前置的计算机连接驱动，由前置计算机向各个观测设备发送指令完成控制，而完成一个观测计划需要这些不同设备之间相互配合，彼此之间需要通信。在这个过程中就涉及多种网络通信模型，如望远镜基座移动操作的点对点的通信，多台CCD同时曝光的点对多点通信。与此同时，在望远镜运行期间，各种设备的增加与升级也是常见的现象，进而导致一系列设备控制、数据采集处理系统升级改造的问题。在系统设计的初始阶段需要考虑多个未知型号终端设备同时工作，并且能随着技术进步和观测要求的变化随时升级更换终端设备的情况。新增的设备又是一个新的网络节点，涉及设备的注册、同步等通信问题。因此，良好的网络通信架构设计是整个望远镜自动控制系统设计的核心。

本文针对大型望远镜自动控制系统中的数据通信技术需求，讨论使用在分布式计算中广泛应用的ZeroMQ网络通信库，设计实现高性能、易扩展的望远镜自动控制系统的通信框架。

1　通信技术

望远镜系统中的各种设备物理上分散部署的特点决定了观测控制系统需要具备分布式控制的能力，目前不管是开源的远程望远镜系统第 2版(Remote Telescope System, 2nd version)[1]，还是国内外大型望远镜的控制系统都采用了分布式的控制原理，主要用到的通信协议包括裸套接(Socket)，超文本传输协议(Hyper Text Transfer Protocol, HTTP)，公共对象请求代理体系结构(Common Object Request Broker Architecture, CORBA)，分布式组件对象模型(Distributed Component Object Model, DCOM)等。这些通信技术在不同阶段发挥了重要作用，但随着通信技术的发展，又都表现出不同的局限性。

RTS2是开源领域中应用广泛的远程望远镜控制系统，支持多种设备的接入和控制，但在大型望远镜控制系统中较少使用。RTS2使用传输控制协议(Transmission Control Protocol, TCP)的原始套接字编程，在望远镜系统中，有多种设备、多种服务，通信的终端数目就有多个，同时也支持多客户端的连接，这就需要每个终端要维持它所有的通信关系。每个参与通信的客户端所需维持的连接数量非常庞大，这非常不利于程序的开发和实现。此外，望远镜控制系统中，经常需要同步操作多种设备。比如，多CCD的顺序观测，组合观测，同步曝光。RTS2中一个客户端是同时建立和多个设备的独立的网络连接，这种情况下，只能通过循环的方式，依次向多个设备发送命令。尽管纯文本协议设计小巧，同时，通常的控制系统中，终端不多，网络负载小，但仍不是严格意义上的广播数据通信方式，不能较好地解决协同控制的问题。

CORBA作为较早的分布式计算和远程对象调用的标准，在天文望远镜控制系统中广泛使用。ALMA控制系统(ALMA Control System, ACS)就是其中的代表[2]， ACS支持组建和容器模型的开发。使用CORBA技术的好处是可以集成不同的开发技术，如JAVA用于控制系统的高层开发，C++用于底层时间关键开发，Python则用于天文学家查询和分析数据。国内郭守敬望远镜控制系统的底层通信也是基于CORBA开发[3]。

天文组件对象模型(Astronomy Component Object Model, ASCOM)是Windows平台下的望远镜观测控制系统，采用微软COM组件编程模式，具有较好的可扩展性。由于其开发周期短、部署容易等特点，ASCOM适合应用在选址望远镜的远程控制系统开发中。丽江的2.4 m望远镜基于ASCOM实现了CCD滤光片和圆顶的控制[4-5]。天文望远镜中的很多设备的驱动及后续的数据处理程序包大都在Linux环境下使用，而ASCOM需要运行在Windows平台下，这给设备的接入和数据处理系统带来很大的不便。

消息中间件的迅速发展，为分布式异构环境中信息交互和控制提供了良好的技术支持，其中以ActiveMQ和RabbitMQ为代表，面向消息的低耦合特性非常适合分布式设备控制。ActiveMQ需要运行在Java环境中，但客户端可以使用多种语言编写，伽利略望远镜(Telescopio Nazionale Galileo, TNG)的观测控制系统(Observation Control System, OCS)网络通信就是基于ActiveMQ实现[6]，支持并发、异步通信模式控制设备，利用ActiveMQ本身提供的主备模式提高消息中枢系统的可用性。但在这种架构中，引入了第三方系统，消息中间件的稳定性是系统稳定运行的前提。

计算机软硬件和自动化技术的快速发展，这些协议和技术都体现出不同层面的局限性，不能完全适应观测控制系统的需求。近年来，云计算和分布式计算技术取得长足发展，新的通信技术不断涌现，ZeroMQ因其开源、跨平台、高性能的特点，被广泛应用在分布式数据处理框架中，如流式计算框架Storm[7]，分布式计算框架DALiuGE[8]。ZeroMQ同样适合在测控系统中使用，如智能楼宇监控[9]。相对于消息中间件ActiveMQ 和RabbitMQ在部署时需要专门的一个服务器，ZeroMQ只需要在应用程序中引用ZeroMQ程序库就可完成通信，更重要的是ZeroMQ支持请求回应模型(Request-Reply)、发布订阅模型(Publish-Subscribe)、推拉模型(Push-Pull)、路由分发模型(Router-Dealer)等，并可灵活组合使用这些基础模型构建更复杂的分布式网络通信框架，满足望远镜控制系统通信中多种通信模型的需求。此外，ZeroMQ提供了C，C++，Java， .NET，Python等多种语言绑定和多种主流操作系统平台的支持，这为望远镜系统中协同控制多种异构设备提供了技术支撑。

2　系统体系结构

参考ATST的体系结构设计[10]，将望远镜远程控制系统分为观测控制系统(Observation Control System, OCS)、望远镜控制系统(Telescope Control System, TCS)、设备控制系统(Instrument Control System, ICS)、数据处理系统(Data Handling System, DHS)和用户界面(User Interface, UI)，系统结构如图1。

图1望远镜控制系统体系结构图
Fig.1The architecture diagram of telescope control system

观测控制系统是整个系统的核心，包含了观测目标维护、观测计划维护、观测脚本的解析和执行调度等。设备控制系统和望远镜控制系统接收观测控制系统的执行命令，负责对望远镜和望远镜系统中的其他设备(如CCD，DOME)进行直接控制。观测设备产生数据后，向数据处理系统发送数据准备好的信息，数据处理系统启动实时数据处理程序，实时数据处理的结果能支持观测调度的决策，选择最优的观测目标。各个子系统之间的交互都是采用ZeroMQ。需要特别说明的是，在观测控制系统中增加了WebServer组件，提供基于HTTP协议的REST服务和WebSocket，使用WebSocket为用户操作界面提供实时通信协议。使用通用平台无关的HTTP协议，目的是构建跨平台的页面，支持多种类型的前端编程技术。

3　关键技术

在早期版本的ZeroMQ中，应用程序编程接口基于AMQP的交换和队列模型，作者于2009重写了应用程序编程接口，改用BSD Socket API，降低了应用程序编程接口的学习曲线，方便ZeroMQ与现有技术的集成。ZeroMQ对象被暴露为 “套接字”，因此使用ZeroMQ编程，首先是套接字的设计，而套接字传输的消息只能是指定长度的二进制数据块，需要定义具体的分布式组件程序能够互相理解的消息模型。ZeroMQ 被设计成侧重于消息传输的轻量级消息中间件，缺少消息服务器存储和转发消息，所以不支持消息持久化及崩溃恢复，因此还需要考虑设计相应的高可用机制。

3.1　套接字设计

ZeroMQ不同程序间通信使用所谓的 “套接字” 进行交互，这里的套接字与TCP套接字非常相似，主要区别在于ZeroMQ的套接字可以处理与多个对等点的通信，有点像未绑定的用户数据报协议(User Datagram Protocol, UDP)套接字。望远镜控制系统实际上也是对设备的控制，因此设备控制系统和望远镜控制系统的设备都可以抽象到设备层，这里引入了管理组件(Steward)，设备和组件之间存在点到点、点到多点、多点到多点的数据事件驱动的控制与处理需求。同时需要考虑终端实时状态、异常恢复、统一时序控制及可用性探测。观测控制系统接收用户的观测计划，最终将操作指令发送给设备，可将观测控制系统看作望远镜控制系统和设备控制系统的客户端(Client)。客户端需要能够操作设备，接收设备广播的更新信息，但客户端不是直接连接到设备上，而是通过管理组件，因此管理组件需要为客户端创建一个接收请求命令的套接字和广播信息的套接字。对于设备来说，需要接收来自客户端的命令，以及客户端的广播信息，管理组件也需要为设备创建一个接收请求命令的套接字和广播信息的套接字。如图2为望远镜控制系统和设备控制系统内部的ZeroMQ通信套接字设计。

图2望远镜控制系统和设备控制系统内部的ZeroMQ通信套接字设计
Fig.2The definition of sockets for TCS and ICS based on ZeroMQ

客户端使用DEALER类型套接字连接到管理组件(Steward)专为客户端通信的ROUTER类型的套接字后，会接收来自Steward的PUB接口的连接信息，再使用SUB接口订阅广播消息。设备连接到Steward 专为设备连接的ROUTER类型的套接字，上报设备参数值，定时发送心跳，获得管理组件的PUB地址和端口，并连接到PUB端接受广播消息。对单个设备的操作，客户端连接到管理组件，查到设备的地址信息，进而发送操作命令，对于多个设备的并发控制，可以通过管理组件的PUB接口广播信息。

3.2　消息模型

ZMQ支持多帧消息，即在一条消息中保存多个消息帧，这里利用多帧消息，格式化消息实现控制。在ZeroMQ中，套接字默认是瞬时的，它所连接的套接字(如ROUTER)会生成一个UUID标识消息的来源，与之相关联。ROUTER套接字在所有收到的消息前添加消息来源的地址，为了客户端能操作特定的设备，需要一个固定标识。每个设备都有一个固定的名称，在启动时可以通过参数指定，这个名称也作为设备的ROUTER套接字的标识。客户端发送特定命令到设备的消息模型定义如图3。

图3客户端发送消息和设备接收的消息模型
Fig.3The message model of commands sent by Client and commands received by Device

图3中Client_Id为自动生成的唯一标识符，Device_Id为[deviceType] + deviceName的组合，如[CCD]Camera1；FromClient和ToDevice表示来源于客户端的命令和发送到设备的命令；Devices为操作的设备名列表，多个设备名使用逗号连接；Command_Group是对命令进行分类，以便进行对消息的后续处理，详细说明如表1。Steward接收到消息后，解析消息，如果Devices为多个设备，则使用PUB套接字广播消息。

设备启动后，向Steward发送设备的注册信息(Command_Group为READY)，接收到客户端的操作指令，执行操作后，向客户端发送执行结

表1　命令消息分类Table 1　 Information of the Command_Groups

果消息(Command_Group为REPLY)。此外定时向Steward发送心跳消息(Command_Group为HEARTBEAT)，发送广播信息(Command_Group为PUB)，消息模型如图4。

图4设备发送消息和客户端接收的消息模型
Fig.4The message model of commands sent by Device and commands received by Client

3.3　压缩与序列化

网络通信时，对数据进行压缩，以减少带宽需求，特别是天文台址通常在高海拔地区，网络带宽资源特别珍贵的情况下尤为重要。使用LZ4压缩算法，在发送前对数据进行压缩，在接收端进行解压缩。LZ4属于无损压缩算法，主要特点是高速解压缩，同时支持多种语言的编程接口。ZeroMQ 被设计成侧重于消息传输的轻量级消息中间件，缺少消息服务器存储和转发消息，所以不支持消息持久化及崩溃恢复，在编写网络应用程序的时候往往需要将程序的某些数据存储在内存中，然后将其传输到网络中的另一台计算机上以实现通讯。这个将程序数据转化成能被存储并传输的格式的过程被称为 “序列化”(Serialization)，而它的逆过程则被称为 “反序列化”(Deserialization)。ZeroMQ仅解决网络通路的问题，并不提供序列化的方法，可以将对象强制转换为char*或者void*类型的数据，然后进行数据的传输，那么对于每一个类的对象，都要编写不同的代码，工作量很大，通用性不高，同时还注意CPU字节序的问题。因此需要选择合适的序列化库，同时能最小化侵入编程。使用MsgPack，MsgPack是一个基于二进制的对象序列化库，具有跨语言的特性，同样非常容易使用。操作命令和更新消息通过MsgPack进行压包，然后写入ZeroMQ的消息结构体(zmq::message_t)，通过ZeroMQ传递，最后接收者利用MsgPack进行解包，从而分析命令，获得数据。

4　高可用性

从系统的结构可以看出管理组件是整个系统的核心部件，为避免在管理组件上的单点故障，采用了主从设备的机制。设备在失去和管理组件主节点的心跳连接时，转向从节点，任一时间，某个节点会充当主节点，接收所有客户端和设备的连接请求，另一个则作为一种备机存在。主管理组件会定时将设备的连接信息通过PUB套接字广播到其他从管理组件，这样一旦主管理组件失效，客户端连接到从管理组件后依然可以立即获得设备信息。

望远镜系统中的各种设备是控制的核心，因此设备的可用性检测是望远镜控制系统中的关键一环。可用性检测是通过固定时间的检测，判断各终端的可用性，自动移除不能工作的设备，在分布式系统中叫作心跳机制。只在设备和管理组件之间使用心跳机制，客户端由于只是在操作时进行连接，不需要保持连接，没有使用心跳机制。采用ZeroMQ编程，在客户端、管理组件和设备中都需要读取多个套接字，主循环中都使用zmq_poll()非阻塞的读取方式，使用另一个计时器触发心跳。不使用主循环来控制心跳的发送，主要是因为这导致过量地发送心跳(阻塞网络)，或是发送得太少(导致节点断开，产生虚假故障)。心跳信息异步地在组件之间传递，任一组件都可以通过它判断对方已经死亡，并中止通信。心跳频率可以在文件中或启动参数中配置，并在各个节点上维持一致的频率。

5　结束语

望远镜观测控制系统是天文望远镜系统的重要组成部分。望远镜实际观测运行中，面临着观测终端设备更新和观测过程逐步复杂的需求。因此研制一套具有高效、良好扩展性的望远镜自动控制系统，以最小的代价快速完成新设备集成与系统升级，能有效降低观测人员的工作难度，提高观测效率。望远镜系统的正常运转离不开多种设备、组件之间相互配合，因此网络通信是观测控制系统的重要底层支撑。本文分析比较了传统天文控制软件中的通信机制如CORBA，DCOM和裸套接(Socket)等技术，研究使用ZeroMQ实现点到点、点到多点的数据事件驱动的通信，介绍了ZeroMQ的套接字设计、消息模型的设计和压缩与序列化技术，并研究高可用性保障在网络受限和设备故障时系统的正常运行，接下来的工作以驱动望远镜和实际观测控制为目标，实现观测计划和操作指令的转换和终端设备控制的通信，以及实现基于HTTP协议的观测控制系统和用户界面的接口。