产品介绍

如何使用

导航 > 产品介绍 > 消息中间件(AMQ)

消息中间件(AMQ)

消息中间件(Adaptive Message Queue,简称:AMQ)是一个高性能的消息中间件,AMQ提供了基于Publish/Subscribe的消息通讯服务,同时AMQ可以提供服务总线功能,供其他进程可以在AMQ上进行服务注册,客户端软件可以通过CEDA API来访问AMQ上注册的服务。

 

消息中间件功能

 

■ 基于C++编写,目标实现高效的协议和通讯框架(链接到产品性能部分的AMQ订阅发布模式)

■ 支持Publish/Subscribe通讯模式

■ 支持Request/Reply通讯模式

■ 支持对消息的持久化

■ 可以动态构建TOPIC

■ 提供:C++, Java, CSharp和COM的开发API

■ 利用Registry Server可以实现集群模式和负载均衡

服务总线功能

■ 其他服务可以在AMQ上进行服务登记

■ 通过AMQ和Registry Server可以实现服务的负载均衡

■ 支持request/reply和publish/subscribe模式

■ 通过ServiceID来访问目标服务

 

AMQ中间件模式工作流程如图所示

● 使用CEDA Client API编写发布端客户端,连接到AMQ(虚线部分),然后发送消息(实线部分);

● 使用CEDA Client API编写订阅端客户端,连接到AMQ(虚线部分),并订阅消息(实线部分)。

 

AMQ服务总线模式工作流程如图所示

● 服务端应用程序(如:牌价服务,交易查询服务,自动交易服务 等)由CEDA API辅助设计完成,在启动服务时将服务端信息注册到Registry Server;

● AMQ从Registry Server读取服务信息(虚线连接部分),并与服务端应用程序建立连接(实线连接部分);

● 客户端与AMQ建立连接,AMQ根据服务端应用程序的负载均衡参数将客户端连接到服务端应用程序并实现通讯。