以PHP代码为实例详解RabbitMQ消息队列中间件的6种模式
作者:stark张宇 发布时间:2023-06-08 12:15:53
RabbitMQ 6种工作模式
对RabbitMQ 6种工作模式(简单模式、工作模式、订阅模式、路由模式、主题模式、RPC模式)进行场景和参数进行讲解,PHP代码作为实例。
安装
客户端实现:添加扩展,执行composer.phar install
命令
{
"require": {
"php-amqplib/php-amqplib": ">=3.0"
}
}
引入包
require_once __DIR__ . '/vendor/autoload.php';
use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;
建立一个链接,
# 链接服务
$connection = new AMQPStreamConnection('127.0.0.1', 5672, 'stark', '1990@stark');
$channel = $connection->channel();
$channel->queue_declare('hello', false, false, false, false);
$msg = new AMQPMessage('Hello World!');
$channel->basic_publish($msg, '', 'hello');
echo " [x] Sent 'Hello World!'\n";
# 关闭信道和链接
$channel->close();
$connection->close();
6种模式
1.简单模式
简单模式是最简单的使用方式,P代表生产者,C代表消费者,红色的代表队列,执行过程生产者发送消息到队列,右面的消费者消费消息,需要注意的是这里没有交换机。
生产者代码(PHP)
# 声明队列
$queueName = 'MqName';
$channel->queue_declare($queueName, false, false, false, false);
queue_declare 参数说明:
队列名
检测队列是否存在,true只检测不创建,false会创建
是否持久化队列,true持久化
是否私有队列 true代表私有
当消费者断开后,队列是否自动删除
# 创建AMQP消息类型
$msg = new AMQPMessage($data,
array('delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT)
);
AMQPMessage 参数说明: 1.消息体 2.是否持久化
$channel->basic_publish($msg, '', $queueName);
basic_publish参数详解:
发送内容
交换机名称,简单模式没有使用交换机
队列名称
消费者代码:
$channel->basic_consume('hello', '', false, true, false, false, $callback);
# 阻塞队列,做监听
while ($channel->is_open()) {
$channel->wait();
}
basic_consume 参数说明:
队列名
消费者标签
AMQP标准
是否自动应答 ack true 自动应答,false应答
是否排他
?
回调函数
2.工作模式
它由一个生产者发送在队列中,work队列会分配消息给不同的消费者,让每个消费者接收到不同的消息。
工作模式的场景特别适合集群模式的异步处理,最大程度发挥每一台服务器的性能。
3.订阅模式
从订阅模式开始就使用了交换机,订阅模式使用了广播类型的交换机,它会让每个队列的消息都是一样的。
生产者把消息发送给交换机,交换机把消息发送给和它绑定的队列,让消费者来消费,需要强调的是绑定的队列获得的消息是一模一样的,订阅模式就是让所有的消费者获得相同的消息。
订阅模式使用场景,天气、微博的订阅,收费文章的订阅等等。
生产者实现:
$channel->exchange_declare('logs', 'fanout', false, false, false);
# 绑定交换机和队列
$channel->queue_bind($queue_name, 'logs');
交换机参数详解:
交换机名
交换机类型
检查是否存在
是否持久化
是否自动删除
$channel->basic_publish($msg, '这里是交换机的名字', $queueName);
消费者和生产者一样,先绑定交换机:
4.路由模式
路由模式使用direct定向类型的交换机,生产者发送一个消息到交换机,交换机根据发送来的路由键发送到相匹配的队列中,来和队列绑定的消费者进行消费。
订阅模式和路由模式的区别,订阅模式无条件的把消息发送给所有的消费者,每一个消费者收到的消息都是一样的,而路由模式对消息进行筛选发送给对应的消费者队列。
5.主题模式
主题模式采用的事topic的交换机,通过通配符进行匹配,通配符主要有*
和#
。
6.RPC模式
RabbitMQ的RPC模式,支持生产者和消费者不在同一个系统中,即允许远程调用的情况。通常,消费者作为服务端,放置在远程的系统中,提供接口,生产者调用接口,并发送消息。
RPC模式是一种远程调用的模式,因为需要http请求,因此速度比系统内部调用慢。而且rpc模式下,通常不易区分哪些是来自外部的请求,哪些是内部的请求,导致整体速度较慢。因此,不能滥用rpc模式。
最后
后面的3个模式不做详细的代码讲解了,可以看参考官网,实现起来都是差不多的。
官网:www.rabbitmq.com/getstarted.…
来源:https://juejin.cn/post/7230395983917547581
猜你喜欢
- Msg 102, Level 15, State 1, Line 3 Incorrect syntax near '+'.
- Web,全称为 World Wide Web,是 Internet 上最重要和最为人们所熟知的应用之一。Web 是指 Internet 上所
- 在开发数据库应用中,经常会遇到处理时间的问题,如查询指定时间的记录等。下面就这些常见的问题,结合自己的一些经验,和大家探讨一下这类问题。首先
- <table border="1" cellpadding="0&quo
- 本文主要介绍了一个获得当前数据库对象依赖关系的实用算法,具体示例请大家参考下文:create function&nb
- Hello, 大家好,又是我~ 大家有看过font set和一些要注意的基本问题以及通用字体族两篇文章后,应该对字体的基本有了一些了解。现
- 在面向对象的编程中,很多语言都支持函数重载,能根据函数传递的不同个数、类型的参数来做不同的操作,JS对它却不支持,需要我们额外做些小动作。在
- '************************************* '读取文件 &
- 像素误差看自己设计好上线的网站,偶尔会发觉像素行间出现了弹性空间,总在不经意间蹦出一定的差距。有些页面很难发现,比如活动类页面,这类页面多呈
- 以前写过一个标签效果,外观虽然好看,但代码不太规范,实现的方法比较繁冗。需要注意的是标签的背景图,两种状态,激活的标签背景为蓝色,反之为灰色
- 不论什么时候,只要系统带有多个设备,而这些设备的性能又各不相同,就存在从慢速设备到快速设备不断更换工作地点以改善系统性能的可能性,这就是缓存
- 以前在介绍SQL2k的时候已经提到了SQL2k对XML的支持,使用for XML语句就可以很容易的把执行的结果转化为一个XML,这样可以在很
- DateDiff 函数描述 返回两个日期之间的时间间隔。 语法 DateDiff(interval, date1, date2 [,firs
- 之前看到很多人一直都问CSS 中DIV垂直居中的问题,看来对此的需求还不少。现在就把我经验拿出来分享一下,希望大家鼓鼓掌。因为在 CSS 中
- 于是写测试程序。。。不行 下载最新的ODBC。。。还是不行 通过sql plus查询。。。咦?竟然也查不到。。。 于是,折腾。。。折腾。。。
- PHP levenshtein() 函数实例计算两个字符串之间的 Levenshtein 距离:<?php echo levensht
- 经常上网的人一定碰到过找不到页面的情况,此时是否有点让人沮丧呢,本文介绍了一些404页面设计优秀的例子,当我们撞见些好玩可爱的页面时,有时反
- 递归查询对于同一个表父子关系的计算提供了很大的方便,这个示例使用了SQL server 2005中的递归查询,使用的表是CarParts,这
- 或者说有一条命令 hostname [string],当string是不包含2950时,是true,包含2950时是false。使用Exce
- 原理:自定义javascript中的oncontextmenu事件,然后使用div层模拟菜单。知道了这个原理结合美工相信你可以做出很漂亮的自