首页 > 其他分享 >RabbitMQ 发送消息到交换机

RabbitMQ 发送消息到交换机

时间:2023-12-02 19:45:27浏览次数:27  
标签:String 队列 RabbitMQ 发送 交换机 消息 msg

发送消息到交换机的代码:

@GetMapping("/mq02")//发送消息给交换机
public void mq02(){
String exchangeName = "hmall.fanout";
String msg = "hello, 每个人";
//三个参数:交换机名称、RoutingKey(暂时为空)、要发送的消息
rabbitTemplate.convertAndSend(exchangeName, null, msg);
}

回顾:发送消息到队列的代码:

@GetMapping("/mq01")//发送消息给队列
public void mq01(){
String queueName = "simple.queue";
String msg = "你好态爷";
rabbitTemplate.convertAndSend(queueName, msg);//队列名称、要发送的消息
}

标签:String,队列,RabbitMQ,发送,交换机,消息,msg
From: https://www.cnblogs.com/gagaya2/p/17872109.html

相关文章

  • RabbitMQ Fanout交换机
     容易搞混的点:1.假如publisher给Fanout交换机发送了一条消息,那么Fanout交换机会给每一个绑定到它身上的队列都发送这条消息,也就是说有多少个队列跟它绑定了,这条消息就有几份,每个队列都收到一份。2.假如一个队列绑定了多个消费者,那么该队列在给消费者投递消息时就是轮询,一......
  • rabbitmq的推(push)拉(pull)模式介绍及代码实现
    在rabbitmq中有两种消息处理的模式,一种是推模式/订阅模式/投递模式(也叫push模式),消费者调用channel.basicConsume方法订阅队列后,由RabbitMQ主动将消息推送给订阅队列的消费者;另一种是拉模式/检索模式(也叫pull模式),需要消费者调用channel.basicGet方法,主动从指定队列中拉取消息。推......
  • RabbitMQ work模型
    默认情况下,MQ队列如果绑定了多个消费者,那么队列在投递消息时就是轮询,一人投递一个(并且一条消息只能投递给监听该队列的某一个消费者)在一个MQ队列上绑定多个消费者的目的是加快队列中消息的处理效率,防止队列中消息的堆积问题。 注:要在消费者的application.yml文件中加上这个......
  • RabbitMQ 接收队列的消息
     代码示例:注:要把这个类加上Component注解packagecom.itheima.amqp_listener;importorg.springframework.amqp.rabbit.annotation.RabbitListener;importorg.springframework.stereotype.Component;@ComponentpublicclassMQListener{@RabbitListener(queues="simpl......
  • RabbitMQ 发送消息到队列(交换机不参与的那种)
    1.导包<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency>2.在application.yml文件里编写配置信息spring:rabbitmq:host:192.168.88.130port:5672......
  • post为什么会发送两次请求?
    同源策略在浏览器中,内容是很开放的,任何资源都可以接入其中,如JavaScript文件、图片、音频、视频等资源,甚至可以下载其他站点的可执行文件。但也不是说浏览器就是完全自由的,如果不加以控制,就会出现一些不可控的局面,例如会出现一些安全问题,如:跨站脚本攻击(XSS)SQL注入攻击OS......
  • C#的HttpWebRequest发送form-data数据
    以下是使用C#中的HttpWebRequest发送post请求的示例代码,请求头为form-data,可以上传文件。你可以将它封装成一个通用的方法。1publicstaticstringHttpPost(stringurl,Dictionary<string,string>parameters,Dictionary<string,string>files)2{stringstrBou......
  • 【Spring】SpringBoot+RabbitMQ(direct/fanout/topic)の構築方法
     ■POM.xmlの中で、下記の内容を追加<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency><dependency>......
  • axios(ajax)发送请求响应码200,但获取不到数据,无法加载响应数据: No datafound for res
    问题截图:没有响应数据控制台报错其实是由于浏览器的跨域资源共享(CORS)策略导致,前后端跨域请求是不行的。什么是域,看页面的url,比如https://www.baidu.com/下的网页都是属于baidu.com这个域。如果你是和我一样是从本地文件打开html的方式来调试ajax,那么一定会出现这个问题,因为本......
  • SkyWalking报警发送到钉钉群
    By tristan-tsl | Sunday,December13,2020Tags| UserManual这篇文章暂时不讲告警策略,直接看默认情况下激活的告警目标以及钉钉上的告警效果SkyWalking内置了很多默认的告警策略,然后根据告警策略生成告警目标,我们可以很容易的在界面上看到当我们想去让这些告......