Solon v2.7.5

aliyun-ons-solon-cloud-plugin

</> markdown 
<dependency>
    <groupId>org.noear</groupId>
    <artifactId>aliyun-ons-solon-cloud-plugin</artifactId>
</dependency>

1、描述

分布式扩展插件。基于 rocketmq client (ons sdk)适配的 solon cloud 插件。提供事件总线服务。

2、能力支持

云端能力接口说明备注
CloudEventService云端事件服务支持 namespace；支持 group

3、配置示例

solon.app:
  group: demo       #配置服务使用的默认组
  name: helloproducer    #发现服务使用的应用名

solon.cloud.aliyun.ons:
  server: http://MQ_IN**************.mq.cn-qingdao.aliyuncs.com:80   #TCP地址
  accessKey: LTAI5t6tC2**********
  secretKey: MLaRt1yTRdfzt2***********

4、应用示例

//订阅
@CloudEvent(topic="hello.demo2", group = "test")
public class EVENT_hello_demo2 implements CloudEventHandler {
    @Override
    public boolean handle(Event event) throws Throwable {
        System.out.println(LocalDateTime.now() + ONode.stringify(event));
        return true;
    }
}

//发布（找个地方安放一下）
Event event = new Event("hello.demo2", msg).group("test");
return CloudClient.event().publish(event);

5、演示项目