MQ助手-是一个基于pulsar包自研实现的SprigBootStater。通过简单注解配置即可进行MQ消息生产与消费。
主要特性基于成熟pulsar包扩展，没有任何框架变动，只为简化开发使用配置简单灵活，无需复杂的配置文件：开发者可以快速注解类或者方法实现消息的生产与消费ApachePulsar云原生分布式消息流平台，当下最佳解决方案使用指引引入依赖implemetatio("cool.doudou:mq-assistat:latest")Pulsar配置pulsar:service-url:pulsar://127.0.0.1:6650subscriptio-ame:sub-celerysubscriptio-type:Shared使用方式消息订阅生产者与topic进行关联绑定/***生产者主题绑定*/@MqProducer(topics={"celery"})@CompoetpublicclassMqCompoet{}消费者与topic进行关联绑定，注意：每个消费者须绑定一个subscriptio-ame后才能进行消费/***消费者主题绑定*/@CompoetpublicclassMqCompoet{@MqCosumer(topics={"celery"})publicvoidreceive(Strigtopic,byte[]msg){System.out.pritl("cosumer:topic["+topic+"]=>"+ewStrig(msg));}}消息发送sed()：发送sedAsyc()：异步发送/***消息发送*/@AllArgsCostructor@ServicepublicclassMqServiceImpl{privateMqHelpermqHelper;publicvoidtest(){//同步StrigmsgId=mqHelper.sed("celery","hello");System.out.pritl("sed:"+msgId);//异步mqHelper.sedAsyc("celery","您好Asyc",System.out::pritl);//同步StrigmsgId=mqHelper.sed("celery",ewbyte[]{0x01,0x02,0x03,0x04});System.out.pritl("sed:"+msgId);//异步mqHelper.sedAsyc("celery",ewbyte[]{0x01,0x02,0x03,0x04},System.out::pritl);}}
点击空白处退出提示
评论