ToB企服应用市场:ToB评测及商务社交产业平台

标题: rabbitmq笔记 [打印本页]
作者: 知者何南    时间: 2024-9-1 04:22
标题: rabbitmq笔记
一、消息队列

1、消息队列的作用

可以异步处理请求

同步处理的缺点：

异步处理的利益

注意：并不是把全部交互方式都改成异步 ，强关联调用还是通过OpenFeign进行 同步调用，弱关联、可独立拆分出来的功能利用消息队列进行异步调用
2、rabbitmq概述


建立TCP连接必要三次握手，反复确认。 所以如果每一次访问RabbitMQ服务器都建立一个Connection开销会极大，效率低下。 所以Channel就是在一个已经建立的Connection中建立的逻辑连接。 如果应用步伐支持多线程，那么每个线程创建一个单独的Channel进行通讯。 每个Channel都有自己的id，Channel之间是完全隔离的。
二、原生方式操作RabbitMQ

生产者
  1. public class Producer {
  2.      
  3.   
  4.     public static void main(String[] args) throws Exception {
  5.      
  6.   
  7.         // 创建连接工厂  
  8.         ConnectionFactory connectionFactory = new ConnectionFactory();  
  9.   
  10.         // 设置主机地址  
  11.         connectionFactory.setHost("192.168.200.100");  
  12.   
  13.         // 设置连接端口号：默认为 5672
  14.         connectionFactory.setPort(5672);
  15.   
  16.         // 虚拟主机名称：默认为 /
  17.         connectionFactory.setVirtualHost("/");
  18.   
  19.         // 设置连接用户名；默认为guest  
  20.         connectionFactory.setUsername("guest");
  21.   
  22.         // 设置连接密码；默认为guest  
  23.         connectionFactory.setPassword("123456");
  24.   
  25.         // 创建连接  
  26.         Connection connection = connectionFactory.newConnection();  
  27.   
  28.         // 创建频道  
  29.         Channel channel = connection.createChannel();  
  30.   
  31.         // 声明（创建）队列  
  32.         // queue      参数1：队列名称  
  33.         // durable    参数2：是否定义持久化队列，当 MQ 重启之后还在  
  34.         // exclusive  参数3：是否独占本次连接。若独占，只能有一个消费者监听这个队列且 Connection 关闭时删除这个队列  
  35.         // autoDelete 参数4：是否在不使用的时候自动删除队列，也就是在没有Consumer时自动删除  
  36.         // arguments  参数5：队列其它参数  
  37.         channel.queueDeclare("simple_queue", true, false, false, null);  
  38.   
  39.         // 要发送的信息  
  40.         String message = "你好；小兔子！";  
  41.   
  42.         // 参数1：交换机名称,如果没有指定则使用默认Default Exchange  
  43.         // 参数2：路由key,简单模式可以传递队列名称  
  44.         // 参数3：配置信息  
  45.         // 参数4：消息内容  
  46.         channel.basicPublish("", "simple_queue", null, message.getBytes());  
  47.   
  48.         System.out.println("已发送消息：" + message);  
  49.   
  50.         // 关闭资源  
  51.         channel.close();  
  52.         connection.close();  
  53.   
  54.     }  
  55.   
  56. }
复制代码
消费者
  1. public class Consumer {
  2.      
  3.   
  4.     public static void main(String[] args) throws Exception {
  5.      
  6.   
  7.         // 1.创建连接工厂  
  8.         ConnectionFactory factory = new ConnectionFactory();  
  9.   
  10.         // 2. 设置参数  
  11.         factory.setHost
复制代码
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。



欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/) Powered by Discuz! X3.4