实现rabbitmq的监听消费和发送消息功能
- 下载安装rabbitmq-client
git clone https://github.com/hashio/websocket-client.git
cd rabbitmq-client
mvn clean install- 在你的应用中添加rabbitmq-client 依赖到pom.xml
<dependency>
<groupId>me.poplaris</groupId>
<artifactId>rabbitmq-client</artifactId>
<version>1.0</version>
</dependency>- 实现消息监听消费
class ApiProcessEventProcessor implements EventProcesser{
@Override
public void process(Object e) {//消费程序这里只是打印信息
System.out.println(e);
}
}- 启动控制器
String defaultHost = "127.0.0.1";
String defaultExchange = "EXCHANGE_DIRECT_TEST";
String defaultQueue = "QUEUE_TEST";
EventControlConfig config = new EventControlConfig(defaultHost);
DefaultEventController controller = DefaultEventController.getInstance(config);
EventTemplate eventTemplate = controller.getEopEventTemplate();
controller.add(defaultQueue, defaultExchange, new ApiProcessEventProcessor());
controller.start();- 发送字符串消息
eventTemplate.send(defaultQueue, defaultExchange, "hello world");- 发送序列化对象消息
eventTemplate.send(defaultQueue, defaultExchange, mockObj());参见博客
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent