使用PHP和RabbitMQ实现消息队列功能

更新时间：2024年03月24日 10:44:10 作者：ayzen1988

这篇文章主要介绍了如何使用PHP和RabbitMQ实现消息队列功能,文中通过示例代码介绍的非常详细,对大家学习或者使用PHP具有一定的参考学习价值,需要的朋友们下面来一起学习学习吧

前言

今天我们来做个小试验，用PHP和RabbitMQ实现消息队列功能。

前期准备，需要安装好docker、docker-compose的运行环境。

使用docker部署php服务的详细步骤_docker_脚本之家 (jb51.net)

一、安装RabbitMQ

1、创建相关目录，执行如下命令。

mkdir -p /docker/rabbitmq/data
cd /docker/rabbitmq

2、编写yaml文件，内容如下；version替换成自己的docker-compose版本。

vim docker-compose.yaml
version: '2.2.2'
services:
  rabbitmq:
    image: rabbitmq
    hostname: rabbitmq
    container_name: rabbitmq
    ports:
      - "5672:5672"
      - "15672:15672"
    volumes:
      - ./data:/var/lib/rabbitmq
    networks:
      - mynet
 
networks:
  mynet:
    name: mynet
    driver: bridge

3、启动rabbitmq，执行如下命令。

docker-compose up -d

4、检查服务是否正常运行，执行如下命令。

docker-compose ps -a

返回如下内容，说明服务已正常启动，正在运行。

5、如果有服务启动失败，可以使用如下命令排查问题。

docker logs rabbitmq

6、至此，rabbitmq安全完成并且已正常运行。

二、安装PHP的AMQP扩展

1、进入test1项目容器，执行如下命令。

docker exec -ti test1 /bin/sh

2、下载AMQP扩展并且完成安装，执行如下命令。

wget https://pecl.php.net/get/amqp-2.1.2.tgz
tar -zxvf amqp-2.1.2.tgz
cd amqp-2.1.2
/usr/local/php/bin/phpize
./configure --with-php-config=/usr/local/php/bin/php-config
make && make install

3、修改php.ini配置，增加amqp扩展，内容如下。

extension=amqp.so

4、检查配置是否成功，执行如下命令，有返回说明已完成安装。

/usr/local/php/bin/php -m|grep amqp

5、重启PHP服务，重启Web服务器或PHP-FPM服务以加载新安装的AMQP扩展。

6、至此，php的amqp扩展已完成安装。

三、测试验证

1、进入test1项目目录，执行如下命令。

cd /docker/test1/html/

2、编写生产者，代码内容如下。

vim producer.php
<?php
// 创建连接到RabbitMQ服务器的连接
$connection = new AMQPConnection(
    [
        'host' => 'rabbitmq',
        'port' => 5672,
        'username' => 'guest',
        'password' => 'guest'
    ]
);
$connection->connect();
 
// 创建一个频道（channel）
$channel = new AMQPChannel($connection);
 
// 声明一个交换机（exchange）
$exchange = new AMQPExchange($channel);
$exchange->setName('exchange_name');
$exchange->setType(AMQP_EX_TYPE_DIRECT); // 直接交换机类型
$exchange->declareExchange();
 
// 声明一个队列
$queue = new AMQPQueue($channel);
$queue->setName('queue_name');
$queue->declareQueue();
 
// 绑定交换机到队列
$queue->bind('exchange_name', 'routing_key');
 
// 发送一条消息
$messageBody = 'Hello, RabbitMQ!'.(!empty($_GET['msg']) ? $_GET['msg'] : '');
$exchange->publish($messageBody, 'routing_key');
 
// 关闭连接
$channel->close();
$connection->disconnect();

3、编写消费者，代码内容如下。

vim consumer.php
<?php
// 创建连接到RabbitMQ服务器的连接
$connection = new AMQPConnection(
    [
        'host' => 'rabbitmq',
        'port' => 5672,
        'username' => 'guest',
        'password' => 'guest'
    ]
);
$connection->connect();
 
// 创建一个频道（channel）
$channel = new AMQPChannel($connection);
 
// 声明一个交换机（exchange）
$exchange = new AMQPExchange($channel);
$exchange->setName('exchange_name');
$exchange->setType(AMQP_EX_TYPE_DIRECT); // 直接交换机类型
$exchange->declareExchange();
 
// 声明一个队列
$queue = new AMQPQueue($channel);
$queue->setName('queue_name');
$queue->declareQueue();
 
// 绑定交换机到队列
$queue->bind('exchange_name', 'routing_key');
 
// 开始消费消息
$queue->consume(function (AMQPEnvelope $envelope, AMQPQueue $queue) {
    if ($envelope->getBody()) {
        echo "Received message: ", $envelope->getBody(), "\n";
    }
}, AMQP_AUTOACK); // 如果设置为AMQP_AUTOACK，消息一旦收到就被认为已确认，否则需要手动确认
 
// 关闭连接
$channel->close();
$connection->disconnect();

4、进入test1项目容器，监控消费者，执行如下命令。

/usr/local/php/bin/php /usr/local/nginx/html/consumer.php

5、在宿主机发起一个生产者请求，执行如下命令。

curl "http://127.0.0.1:8081/producer.php?msg=max"

6、正常情况下，会在test1项目容器看到消费者的输出，类似如下截图。

7、至此，php和rabbitmq实现消息队列的功能已测试验证OK。

总结

用PHP和RabbitMQ实现消息队列功能，其实也不复杂，主要有以下几个步骤。

1、安装RabbitMQ。

2、安装PHP的AMQP扩展。

3、编写生产者、消费者进行验证。

上面的代码只是做个简单的示例，如果运用到实际的项目当中需要做配置化、封装。

以上就是使用PHP和RabbitMQ实现消息队列功能的详细内容，更多关于PHP RabbitMQ消息队列的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

php实现的简单多进程服务器类完整示例
这篇文章主要介绍了php实现的简单多进程服务器类,结合完整实例形式分析了PHP多进程服务器数据传输、响应、处理等相关操作技巧,需要的朋友可以参考下
2020-02-02
PHP实现简单注册登录系统
这篇文章主要为大家详细介绍了PHP实现简单注册登录系统，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2020-12-12
php rmdir使用递归函数删除非空目录实例详解
我们大家都知道，php rmdir()函数用于删除空目录，但如果要删除非空目录，我们必须将非空目录中的文件或子目录删除，本文章向大家介绍php如何使用递归函数删除非空目录，需要的朋友可以参考一下
2016-10-10
php中mysql模块部分功能的简单封装
php中mysql模块部分功能的简单封装，很多cms都是封装了一些mysql的操作代码类，大家可以参考下。
2011-09-09
再谈PHP错误与异常处理
这篇文章主要介绍了再谈PHP错误与异常处理，对错误和异常感兴趣的同学，可以参考下
2021-04-04
深入理解PHP中mt_rand()随机数的安全
mt_rand()使用mersennetwister算法返回随机整数，这个大家都知道，但下面这篇文章主要给大家介绍的是关于PHP中mt_rand()随机数安全的相关资料，文中介绍的非常详细，需要的朋友可以参考借鉴，下面随着小编来一起学习学习吧。
2017-10-10
php转换颜色为其反色的方法
这篇文章主要介绍了php转换颜色为其反色的方法,涉及php操作颜色数值的相关技巧,需要的朋友可以参考下
2015-04-04
php的4种常用运行方式详解
这篇文章主要介绍了php的4种常用运行方式，CGI、FastCGI、APACHE2HANDLER和CLI，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2016-12-12
基于PHP实现图片防盗链
这篇文章主要为大家详细介绍了如何基于PHP实现一个简单的图片防盗链，文中的示例代码讲解详细，感兴趣的小伙伴可以跟随小编一起学习一下
2023-12-12
PHP正则匹配日期和时间(时间戳转换)的实例代码
本文介绍下，用php实现正则匹配日期与时间，并进行时间戳转换的例子，有需要的朋友，参考下吧
2016-12-12