Metrics
0
Watch 36 Star 70 Fork 26

Lockdown / HPMessageCenterC#LGPL-2.1

Sign up for free
Explore and code with more than 2 million developers,Free private repositories !:)
Sign up
高性能消息分发中心。用户只需写好restful接口,在portal里面配置消息的处理地址,消息消费者就会自动访问相关接口,完成消息任务。 spread retract

http://www.cnblogs.com/DKSL/p/8489544.html

Clone or download
Loading...
README.md

试玩地址http://60.205.185.254:8080/,用户名admin,密码123456。请按照说明配置Topic、消息消费者,并开发自己的消息处理Restful API。

HPMessageCenter

高性能消息分发中心。用户只需写好restful接口,在portal里面配置消息的处理地址,消息消费者就会自动访问相关接口,完成消息任务。

部署说明

创建数据库执行Scripts文件夹中的数据库脚本

配置数据库连接字符串

打开MessageCenter.Portal\Configuration\Data\Database.config 输入图片说明

在图片中画红线的地方修改链接字符串

配置RabbitMQ连接属性

打开MessageCenter.Portal\appsettings.json 输入图片说明

在图片中画红线的地方修改RabbitMQ地址和用户名密码

部署MessageCenter.Portal到IIS或者Docker中,即可访问

使用说明

在首页中配置App和Exchange 输入图片说明

在Topic管理页面中配置Topic信息 输入图片说明

ProcessorConfig为消息消费者处理消息的Restful接口

最后在消费者管理页面中添加Server要运行的Consumer 输入图片说明

此时,通过Publisher/Publish接口发送消息到RabbitMQ,系统中的消费者会自动访问配置的对应消息处理接口处理消息。

为什么要开发这样一个消息系统

使用此消息系统处理消息,开发者只需调用接口发送消息、写消息处理的接口,不必关心MQ的实现和使用,使开发者更关注业务,提高开发效率。

扩展性

MessageTransit模块是一个高度抽象的模块,开发者可以继承它的接口实现其他MQ(ActiveMQ和RocketMQ等)的对接。该模块还设计了IMonitor和ILogger接口,开发者可以继承IMonitor接口,自定义实现消息处理失败的短信、邮件通知等功能,继承ILogger接口,可以实现MQ断线的通知等,当然默认的RabbitMQ实现支持断线重连。

性能

一个Sever里每个Topic对应一个消费者。一个消费者一次处理一个消息,如果发生消息处理不及时的情况,可以部署多个Server,并在消费者管理页面添加对应的消息消费者。如果消息数量进一步提高,就需要同步增加消息Restful处理接口的处理能力。比如,一个消息处理接口可以处理每分钟600个并发,一个Server每个Topic每分钟只能处理100个消息,此时可以部署6个Server。消息进一步增加,消息处理接口性能达到瓶颈,增加消息处理接口的处理能力,再增加Sever数即可提高性能。

开发说明

Restful接口规范

    public ActionResult Index(string topic,string messagetext)
    {
            if (!string.IsNullOrWhiteSpace(messagetext))
            {
                messagetext = HttpUtility.UrlDecode(messagetext);
                var request = JsonConvert.DeserializeObject<IndexRequest>(messagetext);
                //你的业务代码
            }
            return Json(new
            {
                Code=0
            },JsonRequestBehavior.AllowGet);
        }
    }

接口接收两个参数,参数名固定为topic和messagetext,messagetext是你的消息的json序列化字符串。处理成功返回Code=0。其他返回视为处理失败。 Java接口编写,请加RequestBody标签,从Body里面读取topic和messagetext。

消息发送

将消息发送到HPMessageCenter的接口/Publisher/Publish即可。消息体需序列化为json格式,包含topic和messagetext两个属性。例如: 输入图片说明

如有疑问,欢迎加群讨论:

输入图片说明

Comments ( 0 )

You need to Sign in for post a comment

C#
1
https://gitee.com/dugukuangshao/HPMessageCenter.git
git@gitee.com:dugukuangshao/HPMessageCenter.git

Help Search