php网站开发怎么样,网站自己推广,手机上的编程软件,低调与华丽wordpress版RabbitMQ介绍 RabbitMQ既一个消息队列#xff0c;主要用来实现应用程序的异步和解耦#xff0c;同时也能起到消息缓冲#xff0c;消息分发的作用。
消息中间件在互联网公司的使用中越来越多。消息中间件最主要的作用是解耦#xff0c;中间件最标准的用法师生产者生产消息传…RabbitMQ介绍 RabbitMQ既一个消息队列主要用来实现应用程序的异步和解耦同时也能起到消息缓冲消息分发的作用。
消息中间件在互联网公司的使用中越来越多。消息中间件最主要的作用是解耦中间件最标准的用法师生产者生产消息传送到队列消费者从队列中拿去消息并处理生产者不用关心是谁来消费消费者不用关心谁在生产消息从而达到解耦的目的。在分布式系统中消息队列也会被用在很多其它的方面比如分布式事务的支持RPC的调用等等。
RabbitMQ是实现AMQP高级消息队列协义的消息中间件的一种在易用性、扩展性、高可用性方面表现不俗。**RabbitMQ主要是为了实现系统之间的双向解耦而实现的。**当生产者大量产生数据时消费者无法快速消费那么需要一个中间层来保存这个数据。 AMQP既高级消息队列协义是应用层协义的一个开放标准为面向消息的中间件设计。消息中间件主要用于组件之间的解耦消息的发送者无需知道消息使用者的存在反之亦然。AMQP的主要特征是面向消息、队列、路由包括点对点和发布/订阅、可靠性、安全。 这里有一篇文章介绍了消息队列的具体用途消息队列使用的四种场景介绍。
异步处理比如注册要发送电子邮件、通知短信、运用队列发送电子邮件、通知短信可以极大减少注册时间应用解耦比如订单系统和库存系统当订单系统完成后的操作交给消息队列后面的操作就由库存系统去完成订单系统不用理会实现应用层的解耦流量削峰比如一些秒杀活动一般会因为流量过大导致流量暴增应用挂点这时候写入消息队列如果队列长度超过最大数量则直接抛出用户请求或跳转至错误页面。消息队列中的请求再做后续处理。日志处理使用Kafka来做日志处理
可以看出消息队列的用途很大。
相关概念 通常我们谈到队列服务会有三个概念发送消息者、队列、收消息者。RabbitMQ在这个基本概念上多做了一层抽象在发消息者和队列之间加入了交换器Exchange。这样发消息者和队列就没有直接联系转而变成发消息者给交换器交换器根据调度策略再把消息给队列。 左侧p代表生产者 中间既是RabbitMQ其中包括交换机和队列。 右侧C 代表消费者也就是往RabbitMQ拿消息的程序。
那么其中比较重要的概念有4个分别是虚拟主机交换机队列和绑定。
四个比较重要的概念
虚拟主机一个虚拟主机有一组交换机、队列和绑定。 为什么需要多个虚拟主机 很简单RabbitMQ当中用户只能从虚拟主机的粒度进行权限控制。因此如果要禁止A组访问B组的交换机/队列/绑定必须为A和B分别创建一个虚拟主机。每一个RabbitMQ服务器都有一个默认的虚拟主机“/”。交换机Exchange用于转发消息但是它不会做存储如果没有队列绑定到交换机的话它会直接丢弃掉发送者发过来的消息。这里有一个比较重要的概念路由键。消息到交换机的时候交换机会转发给对应的队列那么究竟转发到哪个队列就要根据该路由键。绑定也就是交换机需要和队列相绑定这其中如上图所示是多对多的关系。
交换机
交换机的功能主要是接收消息并且转发到绑定的队列交换机不存储消息在启用ack模式后交换机找不到队列会返回错误。交换机有四种类型DirecttopicHeaders Fanout
Directdirect 类型的行为是“先匹配再投送”。既在绑定时设定一个 路由键routing_key消息的路由键匹配时才会被交换机投送到绑定的队列中去。Topic按规则转发消息最灵活Headers设置header attribute参数类型的交换机Fanout转发消息到所有绑定队列
Direct Exchange
是RabbitMQ 默认的交换机模式也是最简单的模式根据key全文匹配去寻找队列。 第一个X 到 Q1 就有一个binding key名字为orangeX到Q2 就有2 个binding key名字为black和green。当消息队中的路由键和这个 binding key 对应上时那么就知道该消息去到哪一个队列了。
PS为什么X到Q2 要有blackgreen 2个binding key呢一个不就行了嘛 这个主要是因为可能又有Q3而Q3只接受black信息而Q2不仅接受black信息还接受green信息。
Topic Exchange
Topic Exchange 转发消息主要根据通配符。 在这种交换机下队列和交换机的绑定会定义一种路由模式通配符要在这种路由模式和路由键之间匹配后交换机才能转发消息。
在这种路由模式下
路由键必须是一串字符用句号.隔开比如说 agreements. us 或者 agreements.eu.stockholm 等。路由模式必须包含一个 星号( * )主要用于匹配路由键指定位置的一个单词。 比如说一个路由模式是这样子agreements…b.*那么就只能匹配路由键是这样子的第一个单词是 agreements第四个单词是 b。 井号#就表示相当于一个或者多个单词例如一个匹配模式是agreements.eu.berlin.#那么以agreements.eu.berlin开头的路由键都是可以的。
具体代码发送的时候还是一样第一个参数表示交换机第二个参数表示路由键第三个参数既消息。
rabbitTemplate.convertAndSend(testTopicExchange,key1.a.c.key2, this is RabbitMQ!);topic 和 Direct 类似只是在匹配上支持了“模式”在“点分”的路由键 形式中可以使用两个通配符
* 表示一个词。# 表示0个或多个词。
Headers Exchange
headers 也是根据规则匹配, 相较于 direct 和 topic 固定地使用 routing_key , headers 则是一个自定义匹配规则的类型. 在队列与交换器绑定时, 会设定一组键值对规则, 消息中也包括一组键值对( headers 属性), 当这些键值对有一对, 或全部匹配时, 消息被投送到对应队列.
fanout Exchange
Fanout Exchange 消息广播的模式不管路由键或者是路由模式会把消息发给绑定给它的全部队列如果配置了routing_key会被忽略。
Spring boot 集成 RabbitMQ Spring boot 集成RabbitMQ 非常简单如果只是简单的使用配置非常少 Spring boot 提供了Spring-boot-starter-amqp 项目对消息各种支持。
简单使用
如果没有安装RabbitMQ服务器我们要先安装服务器Windows下安装和部署RabbitMQ消息队列服务器 1、配置pom包主要是添加Spring-boot-starter-amqp 的支持、配置文件
dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-amqp/artifactId
/dependency配置rabbitmq的安装地址、端口以及账户信息
spring.application.nameSpring-boot-rabbitmqspring.rabbitmq.host192.168.0.86
spring.rabbitmq.port5672
spring.rabbitmq.usernameadmin
spring.rabbitmq.password1234562、队列配置
Configuration
public class RabbitConfig {Beanpublic Queue Queue() {return new Queue(hello);}}3、发送者 rebbitTemplate是springboot提供的默认实现。
public class HelloSender {Autowiredprivate AmqpTemplate rabbitTemplate;public void send() {String context hello new Date();System.out.println(Sender : context);this.rabbitTemplate.convertAndSend(hello, context);}
}4、接收者
Component
RabbitListener(queues hello)
public class HelloReceiver {RabbitHandlerpublic void process(String hello) {System.out.println(Receiver : hello);}}5、测试
RunWith(SpringRunner.class)
SpringBootTest
public class RabbitMqHelloTest {Autowiredprivate HelloSender helloSender;Testpublic void hello() throws Exception {helloSender.send();}}注意发送者和接收者的queue name必须一致不然不能接收。
高级使用
对象的支持
Spring boot已经完美的支持对象的发送和接收不需要额外配置。
Topic Exchange
topic 是RabbitMQ中最灵活的一种方式可以根据routing_key自由的绑定不同的队列 首先对topic规则配置这里使用两个队列来测试。
Configuration
public class TopicRabbitConfig {final static String message topic.message;final static String messages topic.messages;Beanpublic Queue queueMessage() {return new Queue(TopicRabbitConfig.message);}Beanpublic Queue queueMessages() {return new Queue(TopicRabbitConfig.messages);}BeanTopicExchange exchange() {return new TopicExchange(exchange);}BeanBinding bindingExchangeMessage(Queue queueMessage, TopicExchange exchange) {return BindingBuilder.bind(queueMessage).to(exchange).with(topic.message);}BeanBinding bindingExchangeMessages(Queue queueMessages, TopicExchange exchange) {return BindingBuilder.bind(queueMessages).to(exchange).with(topic.#);}
}使用queueMessages同时匹配两个队列queueMessage值匹配“topic.message”队列
public void send1() {String context hi, i am message 1;System.out.println(Sender : context);this.rabbitTemplate.convertAndSend(exchange, topic.message, context);
}public void send2() {String context hi, i am messages 2;System.out.println(Sender : context);this.rabbitTemplate.convertAndSend(exchange, topic.messages, context);
}发送send1会匹配到topic.#和topic.message 两个Receiver都可以接收到消息发送send2只有topic.#可以匹配所有只有Receiver2监听到的消息。
Fanout Exchange
Fanout 就是我们熟悉的广播模式或者订阅模式给Fanout交换机发送消息绑定了这个交换机的所有队列都收到这个消息。 Fanout 相关配置
Configuration
public class FanoutRabbitConfig {Beanpublic Queue AMessage() {return new Queue(fanout.A);}Beanpublic Queue BMessage() {return new Queue(fanout.B);}Beanpublic Queue CMessage() {return new Queue(fanout.C);}BeanFanoutExchange fanoutExchange() {return new FanoutExchange(fanoutExchange);}BeanBinding bindingExchangeA(Queue AMessage,FanoutExchange fanoutExchange) {return BindingBuilder.bind(AMessage).to(fanoutExchange);}BeanBinding bindingExchangeB(Queue BMessage, FanoutExchange fanoutExchange) {return BindingBuilder.bind(BMessage).to(fanoutExchange);}BeanBinding bindingExchangeC(Queue CMessage, FanoutExchange fanoutExchange) {return BindingBuilder.bind(CMessage).to(fanoutExchange);}
}这里使用了A、B、C三个队列绑定到Fanout交换机上面发送端的routing_key写任何字符都会被忽略
public void send() {String context hi, fanout msg ;System.out.println(Sender : context);this.rabbitTemplate.convertAndSend(fanoutExchange,, context); //第二个参数为路由键写任何值都被忽略
}结果如下
Sender : hi, fanout msg
...
fanout Receiver B: hi, fanout msg
fanout Receiver A : hi, fanout msg
fanout Receiver C: hi, fanout msg 结果说明绑定到fanout交换机上面的队列都收到了消息。
码云示例
