详解PHP+RabbitMQ(AMQP协议、通讯架构、6大模式、交换机队列消息持久化、死信队列、延时队列、消息丢失、重复消费、消息应答、消息应答、发布确认、故障转移、不公平分发、优先级、等)

在回答这个问题之前,我需要先澄清一点:问题本身并没有给出一个明确的问题,而是一个包含多个子问题的列表。我将会尝试回答这些子问题,并提供相关的解释和示例代码。

  1. PHP中使用RabbitMQ

首先,确保你已经安装了RabbitMQ和PHP的amqp扩展。




$connection = new AMQPConnection(array(
    'host' => '127.0.0.1',
    'port' => '5672',
    'vhost' => '/',
    'login' => 'guest',
    'password' => 'guest'
));
 
$connection->connect() or die("Cannot connect to the broker!\n");
 
// 创建一个通道
$channel = new AMQPChannel($connection);
 
// 创建一个交换机
$exchange = new AMQPExchange($channel);
$exchange->setName('exchange_name');
$exchange->setType(AMQP_EX_TYPE_DIRECT); // 直接类型
$exchange->setFlags(AMQP_DURABLE); // 持久化
 
// 发送消息
$exchange->publish('Hello, RabbitMQ!', 'routing_key');
 
// 关闭通道和连接
$channel->close();
$connection->close();
  1. AMQP协议详解

AMQP(Advanced Message Queuing Protocol)是一个提供统一消息服务的应用层标准高级消息队列协议,设计的目的是为了解决不同消息中间件的兼容问题。

  1. RabbitMQ通讯架构

RabbitMQ是一个消息代理,它接受来自生产者的消息,并将它们路由给服务器上的消费者。RabbitMQ使用的是AMQP协议,因此它的通讯架构包括以下几个主要组件:

  • 生产者:发送消息的应用。
  • 交换机:接收生产者发送的消息并将它们路由到一个或多个队列。
  • 队列:存储消息直到消费者取走。
  • 消费者:接收消息并处理它们的应用。
  1. 6大模式

RabbitMQ中有6种模式,分别是简单模式、工作队列模式、发布/订阅模式、路由模式、主题模式和RPC模式。

简单模式:一个生产者,一个消费者。

工作队列模式:多个消费者共享一个队列,平衡负载。

发布/订阅模式:一个生产者发给多个消费者。

路由模式:生产者将消息发给特定的队列。

主题模式:路由模式的拓展,通过模式匹配进行路由。

RPC模式:远程过程调用,函数调用的返回结果。

  1. 队列/消息持久化

可以设置队列和消息的持久化属性,以保证在服务器重启后消息不会丢失。




// 设置队列持久化
$queue->setFlags(AMQP_DURABLE);
 
// 发送持久化消息
$exchange->publish($message, $routingKey, AMQP_DURABLE);
  1. 交换机类型

RabbitMQ中有四种交换机类型:直接(Direct)、主题(Topic)、头部(Headers)和 fanout(广播)。

直接交换机:通过路由键完全匹配。

主题交换机:通过路由键模糊匹配。

头部交换机:通过查看消息头部的匹配。

广

PHP , mq , 架构
最后修改于:2024年08月14日 10:41

评论已关闭

推荐阅读

Vue中使用mind-map实现在线思维导图
2024年08月04日
VUE
Web前端最全Vue实现免密登录跳转的方式_vue怎么样不登录返回首页,最强技术实现
2024年08月04日
VUE
vue3 项目搭建教程(基于create-vue,vite,Vite + Vue)
2024年08月04日
VUE
Vue-颜色选择器实现方案——>Vue-Color( 实战*1+ Demo*7)
2024年08月04日
VUE
Vue项目卡顿慢加载?这些优化技巧告诉你!_vue数据多渲染卡顿
2024年08月04日
VUE
vue中的keep-alive详解与应用场景
2024年08月04日
VUE
Vue、React实现excel导出功能(三种实现方式保姆级讲解)
2024年08月04日
vue-office/docx插件实现docx文件预览
2024年08月04日
VUE
java调用js文件的两种方法(支持V8引擎)
2024年08月04日
JavaScript:解决计算精度问题/mathjs/bignumber.js/big.js/decimal.js
2024年08月04日
两周从爬虫小白变大神 _yjs_js_security_passport
2024年08月04日
JS笔记(对象、函数、数组)
2024年08月04日
Markdown.js:强大的纯JavaScript Markdown解析器
2024年08月04日
Vue项目:js模拟点击a标签下载文件并重命名,URL文件地址下载方法、请求接口下载文件方法总结。
2024年08月04日
vue 父组件怎么获取子组件里面的data数据
2024年08月04日
VUE
个人开发实现AI套壳网站快速搭建(Vue+elementUI+SpringBoot)
2024年08月04日
el-table 表格封装并改造实现单元格可编辑
2024年08月04日
none
nodejs环境下创建vue项目、SSH密钥登陆!!!
2024年08月04日
vue+quill+element-ui实现视频、图片上传及缩放保姆级教程,轻松使用富文本
2024年08月04日
【three.js】22. Imported Models导入模型
2024年08月04日