我是靠谱客的博主 复杂草莓,这篇文章主要介绍springboot整合阿里云rocketmq的tcp连接接入,现在分享给大家,希望可以做个参考。

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内容请搜索靠谱客的其他文章。

本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
点赞(138)

评论列表共有 0 条评论

立即
投稿
返回
顶部