异步消息

特性

• API简单学习成本低
• 支持多种消息中间件，适应性好
• 支持Topic级别的线程隔离
• 支持点对点消息，也支持广播消息
• 支持延迟消息（测试版本）

快速上手

1、在pom.xml中引入framework-message-redis模块

<dependency>
	<groupId>com.hbasesoft.framework</groupId>
	<artifactId>framework-message-redis</artifactId>
	<version>${project.parent.version}</version>
</dependency>

2、在application.yml中配置消息中间件

message: #消息服务
  model: REDIS
  redis:
   address: 127.0.0.1:6379

Event消息

1、消费者：需要实现com.hbasesoft.framework.message.core.event.EventLinsener接口，并注入进Spring容器

TestEventHandler.java

@Service
public class TestEventHandler implements EventLinsener {

    @Override
    public String[] events() {
        // 监听的Topic
        return new String[] {
            "testEvent"
        };
    }

    @Override
    public void onEmmit(final String event, final EventData data) {
        // 接收到消息后的业务处理
        ....
    }
}

2、生产者直接调用com.hbasesoft.framework.message.core.event.EventEmmiter.emmit(String, EventData)静态方法来发送消息

TestEventHandler.java

public static void main(final String[] args) {
        for (int i = 0; i < NUM_10000; i++) {

            EventData data = new EventData();
            data.put("key", "value" + i);
            EventEmmiter.emmit("testEvent", data);
        }
    }

消息的API

1. 使用com.hbasesoft.framework.message.core.MessageHelper.createMessageSubcriberFactory()来注册消费者， 消费者继承MessageSubscriber
2. 使用com.hbasesoft.framework.message.core.MessageHelper.createMessagePublisher()来创建生产者

配置参数说明