特性与策略 | 发产与消费 | 多通道示例 | 生态 / Solon Cloud Event [传送] ### 1、情况简介 所谓多通道，即多个插件同时使用。比如用 mqtt 做物联网消息的处理，再用 rabbitmq 做为业务系统的消息处理。这是一直有的特性，却忘了完善资料，罪过。 ### 2、引入 maven 包 ```xml org.noear mqtt-solon-cloud-plugin org.noear rabbitmq-solon-cloud-plugin ``` ### 3、添加应用配置示例 ```yaml # mqtt 做为默认通道 //不需要指定 event.channel solon.cloud.mqtt: server: "tcp://localhost:41883" #mqtt服务地址 # rabbitmq 做为 biz 通道 //指定了 event.channel solon.cloud.rabbitmq: server: localhost:5672 #rabbitmq 服务地址 username: root #rabbitmq 链接账号 password: 123456 #rabbitmq 链接密码 event: channel: "biz" ``` ### 4、添加定阅与发送的代码示例 订阅消息 ```java //订阅 biz 通道的消息 @CloudEvent(value = "hello.biz", channel = "biz") public class EVENT_hello_demo2 implements CloudEventHandler { @Override public boolean handle(Event event) throws Throwable { System.out.println(LocalDateTime.now() + ONode.stringify(event)); return event.times() > 2; } } //订阅 默认 通道的消息（不指定通道，即为默认） @CloudEvent("hello.mtt") public class EVENT_hello_demo2 implements CloudEventHandler { @Override public boolean handle(Event event) throws Throwable { System.out.println(LocalDateTime.now() + ONode.stringify(event)); return event.times() > 2; } } ``` 发送消息 ```java //发送 biz 通道的消息 Event event = new Event("hello.biz", msg).channel("biz"); return CloudClient.event().publish(event); //发送 默认 通道的消息（不指定通道，即为默认） Event event = new Event("hello.mtt", msg).qos(1).retained(true); return CloudClient.event().publish(event); ``` ### 5、使用时有什么区别？ 就是多了 channel 需要指定，没有指定时则为默认。 ### 6、示例源码 [https://gitee.com/noear/solon-examples/tree/main/9.Solon-Cloud/demo9039-event_multi_channel2](https://gitee.com/noear/solon-examples/tree/main/9.Solon-Cloud/demo9039-event_multi_channel2)