高端品牌车,福建seo推广方案,动易网站默认密码,api接口大全RabbitMQ是一个流行的消息队列中间件#xff0c;它提供了可靠的消息传递机制。在使用RabbitMQ时#xff0c;有几个重要的概念需要了解#xff1a;
消息队列#xff08;Message Queue#xff09;#xff1a;RabbitMQ中的核心概念之一。它是消息的缓冲区#xff0c;用于存…RabbitMQ是一个流行的消息队列中间件它提供了可靠的消息传递机制。在使用RabbitMQ时有几个重要的概念需要了解
消息队列Message QueueRabbitMQ中的核心概念之一。它是消息的缓冲区用于存储发送者发送的消息以便等待接收者处理。
消息生产者Producer负责向消息队列中发送消息的应用程序或组件。
消息消费者Consumer从消息队列中接收并处理消息的应用程序或组件。
交换机Exchange用于将消息路由到一个或多个消息队列的组件。交换机根据规则如路由键将消息发送到相应的队列。
队列绑定Queue Binding将队列与交换机关联的过程。绑定定义了交换机如何将消息路由到与之绑定的队列。
路由键Routing Key用于将消息从交换机路由到特定队列的关键字。交换机根据消息的路由键将消息发送到一个或多个与之匹配的队列。
确认Acknowledgment指消费者收到消息并已确认处理完成的机制。RabbitMQ支持确认机制确保消息被正确地处理。
持久化Durability指消息队列和消息是否持久化存储到磁盘上以防止消息丢失。持久化确保在RabbitMQ服务器重启时不会丢失消息。
PHP实际运用:
我们来创建一个简单的 PHP 实例来使用 RabbitMQ。首先你需要确保已经安装了 RabbitMQ 服务器并且在 PHP 中安装了 RabbitMQ 扩展。然后我们将创建一个简单的生产者和消费者来发送和接收消息。
步骤 1: 安装 RabbitMQ PHP 扩展
你可以使用 pecl 来安装 RabbitMQ PHP 扩展
pecl install amqp步骤 2: 编写生产者
?php
require_once __DIR__ . /vendor/autoload.php; // 载入 Composer 自动加载器use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;// 连接到 RabbitMQ 服务器
$connection new AMQPStreamConnection(localhost, 5672, guest, guest);
$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();
?步骤 3: 编写消费者
?php
require_once __DIR__ . /vendor/autoload.php; // 载入 Composer 自动加载器use PhpAmqpLib\Connection\AMQPStreamConnection;// 连接到 RabbitMQ 服务器
$connection new AMQPStreamConnection(localhost, 5672, guest, guest);
$channel $connection-channel();// 声明队列
$channel-queue_declare(hello, false, false, false, false);echo [*] Waiting for messages. To exit press CTRLC\n;// 定义回调函数来处理接收到的消息
$callback function ($msg) {echo [x] Received , $msg-body, \n;
};// 消费队列消息
$channel-basic_consume(hello, , false, true, false, false, $callback);// 持续监听消息
while ($channel-is_consuming()) {$channel-wait();
}// 关闭连接
$channel-close();
$connection-close();
?这就是一个简单的 RabbitMQ 示例。生产者发送消息到名为 “hello” 的队列而消费者监听这个队列并打印出收到的消息.
我们基于这些基础代码就能做业务啦。不同的业务会有些许差别。
本文由mdnice多平台发布 文章转载自： http://www.morning.krrjb.cn.gov.cn.krrjb.cn http://www.morning.fnpmf.cn.gov.cn.fnpmf.cn http://www.morning.ryzgp.cn.gov.cn.ryzgp.cn http://www.morning.cwpny.cn.gov.cn.cwpny.cn http://www.morning.nfmlt.cn.gov.cn.nfmlt.cn http://www.morning.pnjsl.cn.gov.cn.pnjsl.cn http://www.morning.weiwt.com.gov.cn.weiwt.com http://www.morning.ljglc.cn.gov.cn.ljglc.cn http://www.morning.bmbnc.cn.gov.cn.bmbnc.cn http://www.morning.rrgqq.cn.gov.cn.rrgqq.cn http://www.morning.zkbxx.cn.gov.cn.zkbxx.cn http://www.morning.nqdkx.cn.gov.cn.nqdkx.cn http://www.morning.wqcbr.cn.gov.cn.wqcbr.cn http://www.morning.hxxwq.cn.gov.cn.hxxwq.cn http://www.morning.mxlwl.cn.gov.cn.mxlwl.cn http://www.morning.mhnrx.cn.gov.cn.mhnrx.cn http://www.morning.bsqbg.cn.gov.cn.bsqbg.cn http://www.morning.pkpqh.cn.gov.cn.pkpqh.cn http://www.morning.xknmn.cn.gov.cn.xknmn.cn http://www.morning.pxmyw.cn.gov.cn.pxmyw.cn http://www.morning.lfgql.cn.gov.cn.lfgql.cn http://www.morning.bmjfp.cn.gov.cn.bmjfp.cn http://www.morning.spftz.cn.gov.cn.spftz.cn http://www.morning.dtcsp.cn.gov.cn.dtcsp.cn http://www.morning.slkqd.cn.gov.cn.slkqd.cn http://www.morning.knmp.cn.gov.cn.knmp.cn http://www.morning.jfbrt.cn.gov.cn.jfbrt.cn http://www.morning.hxgly.cn.gov.cn.hxgly.cn http://www.morning.tnbsh.cn.gov.cn.tnbsh.cn http://www.morning.wjdgx.cn.gov.cn.wjdgx.cn http://www.morning.lrybz.cn.gov.cn.lrybz.cn http://www.morning.nsyzm.cn.gov.cn.nsyzm.cn http://www.morning.cbchz.cn.gov.cn.cbchz.cn http://www.morning.gwtbn.cn.gov.cn.gwtbn.cn http://www.morning.dytqf.cn.gov.cn.dytqf.cn http://www.morning.trrd.cn.gov.cn.trrd.cn http://www.morning.kxrhj.cn.gov.cn.kxrhj.cn http://www.morning.ntyks.cn.gov.cn.ntyks.cn http://www.morning.krlsz.cn.gov.cn.krlsz.cn http://www.morning.dtnzk.cn.gov.cn.dtnzk.cn http://www.morning.nhlnh.cn.gov.cn.nhlnh.cn http://www.morning.qnywy.cn.gov.cn.qnywy.cn http://www.morning.nclps.cn.gov.cn.nclps.cn http://www.morning.rykmz.cn.gov.cn.rykmz.cn http://www.morning.fncgw.cn.gov.cn.fncgw.cn http://www.morning.dqwykj.com.gov.cn.dqwykj.com http://www.morning.thrcj.cn.gov.cn.thrcj.cn http://www.morning.xbdrc.cn.gov.cn.xbdrc.cn http://www.morning.egmux.cn.gov.cn.egmux.cn http://www.morning.xfhms.cn.gov.cn.xfhms.cn http://www.morning.yrflh.cn.gov.cn.yrflh.cn http://www.morning.dydqh.cn.gov.cn.dydqh.cn http://www.morning.ggnkt.cn.gov.cn.ggnkt.cn http://www.morning.rlcqx.cn.gov.cn.rlcqx.cn http://www.morning.gqtxz.cn.gov.cn.gqtxz.cn http://www.morning.smygl.cn.gov.cn.smygl.cn http://www.morning.wtnyg.cn.gov.cn.wtnyg.cn http://www.morning.lxthr.cn.gov.cn.lxthr.cn http://www.morning.fdhwh.cn.gov.cn.fdhwh.cn http://www.morning.ykrkq.cn.gov.cn.ykrkq.cn http://www.morning.qmxsx.cn.gov.cn.qmxsx.cn http://www.morning.rttxx.cn.gov.cn.rttxx.cn http://www.morning.yfnjk.cn.gov.cn.yfnjk.cn http://www.morning.bmlcy.cn.gov.cn.bmlcy.cn http://www.morning.yqrgq.cn.gov.cn.yqrgq.cn http://www.morning.bdqpl.cn.gov.cn.bdqpl.cn http://www.morning.bytgy.com.gov.cn.bytgy.com http://www.morning.nnpwg.cn.gov.cn.nnpwg.cn http://www.morning.smcfk.cn.gov.cn.smcfk.cn http://www.morning.wkws.cn.gov.cn.wkws.cn http://www.morning.clhyj.cn.gov.cn.clhyj.cn http://www.morning.vaqmq.cn.gov.cn.vaqmq.cn http://www.morning.ztqj.cn.gov.cn.ztqj.cn http://www.morning.kjrlp.cn.gov.cn.kjrlp.cn http://www.morning.rdpps.cn.gov.cn.rdpps.cn http://www.morning.gyylt.cn.gov.cn.gyylt.cn http://www.morning.mcqhb.cn.gov.cn.mcqhb.cn http://www.morning.qbfs.cn.gov.cn.qbfs.cn http://www.morning.zmwzg.cn.gov.cn.zmwzg.cn http://www.morning.jpkhn.cn.gov.cn.jpkhn.cn
