RabbitMQ 与 PHP Swoole 实现

RabbitMQ 与 PHP Swoole 的结合实现

一、概述

RabbitMQ 是一个开源的消息队列中间件,允许通过异步消息传递来解耦应用程序的各个部分。Swoole 是一个高性能的 PHP 扩展,支持异步编程和协程,适用于构建高并发的网络服务。将 RabbitMQ 与 Swoole 结合使用,可以构建高效、可扩展的应用程序。本文将介绍如何使用 RabbitMQ 和 PHP Swoole 实现一个简单的消息队列示例。

二、环境准备

2.1 安装 RabbitMQ

使用 Docker 快速启动 RabbitMQ 实例:

docker run -d --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:management

访问 RabbitMQ 管理界面:http://localhost:15672,默认用户名和密码都是 guest

2.2 安装 Swoole

确保你的 PHP 环境支持 Swoole,可以通过以下命令安装 Swoole 扩展:

pecl install swoole

2.3 安装 RabbitMQ PHP 客户端库

使用 Composer 安装 php-amqplib

composer require php-amqplib/php-amqplib

三、构建示例应用

3.1 创建生产者

创建一个名为 producer.php 的文件,内容如下:

<?php
require __DIR__ . '/vendor/autoload.php';use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;function sendMessage($message) {$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');$channel = $connection->channel();$channel->queue_declare('task_queue', false, true, false, false, false, []);$msg = new AMQPMessage($message, ['delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT,]);$channel->basic_publish($msg, '', 'task_queue');echo " [x] Sent '$message'\n";$channel->close();$connection->close();
}// 使用 Swoole 创建一个 HTTP 服务器
$server = new Swoole\Http\Server("127.0.0.1", 9501);$server->on("request", function ($request, $response) {$message = $request->post['message'] ?? 'Hello World!';sendMessage($message);$response->end("Message sent: $message");
});$server->start();

在这个代码中,我们创建了一个 Swoole HTTP 服务器,当收到请求时,会将请求中的消息发送到 RabbitMQ 的 task_queue 队列中。

3.2 创建消费者

创建一个名为 consumer.php 的文件,内容如下:

<?php
require __DIR__ . '/vendor/autoload.php';use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;function consumeMessages() {$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');$channel = $connection->channel();$channel->queue_declare('task_queue', false, true, false, false, false, []);$callback = function ($msg) {echo " [x] Received {$msg->body}\n";sleep(substr_count($msg->body, '.')); // 模拟处理时间echo " [x] Done\n";$msg->ack(); // 确认消息已被处理};$channel->basic_qos(null, 1, null); // 每次只处理一条消息$channel->basic_consume('task_queue', '', false, false, false, false, $callback);echo " [*] Waiting for messages. To exit press CTRL+C\n";while ($channel->is_consuming()) {$channel->wait();}$channel->close();$connection->close();
}// 启动消费者
consumeMessages();

消费者从 RabbitMQ 中的 task_queue 队列中读取消息,并在处理完后发送确认。如果消息体包含句点 (.),则消费者将模拟处理时间。

四、运行示例

  1. 启动 RabbitMQ:确保 RabbitMQ 服务正在运行。
  2. 启动消费者:在一个终端中运行消费者代码:
php consumer.php
  1. 启动生产者:在另一个终端中运行生产者代码:
php producer.php
  1. 发送消息:使用 curl 或 Postman 向生产者发送 HTTP 请求:
curl -X POST -d "message=Hello from Swoole!" http://127.0.0.1:9501

你可以多次发送消息,每次都会在消费者中看到相应的处理输出。

五、优点与应用场景

5.1 优点

  • 高并发:Swoole 支持异步和协程,能够处理大量并发请求,适合高流量场景。
  • 解耦设计:RabbitMQ 作为消息中间件,可以有效地将系统的各个部分解耦,提高系统的可维护性和扩展性。
  • 可靠性:通过 RabbitMQ 的消息持久化和确认机制,可以确保消息不丢失。

5.2 应用场景

  • 异步任务处理:适合需要后台处理的任务,如发送邮件、生成报告等。
  • 数据流处理:可以用于实时数据处理和事件驱动的架构。
  • 微服务架构:在微服务架构中,RabbitMQ 可以作为服务之间的通信桥梁。

六、总结

通过将 RabbitMQ 与 PHP Swoole 结合使用,我们能够构建出高效、可扩展的消息队列系统。本文展示了如何使用 Swoole 创建生产者和消费者,实现消息的发送和接收。希望通过这个示例,能够更好地理解 RabbitMQ 和 Swoole 的应用及其潜力,为后续的开发与应用提供参考。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/pingmian/60742.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

一文说清C++类型转换操作符(cast operator)

一 前言 大家在编程时&#xff0c;一定会遇到要做类型转换的应用场景。 但是&#xff0c;C风格的类型转换太强大&#xff0c;太危险&#xff0c;它允许将一个给定类型转换成我们想要的任何其他类型。 所以在C中&#xff0c;提供了一些更安全和更明确的类型转换操作符&#xff…

STM32(hal库)在串口中,USART和uart有什么区别?

在STM32的HAL库中&#xff0c;USART和UART都是用于串口通信的模块&#xff0c;但它们在功能特性和使用场景上存在一些区别。以下是对两者的详细比较&#xff1a; 一、功能特性 UART&#xff08;通用异步收发器&#xff09;&#xff1a; 是一种串行、异步、全双工的通信协议。通…

使用 Ansys Mechanical 中的“螺栓工具”插件导出螺栓反作用力

概括&#xff1a; 对于处理复杂组件和结构的工程师和分析师来说&#xff0c;提高在 Ansys Mechanical 中提取多个螺栓反作用力表格的效率至关重要。在有限元分析 (FEA) 中&#xff0c;准确确定螺栓上的反作用力对于评估机械连接的完整性和性能至关重要。但是&#xff0c;手动提…

Docker部署Kafka SASL_SSL认证,并集成到Spring Boot

1&#xff0c;创建证书和密钥 需要openssl环境&#xff0c;如果是Window下&#xff0c;下载openssl Win32/Win64 OpenSSL Installer for Windows - Shining Light Productions 还需要keytool环境&#xff0c;此环境是在jdk环境下 本案例所使用的账号密码均为&#xff1a; ka…

机器学习(基础2)

特征工程 特征工程:就是对特征进行相关的处理 一般使用pandas来进行数据清洗和数据处理、使用sklearn来进行特征工程 特征工程是将任意数据(如文本或图像)转换为可用于机器学习的数字特征,比如:字典特征提取(特征离散化)、文本特征提取、图像特征提取。 特征工程API 实例化…

CSS Module:告别类名冲突,拥抱模块化样式(5)

CSS Module 是一种解决 CSS 类名冲突的全新思路。它通过构建工具&#xff08;如 webpack&#xff09;将 CSS 样式切分为更加精细的模块&#xff0c;并在编译时将类名转换为唯一的标识符&#xff0c;从而避免类名冲突。本文将详细介绍 CSS Module 的实现原理和使用方法。 1. 思…

webpack案例----pdd(anti-content)

本文章中所有内容仅供学习交流&#xff0c;相关链接做了脱敏处理&#xff0c;若有侵权&#xff0c;请联系我立即删除&#xff01; 目标网址&#xff1a;aHR0cHM6Ly9waW5kdW9kdW8uY29tL2hvbWUvM2M 加密参数&#xff1a;anti_content 载荷里面的rn是不变的 发现加密是anti-con…

蓝队的基础

声明&#xff01; 学习视频来自B站up主 **泷羽sec** 有兴趣的师傅可以关注一下&#xff0c;如涉及侵权马上删除文章&#xff0c;笔记只是方便各位师傅的学习和探讨&#xff0c;文章所提到的网站以及内容&#xff0c;只做学习交流&#xff0c;其他均与本人以及泷羽sec团…

Flume1.9.0自定义Sink组件将数据发送至Mysql

需求 1、将Flume采集到的日志数据也同步保存到MySQL中一份&#xff0c;但是Flume目前不支持直接向MySQL中写数据&#xff0c;所以需要用到自定义Sink&#xff0c;自定义一个MysqlSink。 2、日志数据默认在Linux本地的/data/log/user.log日志文件中&#xff0c;使用Flume采集到…

Docker compose部署Activemq

整个工具的代码都在Gitee或者Github地址内 gitee&#xff1a;solomon-parent: 这个项目主要是总结了工作上遇到的问题以及学习一些框架用于整合例如:rabbitMq、reids、Mqtt、S3协议的文件服务器、mongodb github&#xff1a;GitHub - ZeroNing/solomon-parent: 这个项目主要是…

MySQL【五】

索引 能让数据库服务器更快地查找和获取表中指定的行。类似于书的目录。在MySQL中&#xff0c;所有数据类型都可以被索引。 索引的分类 主键索引&#xff1a;方式1&#xff1a;ALTER TABLE 表名 ADD PRIMARY KEY 索引名( 字段名 ) 方式2&#xff1a;创建表的时候指定主键 ###…

T265相机双目鱼眼+imu联合标定(全记录)

最近工作用到t265&#xff0c;记录一遍标定过程 1.安装驱动 首先安装realsense驱动&#xff0c;因为笔者之前使用过d435i&#xff0c;装的librealsense版本为2.55.1&#xff0c;直接使用t265会出现找不到设备的问题&#xff0c;经查阅发现是因为realsense在2.53.1后就不再支持…

Kotlin中泛型的协变

interface Shapeclass Circle : Shapefun main() {val shapes1: List<Shape> listOf<Circle>()val shapes2: MutableList<Shape> mutableListOf<Circle>() }如上代码&#xff0c;第一行赋值语句是OK的&#xff0c;第二行赋值语句在编辑器上直接就报错…

PostgreSQL 从库查询与复制冲突

PostgreSQL ERROR: canceling statement due to conflict with recovery PostgreSQL ERROR: canceling statement due to conflict with recovery PostgreSQL 在主从模式下&#xff0c;当我们在从库上执行查询的时候常常会遇到这样的问题。 ERROR: canceling statement due t…

RT-DETR融合[CVPR2023]FasterNet种的PConv及相关改进思路

RT-DETR使用教程&#xff1a; RT-DETR使用教程 RT-DETR改进汇总贴&#xff1a;RT-DETR更新汇总贴 《Run, Don’t Walk: Chasing Higher FLOPS for Faster Neural Networks》 一、 模块介绍 论文链接&#xff1a;Run, Dont Walk: Chasing Higher FLOPS for Faster Neural Netwo…

【测试框架篇】单元测试框架pytest(2):用例编写

一、 前言 前面一章我们介绍了pytest环境安装和配置&#xff0c;并在pycharm里面实现了我们第一个pytest脚本。但是有些童鞋可能在编写脚本的时候遇到了问题&#xff0c;本文会讲一下我们编写pytest用例时需要遵守哪些既定的规则&#xff0c;同时这个规则也是可以修改的。 二…

嵌入式硬件电子电路设计(五)MOS管详解(NMOS、PMOS、三极管跟mos管的区别)

引言&#xff1a;在我们的日常使用中&#xff0c;MOS就是个纯粹的电子开关&#xff0c;虽然MOS管也有放大作用&#xff0c;但是几乎用不到&#xff0c;只用它的开关作用&#xff0c;一般的电机驱动&#xff0c;开关电源&#xff0c;逆变器等大功率设备&#xff0c;全部使用MOS管…

Conda安装软件错误(Pycharm)

conda的环境变量路径错误&#xff0c;比如移动了conda的文件位置conda的python版本不适合&#xff0c;python3.10现在更适合很多库conda对cmd没有初始化&#xff0c;conda init cmd.exe

《TCP/IP网络编程》学习笔记 | Chapter 11:进程间通信

《TCP/IP网络编程》学习笔记 | Chapter 11&#xff1a;进程间通信 《TCP/IP网络编程》学习笔记 | Chapter 11&#xff1a;进程间通信进程间通信的基本概念通过管道实现进程间通信通过管道进行进程间双向通信 运用进程间通信习题&#xff08;1&#xff09;什么是进程间通信&…

推荐一款高效的网站数据抓取工具:SysNucleus WebHarvy

SysNucleus WebHarvy是一款高效的网站数据抓取工具&#xff0c;支持从网页中提取文本、图像、URL 和电子邮件等内容&#xff0c;无需编写任何代码或脚本即可轻松实现数据抓取。用户可以通过 WebHarvy 内置的浏览器直观地浏览网页&#xff0c;指引软件提取所需的数据。它通过自动…