rocketMQTempalte如何使用

2020-12-31 09:50发布

rocketMQTemplate方法有那些,消息发送与及消费的方法如何使用?

rocketMQTemplate方法有那些,消息发送与及消费的方法如何使用?

9条回答
茄子酱
2楼 · 2020-12-31 10:09

1.配置文件

#必须配置
#指定nameServer
rocketmq.nameServer=192.168.56.129:9876 
#指定发送者组名 相当于rabbitmq的virtual host 逻辑上的划分
rocketmq.producer.group=my-group

#其他可选配置
rocketmq.producer.send-message-timeout=300000
rocketmq.producer.compress-message-body-threshold=4096
rocketmq.producer.max-message-size=4194304
rocketmq.producer.retry-times-when-send-async-failed=0
rocketmq.producer.retry-next-server=true
rocketmq.producer.retry-times-when-send-failed=212345678910111213

2.发送消息

    @Autowired
    private RocketMQTemplate rocketMQTemplate;
    
    public void send(){
     //实体类User
        User user=new User(999L,"testUser");
        //发送自定对象
        rocketMQTemplate.convertAndSend("test_topic",user);
    }123456789

消费者
1.配置文件

#指定nameServer
rocketmq.nameServer=192.168.56.129:9876 
12

2.接收消息

@RocketMQMessageListener(
        topic = "test_topic",      //topic:和消费者发送的topic相同
        consumerGroup = "test_my-consumer",     //group:不用和生产者group相同
        selectorExpression = "*")        //tag
@Component  //必须注入spring容器
//泛型必须和接收的消息类型相同
public class TestListner implements RocketMQListener {

    @Override
    public void onMessage(User user) {
        System.out.println(user);
    }
}12345678910111213
  • 注意:测试的时候尽管默认集群模式 但还是多个消费者的时候重复消费


Kindery
3楼 · 2020-12-31 10:11

    • 源码地址:https://github.com/apache/rocketmq-spring

    • 进入源码目录,执行如下命令:mvn clean install

    • 执行完上述两步 依赖会自动加入本地的maven仓库

  • 附:如何把jar包加入本地maven仓库的方法

    • 文件夹路径:groupId/artifactId/version

    • 下载好要使用的jar包

    • 把要本地maven仓库该jar包的文件夹路径创建好 不然找不到指定路径(注意文件里要删干净)


是开心果呀 - 热爱生活
4楼 · 2020-12-31 10:13

首先使用@Autowired注入MongoTemplate(后面直接使用,就不特殊说明)

@Autowired

private RocketMQTemplate rocketMQTemplate;

简单使用

//发送消息public class ProducerController {    @Autowired    private RocketMQTemplate rocketMQTemplate;     public void send(){    //实体类User    User user=new User(999L,"testUser");    //发送自定义对象    rocketMQTemplate.convertAndSend("test_topic",user);//会自动转换为json格式 }}

//接收消息@Component  //必须注入spring容器@RocketMQMessageListener(        topic = "test_topic", //topic:消息的发送者使用同一个topic        consumerGroup = "test_my-consumer",     //group:不用和生产者group相同        selectorExpression = "*")    //tag // 在RocketMQ中消费者和发送者组没有关系 // 如果两个消费者groupname和topic都一样,则二者轮循接收消息 // 如果两个消费者topic一样,而group不一样,则消息变成广播机制// RocketMQListener<>泛型必须和接收的消息类型相同public class TestListner implements RocketMQListener<User> { private static final ObjectMapper MAPPER = new ObjectMapper();    @Override    public void onMessage(User user) { JsonNode jsonNode = MAPPER.readTree(user);//可以使用mapper读取json格式数据 Long userId = jsonNode.get("userId").asLong();        System.out.println(user);    }}

收获很多
5楼 · 2020-12-31 13:34
    • 源码地址:https://github.com/apache/rocketmq-spring

    • 进入源码目录,执行如下命令:mvn clean install

    • 执行完上述两步 依赖会自动加入本地的maven仓库

  • 附:如何把jar包加入本地maven仓库的方法

    • 文件夹路径:groupId/artifactId/version

    • 下载好要使用的jar包

    • 把要本地maven仓库该jar包的文件夹路径创建好 不然找不到指定路径(注意文件里要删干净)


爱煲汤的小王
6楼 · 2020-12-31 13:42
    • 源码地址:https://github.com/apache/rocketmq-spring

    • 进入源码目录,执行如下命令:mvn clean install

    • 执行完上述两步 依赖会自动加入本地的maven仓库

  • 附:如何把jar包加入本地maven仓库的方法

    • 文件夹路径:groupId/artifactId/version

    • 下载好要使用的jar包

    • 把要本地maven仓库该jar包的文件夹路径创建好 不然找不到指定路径(注意文件里要删干净)


小小收藏家
7楼 · 2021-01-02 21:01
    • 源码地址:https://github.com/apache/rocketmq-spring

    • 进入源码目录,执行如下命令:mvn clean install

    • 执行完上述两步 依赖会自动加入本地的maven仓库

  • 附:如何把jar包加入本地maven仓库的方法

    • 文件夹路径:groupId/artifactId/version

    • 下载好要使用的jar包

    • 把要本地maven仓库该jar包的文件夹路径创建好 不然找不到指定路径(注意文件里要删干净)


我的网名不再改
8楼 · 2021-01-03 13:52

1、pom.xml依赖


    org.apache.rocketmq
    rocketmq-spring-boot-starter
  2.0.3
    org.apache.rocketmq
    rocketmq-client
    4.5.1
    org.apache.rocketmq
    rocketmq-common
    4.5.1123456789101112131415

2、配置文件

# 必须配置
# 指定nameServer
rocketmq.nameServer=192.168.168.168:9876 # 指定发送者组名 相当于rabbitmq的virtual host 逻辑上的划分
rocketmq.producer.group=my-group

# 其他可选配置
#rocketmq.producer.send-message-timeout=300000#rocketmq.producer.compress-message-body-threshold=4096#rocketmq.producer.max-message-size=4194304#rocketmq.producer.retry-times-when-send-async-failed=0#rocketmq.producer.retry-next-server=true#rocketmq.producer.retry-times-when-send-failed=212345678910111213

3、RocketMQTemplate的基本方法

首先使用@Autowired注入MongoTemplate(后面直接使用,就不特殊说明)

@Autowiredprivate RocketMQTemplate rocketMQTemplate;12

简单使用

//发送消息public class ProducerController {
    @Autowired
    private RocketMQTemplate rocketMQTemplate;
    
 public void send(){
     //实体类User
     User user=new User(999L,"testUser");
     //发送自定义对象
     rocketMQTemplate.convertAndSend("test_topic",user);//会自动转换为json格式
 }}123456789101112
//接收消息@Component  //必须注入spring容器@RocketMQMessageListener(
        topic = "test_topic",      //topic:消息的发送者使用同一个topic
        consumerGroup = "test_my-consumer",     //group:不用和生产者group相同
        selectorExpression = "*")        //tag
  // 在RocketMQ中消费者和发送者组没有关系
  // 如果两个消费者groupname和topic都一样,则二者轮循接收消息
  // 如果两个消费者topic一样,而group不一样,则消息变成广播机制// RocketMQListener<>泛型必须和接收的消息类型相同public class TestListner implements RocketMQListener {

 private static final ObjectMapper MAPPER = new ObjectMapper();

    @Override
    public void onMessage(User user) {
  JsonNode jsonNode = MAPPER.readTree(user);//可以使用mapper读取json格式数据
  Long userId = jsonNode.get("userId").asLong();
        System.out.println(user);
    }}


希希
9楼 · 2021-01-03 15:30
  • 源码地址:https://github.com/apache/rocketmq-spring

  • 进入源码目录,执行如下命令:mvn clean install

  • 执行完上述两步 依赖会自动加入本地的maven仓库

  • 文件夹路径:groupId/artifactId/version

  • 下载好要使用的jar包

  • 把要本地maven仓库该jar包的文件夹路径创建好 不然找不到指定路径(注意文件里要删干净)



  • 附:如何把jar包加入本地maven仓库的方法


相关问题推荐

  • 回答 2

    Statement的execute(String query)方法用来执行任意的SQL查询,如果查询的结果是一个ResultSet,这个方法就返回true。如果结果不是ResultSet,比如insert或者update查询,它就会返回false。我们可以通过它的getResultSet方法来获取ResultSet,或者通过getUpda...

  • 回答 22

    忙的时候项目期肯定要加班 但是每天加班应该还不至于

  • 回答 108
    已采纳

    虽然Java人才越来越多,但是人才缺口也是很大的,我国对JAVA工程师的需求是所有软件工程师当中需求大的,达到全部需求量的60%-70%,所以Java市场在短时间内不可能饱和。其次,Java市场不断变化,人才需求也会不断增加。马云说过,未来的制造业要的不是石油,...

  • 回答 5
    已采纳

    工信部证书含金量较高。工信部是国务院的下属结构,具有发放资质、证书的资格。其所发放的证书具有较强的权威性,在全国范围内收到认可,含金量通常都比较高。 工信部证书,其含义也就是工信部颁发并承认的某项技能证书,是具有法律效力的,并且是国家认可的...

  • 回答 70
    已采纳

    学Java好不好找工作?看学完Java后能做些什么吧。一、大数据技术Hadoop以及其他大数据处理技术都是用Java或者其他,例如Apache的基于Java 的 HBase和Accumulo以及ElasticSearchas。但是Java在此领域并未占太大空间,但只要Hadoop和ElasticSearchas能够成长壮...

  • 回答 16
    已采纳

    就是java的基础知识啊,比如Java 集合框架;Java 多线程;线程的五种状态;Java 虚拟机;MySQL (InnoDB);Spring 相关;计算机网络;MQ 消息队列诸如此类

  • 回答 12

    #{}和${}这两个语法是为了动态传递参数而存在的,是Mybatis实现动态SQL的基础,总体上他们的作用是一致的(为了动态传参),但是在编译过程、是否自动加单引号、安全性、使用场景等方面有很多不同,下面详细比较两者间的区别:1.#{} 是 占位符 :动态解析 ...

  • 回答 62

    没问题的,专科学历也能学习Java开发的,主要看自己感不感兴趣,只要认真学,市面上的培训机构不少都是零基础课程,能跟得上,或是自己先找些资料学习一下。

  • 回答 4

    1、反射对单例模式的破坏采用反射的方式另辟蹊径实例了该类,导致程序中会存在不止一个实例。解决方案其思想就是采用一个全局变量,来标记是否已经实例化过了,如果已经实例化过了,第 二次实例化的时候,抛出异常2、clone()对单例模式的破坏当需要实现单例的...

  • 回答 5

     优点: 一、实例控制  单例模式会阻止其他对象实例化其自己的单例对象的副本,从而确保所有对象都访问唯一实例。 二、灵活性  因为类控制了实例化过程,所以类可以灵活更改实例化过程。 缺点: 一、开销  虽然数量很少,但如果每次对象请求引用时都要...

  • 回答 4

    这个主要是看你数组的长度是多少, 比如之前写过的一个程序有个数组存的是各个客户端的ip地址:string clientIp[4]={XXX, xxx, xxx, xxx};这个时候如果想把hash值对应到上面四个地址的话,就应该对4取余,这个时候p就应该为4...

  • 回答 6

     哈希表的大小 · 关键字的分布情况 · 记录的查找频率 1.直接寻址法:取关键字或关键字的某个线性函数值为散列地址。即H(key)=key或H(key) = a·key + b,其中a和b为常数(这种散列函数叫做自身函数)。...

  • 回答 6

    哈希表的大小取决于一组质数,原因是在hash函数中,你要用这些质数来做模运算(%)。而分析发现,如果不是用质数来做模运算的话,很多生活中的数据分布,会集中在某些点上。所以这里最后采用了质数做模的除数。 因为用质数做了模的除数,自然存储空间的大小也用质数了...

  • 回答 2

    是啊,哈希函数的设计至关重要,好的哈希函数会尽可能地保证计算简单和散列地址分布均匀,但是,我们需要清楚的是,数组是一块连续的固定长度的内存空间

  • 回答 3

     解码查表优化算法,seo优化

  • 回答 5

    1.对对象元素中的关键字(对象中的特有数据),进行哈希算法的运算,并得出一个具体的算法值,这个值 称为哈希值。2.哈希值就是这个元素的位置。3.如果哈希值出现冲突,再次判断这个关键字对应的对象是否相同。如果对象相同,就不存储,因为元素重复。如果对象不同,就...

没有解决我的问题,去提问