1、pom
<dependency>
<groupId>com.aliyun.openservices</groupId>
<artifactId>ons-client</artifactId>
<version>1.8.8.5.Final</version>
</dependency>
2、mq配置
package com.pojo.prj.config;
import com.aliyun.openservices.ons.api.PropertyKeyConst;
import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;
import java.util.Properties;
@Configuration
@ConfigurationProperties(prefix = "rocketmq")
@Data
public class RocketmqConfig {
//阿里云账号对应的accessKey
private String accessKey;
//阿里云账号对应的secretKey
private String secretKey;
//阿里云rocketmq的接入点
private String nameSrvAddr;
//topic
private String topic;
//消费组id
private String group
最后
以上就是复杂草莓最近收集整理的关于springboot整合阿里云rocketmq的tcp连接接入的全部内容,更多相关springboot整合阿里云rocketmq内容请搜索靠谱客的其他文章。
本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
发表评论 取消回复