文档章节

Rabbitmq---消息队列

A
 Ala6
发布于 11/14 21:26
字数 1993
阅读 443
收藏 29

一 . MQ:message queue

  消息队列的作用:   1 通信解耦   2 高峰限流

原理分析:

一开始,认证系统是强耦合的,A系统传递认证系统消息接收计算结果的过程中

  1 传给认证系统

  2 认证系统计算

  3 返回计算结果

  4 读取A系统逻辑

只要当前计算没有完成,对于认证系统来讲消耗线程资源.并存在强耦合现象

有了消息队列,每一次连接不管是生成消息还是消费消息,都有各自的逻辑与其他逻辑无关--通信解耦

 

  通信强耦合的情况下高峰访问拒绝,达到了高峰限流的效果

二 . Rabbitmq

  1 rabbitmq的结构(组件)

    外部: 生产者和消费者

    生产者:对于消息来讲,生成消息客户端是生产者

    消费者:消费消息执行消费后的逻辑的客户端是消费者

  客户端可以使用各种其他技术或者语言 都不是rabbitmq自身的技术

  2 rabbitmq内部组件

  connection:基于底层通信逻辑的长连接

  channel:基于长连接创建的;可以在一次长连接的基础上多次频繁的创建和销毁,占用资源非常少

  交换机Exchange   优点:并发能力高 并发稳定

    客户端连接发送消息,多种情况都需要并发的发送,如果从客户端执行并发的发送逻辑,rabbitmq的并发能力就限制在了客户端

    exchange基于erlang语言开发的(并发,可控制线程)

  queue:rabbitmq中的队列,根据不同的情况队列可以完成不同的工作

  使用场景:在项目中,将一些无需即时返回且耗时的操作提取出来,进行了异步处理,而这种异步处理的方式大大的节省了服务器的请求响应时间,从而提高了系统的吞吐量。

三 . rabbitmq的五种工作模式

  1 简单模式

  

  1 )一个生产者将消息交给默认的交换机(AMQP default)

  2 )交换机获取消息后交给绑定的这个生产者的队列(其中关系是通过队列名称完成的)

  3 )监听当前队列的消费者获取消息,执行消费逻辑

    应用场景:短信聊天

  2 工作模式(资源争抢)

  

  1 )生产者将消息交给交换机

  2 )交换机交给绑定的队列

  3 )队列由多个消费者同时监听,只有其中一个能获取者一条消息,形成了资源的争抢,谁的资源空闲大,争抢到的可能越大

  3 发布订阅(publish/fanout)

  1 )生产者扔给交换机消息
  2 )交换机根据自身的类型(fanout)将会把所有消息复制同步到所有与其绑定的队列
  3 )每个队列可以有一个消费者,接收消息进行消费逻辑

  4 路由模式(routing/dircet)

  

  1 )生产者还是将消息发送给交换机,消息携带具体的路由key(routingKey)

  2 )交换机类型direct,将接受到消息中的routingKey与之绑定队列的routingKey比对

  3 )消费者监听一个队列,获取消息,执行消费逻辑.

  5 topic主题模式

  

  1 )生产端发送消息,消息携带具体的路由key
  2 )交换机的类型topic 
  3 )队列绑定交换机不在使用具体的路由key而是一个范围值

 与路由模式的区别:路由模式中的queue绑定携带的具体的key值,路由细化划分,topic主题模式queue携带的key是一个范围的匹配,某一类消息的获取

   

四 . rabbitmq的安装及虚拟机和用户名的创建

  https://www.cnblogs.com/nanlinghan/p/9960361.html

五 . springboot整合rabbitmq

  整合思路:1 )配置信息 2 )配置类 (明确初始化对象,初始化一个工厂,就从工厂获取连接;生产端逻辑实现简单;) 3 )二次封装

  springboot
      自动配置:扫描同名,下级包
           根据依赖的文件自动配置需要的内容(一旦依赖了jdbc,不配置datasource就报错)
      springboot就会根据依赖的amqp自动创建连接消息队列的内部connection,封装一个对外调用的对象rabbitTemplate模板对象;做生产逻辑
      利用底层连接,实现异步非阻塞监听,只需要在方法上使用注解,就可以将监听内容传递给方法的参数;

           欢迎工作一到五年的Java工程师朋友们加入Java架构交流圈:874811168 圈内提供免费的Java架构学习资料(里面有高可用、高并发、高性能及分布式、Jvm性能调优、Spring源码,MyBatis,Netty,Redis,Kafka,Mysql,Zookeeper,Tomcat,Docker,Dubbo,Nginx等多个知识点的架构资料)合理利用自己每一分每一秒的时间来学习提升自己,不要再用"没有时间“来掩饰自己思想上的懒惰!趁年轻,使劲拼,给未来的自己一个交代!

1 添加依赖
    <starter-amqp>简化依赖
      groupId在maven库是一个具有结构的文件夹
      artifactId是一整个文件夹
      version是一个文件夹
       org\springframework\boot\spring-boot-starter-amqp
     <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>

2 配置文件(application.properties)

      spring.rabbitmq.host=10.9.100.26
      spring.rabbitmq.port=5672
      spring.rabbitmq.username=easymall
      spring.rabbitmq.password=123456
   spring.rabbitmq.virtualHost=/easymall

3 配置文件中声明对象

      内部完成各种连接channel等的封装
      声明需要的队列和交换机
     配置类中完成这种声明,并且交换机,队列的对象由框架维护,何时调用由业务逻辑决定;

1 package com.jt.config;
 2 import org.springframework.amqp.core.Binding;
 3 import org.springframework.amqp.core.BindingBuilder;
 4 import org.springframework.amqp.core.DirectExchange;
 5 import org.springframework.amqp.core.Queue;
 6 import org.springframework.context.annotation.Bean;
 7 import org.springframework.context.annotation.Configuration;
 8 @Configuration
 9 public class RabbitmqConfig {
10     //路由模式做案例
11     //准备2个queue,1个路由交换机
12     //声明2个队列
13     @Bean 
14     public Queue queue01(){
15         //org.springframework.amqp.core.
16         return new Queue("springboot-q1", false);
17     }  
18     @Bean 
19     public Queue queue02(){
20         //org.springframework.amqp.core.
21         return new Queue("springboot-q2", false);
22     } 
23     @Bean//声明交换机
24     public DirectExchange ex(){
25         return new DirectExchange("springboot-ex");
26     }
27     //声明绑定关系
28     @Bean
29     public Binding bind01(){
30         return BindingBuilder.
31                 bind(queue01()).to(ex()).with("item.add");
32     }
33     @Bean
34     public Binding bind02(){
35         return BindingBuilder.
36                 bind(queue02()).to(ex()).with("item.update");}}

4 编写生成者代码

      编写到一个controller中,接收访问的参数,利用参数作为消息发送到交换机携带路由key

1 package com.jt.controller;
 2 
 3 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 4 import org.springframework.beans.factory.annotation.Autowired;
 5 import org.springframework.stereotype.Controller;
 6 import org.springframework.web.bind.annotation.RequestMapping;
 7 import org.springframework.web.bind.annotation.ResponseBody;
    欢迎工作一到五年的Java工程师朋友们加入Java架构交流圈:874811168
 8 
 9 @Controller
10 public class MsgController {
11     @Autowired
12     private RabbitTemplate rabbit;
13     /*
14      * 接收消息msg
15      */
16     @RequestMapping("msg")
17     @ResponseBody
18     public String sendMsg(String msg,String routingKey){
19         //注入自动配置的rabbitTemplate对象发送消息
20         rabbit.convertAndSend("springboot-ex", routingKey, msg);
21         return "success";
22     }
23 }

5 消费端

  2个消费者,监听2个队列,发送的不同路由key会在不同的消费端完成消费逻辑

1 package com.jt.component;
 2 
 3 import org.springframework.amqp.rabbit.annotation.RabbitListener;
 4 import org.springframework.stereotype.Component;
 5 @Component
 6 public class ConsumerCon {
 7     //实现消费逻辑,需要完成异步监听
 8     //监听注解会绑定队列的消费者和当前的方法,一旦消费者获取消息,会把消息内容传递给
 9     //自定义的方法参数msg
       //欢迎工作一到五年的Java工程师朋友们加入Java架构交流圈:874811168
10     @RabbitListener(queues="springboot-q1")
11     public void process01(String msg){
12         System.out.println("消费者1接收商品新增:"+msg);
13     }
14     
15     @RabbitListener(queues="springboot-q2")
16     public void process02(String msg){
17         System.out.println("消费者2接收到商品更新:"+msg);
18     }
19 }

© 著作权归作者所有

共有 人打赏支持
A
粉丝 51
博文 58
码字总数 144072
作品 0
黄浦
私信 提问
加载中

评论(2)

乱世当空
写的很清楚~
O
OSC_kUWFQt
写的很清楚~
RabbitMQ实战2.消息轮询、响应、持久化

继上篇 RabbitMQ实战1.消息代理 消息轮询分配 如果生产者投递的消息需要运行相当长的时间,且有多个消费者在处理消息,那么RabbitMQ是怎么分配消息的? 新建 new_task.py 新建 worker.py 在三...

章鱼喵_
08/09
0
0
RabbitMQ中的工作队列(work queues)

工作队列的设计思想:避免立即执行资源密集型任务。 我们将任务封装为消息并将其发送到队列,消费者从队列中取出任务并执行任务。当我们开启了多个消费者的时候,任务将在他们之间共享。 循环...

m0_37884977
05/17
0
0
消息中间件—RabbitMQ(集群原理与搭建篇)

摘要:实际生产应用中都会采用消息队列的集群方案,如果选择RabbitMQ那么有必要了解下它的集群方案原理 一般来说,如果只是为了学习RabbitMQ或者验证业务工程的正确性那么在本地环境或者测试...

癫狂侠
05/25
0
0
RabbitMQ与Redis队列对比

本文仅针对RabbitMQ与Redis做队列应用时的情况进行对比 具体采用什么方式实现,还需要取决于系统的实际需求 简要介绍 RabbitMQ RabbitMQ是实现AMQP(高级消息队列协议)的消息中间件的一种,...

凯文加内特
2015/05/20
0
0
RabbitMQ 的安装与工作模式

RabbitMQ 概念: 交换机(exchange type)把消息推送到队列的方法: fanout:不处理路由键,转发到所有绑定的队列上 direct:处理路由键,必须完全匹配,即路由键字符串相同才会转发 topic:路由...

求学ing
2014/11/11
0
0

没有更多内容

加载失败,请刷新页面

加载更多

使用CURL检测Clinet侧发起的HTTP请求各阶段时间

第一、HTTP请求的过程介绍 一个HTTP请求,涉及多个阶段 1、DNS解析域名 2、请求从Clinet路由至Server,Clinet与Server建立TCP连接 3、如果使用了HTTPS,还涉及SSL连接的建立 4、server开始准...

李玉长
4分钟前
0
0
Flume+Kafka双剑合璧玩转大数据平台日志采集

概述 大数据平台每天会产生大量的日志,处理这些日志需要特定的日志系统。 一般而言,这些系统需要具有以下特征: 构建应用系统和分析系统的桥梁,并将它们之间的关联解耦; 支持近实时的在线...

java菜分享
10分钟前
0
0
Jenkins 分布式-管理节点

什么是Jenkins的分布式构建: Jenkins的分布式构建,在Jenkins的配置中叫做节点;能够让同一套代码或项目在不同的环境分发 节点配置 系统设置 - 节点管理 - 新建节点...

以谁为师
17分钟前
0
0
图片无限轮播

<!doctype html><html lang="en"><head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, user-scalable=no, initial-scale=1.0, max......

shawnDream
19分钟前
1
0
js 在==时,则会有一些让人难以理解的陷阱

在==时,则会有一些让人难以理解的陷阱。 (function () { var undefined; undefined == null; // true 1 == true; //true 2 == true; // false 0 == false; // true 0 == ''; // true NaN ==......

之渊
22分钟前
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部