springboot集成购买阿里的rocketmq

上篇文章介绍了springboot集成自建rocketmq双主双从

https://blog.csdn.net/C18298182575/article/details/121381621

这里说集成购买的rocketmq，主要区别在哪

1.多了一个client-ip，之前这个是不需要配置的，默认取本机ip

2.access-key secret-key，这是对接阿里，腾讯等必须的密钥，配置即可

3.在代码层面实现以上两个配置

配置

rocketmq:name-server: "192.168.*:9876;192.168.*:9876"access-channel: CLOUDclient:ip: ${HOST_IP:${spring.cloud.client.ip-address}}producer:access-key: "*"secret-key: "*"#发送消息超时时间,默认3000sendMsgTimeout: 3000#发送消息失败重试次数，默认2retryTimesWhenSendFailed: 2algorithm:producerGroup: algorithm-api#跟接受的集群组有关，同一个集群组所采用的comsumerGroup是一致的group: GID_pushconsumer:access-key: "*"secret-key: "*"#跟生产者的topic对应consumeMessageBatchMaxSize: 3consumeThreadMin: 20consumeThreadMax: 64pay_group: GID_paytopicAndTagInfos:

之前说过

RocketMQProperties，这个配置类与配置文件属性对应，生产者消费者都有以下属性，自动实现注入bean
private String accessKey;
private String secretKey;

client-ip配置，是在消费端，如下多实现一个接口，

RocketMQPushConsumerLifecycleListener

@Component
@Slf4j
@RocketMQMessageListener(topic = "${rocketmq.consumer.topicAndTagInfos.topic}", consumerGroup = "${rocketmq.consumer.group}")
public class PayConsumer implements RocketMQListener<MessageExt>, RocketMQPushConsumerLifecycleListener {@Value("${rocketmq.client.ip}")private String hostIp;@Override@Transactional(rollbackFor = Exception.class)public void onMessage(MessageExt message) {}@Overridepublic void prepareStart(DefaultMQPushConsumer consumer) {consumer.setClientIP(hostIp);}
}

springboot集成购买阿里的rocketmq相关推荐

springboot集成阿里OSS上传文件
开发前的准备: 自己在阿里云上申请免费的Oss对象存储,新建Bucket---读写权限选择公共读,我开始这里忘了导致后来踩了小坑接下来是代码中的一些配置:我用的是springboot 1>添加 ...
Springboot2.0集成阿里云RocketMQ
介绍 RocketMQ是出自阿里巴巴的一款开源消息中间件,在设计上借鉴了Kafka,2017年成为Apache顶级项目,虽然目前社区无法和Kafka比肩,但其历经多次天猫双十一的考验,其性能和稳定是毋 ...
springboot集成阿里MNS消息队列发布订阅消息功能
声明: 上一篇文章是springboot集成阿里ons发布订阅消息,此篇文章是mns发布订阅功能先简单记录一下ons与mns有什么区别这里是在网上找的对比图: 此处为具体区别文章链接:点击打开链接 ...
springBOOT集成阿里云MQ-AMQP
序: MQ的优势就不做介绍了可以自行百度,前篇写了springboot集成本地搭建的rabbitmq组建,但是项目最后部署打算还是直接使用阿里云的AMQP,阿里云AMQP是直接可以兼容rabbitmq ...
SpringBoot集成阿里云短信服务
SpringBoot集成阿里云短信服务 1.准备工作 2.项目集成 2.1 添加依赖 2.2 配置文件 2.3 业务逻辑实现在实际项目中经常有发送短信的功能,今天进说一下对接阿里云短信服务实现短信发 ...
springboot集成阿里云短信服务，实现发送短信功能
springboot集成阿里云短信服务,实现发送短信功能准备工作: 1.登陆阿里云->进入控制台->开通短信服务(进入后根据提示开通) 2.充值(借人家平台发短信你以为不要钱的?我充了3 ...
SpringBoot集成阿里云存储OSS服务
前言该文章会先简单的介绍一下阿里云的OSS存储,然后演示如何在SpringBoot项目中集成OSS,每一步都有记录,保证初学者也能看懂. 文章目录前言 1.阿里云存储OSS是什么? 2.Sprin ...
SpringBoot 集成阿里的 FastJson
2019独角兽企业重金招聘Python工程师标准>>> SpringBoot 集成 fastjson pom.xml 中添加引用 <dependency><grou ...
kafka(组件分析整合springboot集成实战)
kafka 组件搭建 springboot集成实战 kafka 组件搭建 springboot集成实战 1.应用场景 1.1 kafka场景 1.2 kafka特性 1.3 消息对比 1.4 ...
java整合mybatis,springboot集成mybatis
# springboot集成mybatis springboot基础mybatis还是很简单的,比之前springmvc集成mybatis要少很多配置,只要大家按照步骤一步一步来,几分钟就能实现.具 ...

springboot集成购买阿里的rocketmq

springboot集成购买阿里的rocketmq相关推荐

最新文章

热门文章