在线时间:8:00-16:00
迪恩网络APP
随时随地掌握行业动态
扫描二维码
关注迪恩网络微信公众号
开源软件名称:rocketONS-starter开源软件地址:https://gitee.com/zc_oss/rocketONS-starter开源软件介绍:rocketONS-starter介绍轻量级springBootStarter,基于阿里云ONS消息服务的一个简易封装,能快捷的创建rocketMQ的生产者和消费者,实现应用之间的消息传递. 软件架构基于spring的ApplicationContext容器管理,自动扫描consumer监听器,并注册启动消费者,来回调接受来自阿里云ONS服务传递分发的消息.可根据配置文件动态创建消费者和生产者,自定义消费者的启停开关,自动序列化和解析消息实体. 安装教程 <dependency> <groupId>io.gitee.zhucan123</groupId> <artifactId>rocket-ons-spring-boot-starter</artifactId> <version>1.0.8</version> </dependency> 使用说明1. 项目加入配置rocket: address: http://xxxx secretKey: xxxx accessKey: xxxx topic: xxxx groupSuffix: GID_ enable: true delay: 1000
1.1 在主程序上面加上@EnableRocketONS来开启使用,或配置类中设置 rocket.enable = true@EnableRocketONSpublic class App { public static void main(String[] args) { SpringApplication.run(App.class, args); }} 2. consumer的使用示例代码@ConsumerListener(tags = "msg_tag", consumers = 2)@OnsConfiguration(topic = "topic-example", group = "GID_${example.group}")public class ExampleConsumerListener implements RocketListener<MessageData> { @Override public Action consume(Message message, MessageData messageBody, ConsumeContext consumeContext) { // do someThing! return Action.CommitMessage; }}
3. 生产者的使用@OnsConfiguration(topic = "topic-example", group = "group-example")public class ExampleProducer extends DefaultProducerProxy {}
参与贡献
码云特技
|
请发表评论