# HPMessageCenter

**Repository Path**: darkangle_admin/HPMessageCenter

## Basic Information

- **Project Name**: HPMessageCenter
- **Description**: 高性能消息分发中心。用户只需写好restful接口，在portal里面配置消息的处理地址，消息消费者就会自动访问相关接口，完成消息任务。
- **Primary Language**: C#
- **License**: LGPL-2.1
- **Default Branch**: master
- **Homepage**: http://www.cnblogs.com/DKSL/p/8489544.html
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 37
- **Created**: 2022-01-20
- **Last Updated**: 2022-01-20

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

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

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

### 部署说明
 **创建数据库执行Scripts文件夹中的数据库脚本** 

 **配置数据库连接字符串** 

打开MessageCenter.Portal\Configuration\Data\Database.config
![输入图片说明](https://gitee.com/uploads/images/2018/0301/161547_191f3532_13001.png "TIM图片20180301161514.png")

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

 **配置RabbitMQ连接属性** 

打开MessageCenter.Portal\appsettings.json
![输入图片说明](https://gitee.com/uploads/images/2018/0301/161838_940d3b45_13001.png "TIM截图20180301161815.png")

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

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

### 使用说明

 **在首页中配置App和Exchange** 
![输入图片说明](https://gitee.com/uploads/images/2018/0301/162227_02b643e3_13001.png "TIM截图20180301162157.png")

 **在Topic管理页面中配置Topic信息** 
![输入图片说明](https://gitee.com/uploads/images/2018/0301/162325_f9047cb3_13001.png "TIM截图20180301162251.png")

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

 **最后在消费者管理页面中添加Server要运行的Consumer** 
![输入图片说明](https://gitee.com/uploads/images/2018/0301/162558_5e4275d8_13001.png "TIM图片20180301162542.png")

此时，通过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两个属性。例如：
![输入图片说明](https://gitee.com/uploads/images/2018/0316/154630_ca6f5509_13001.png "TIM图片20180316154337.png")

### 如有疑问，欢迎加群讨论：

![输入图片说明](https://gitee.com/uploads/images/2018/0302/122833_1c1d483a_13001.png "HPMessageCenter群二维码.png")