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

前言

今天我们来做个小试验,用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

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

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

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项目容器看到消费者的输出,类似如下截图。

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

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

总结

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

1、安装RabbitMQ。

2、安装PHP的AMQP扩展。

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

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

以上就是使用PHP和RabbitMQ实现消息队列功能的详细内容,更多关于PHP RabbitMQ消息队列的资料请关注恩蓝小号其它相关文章!

原创文章,作者:FFBPO,如若转载,请注明出处:https://www.wangzhanshi.com/n/729.html

(0)
FFBPO的头像FFBPO
上一篇 2024年12月17日 17:53:18
下一篇 2024年12月17日 17:53:20

相关推荐

  • 讲解PHP 8 新特性 Attributes

    嘿嘿,今天呢,我想谈谈Attributes,为啥呢, 是昨天我看到很多群在转发一个文章,叫做《理解PHP8中的Attributes》,说实在的,这篇文章应该是直接从英文翻译过来的,…

    php 2025年1月2日
  • echo和print语句怎么在PHP7中使用

    PHP echo 和 print 语句 echo 和 print 之间的差异: echo – 能够输出一个以上的字符串 print – 只能输出一个字符串,…

    php 2025年1月1日
  • 实例探索PHP只读属性改变游戏规则的特性

    正文 只读属性是一个改变游戏规则的新特性。它允许您声明只能在初始化期间设置且此后无法修改的属性。 只读属性就像是代码中的恒久不变的守护者,确保一切保持原样。它们可以用于各种目的,例…

    php 2024年12月17日
  • php7连接不上mysql的解决方法

    1、添加php.ini文件 新版的PHP7中,没有php.ini,需要自己创建。新版有两个php.ini-development和php.ini-production文件,复制一个…

    php 2025年1月1日
  • 在ThinkPHP6中使用mysql进行分页查询的实现代码

    随着互联网的快速发展,web应用程序的开发也越来越复杂。而分页查询是web应用程序中常见的功能之一。thinkphp6是一个web框架,可以帮助开发人员快速开发应用程序。在本文中,…

    2024年12月17日
  • PHP7原生MySQL数据库怎么操作

    php7中mysql的连接与使用与PHP5中大不相同 PHP5中mysql_connect()等函数大多被PHP7中类的成员函数所代替。PHP5中连接mysql是过程性的,而PHP…

    php 2025年1月1日
  • php5是什么意思

     2004年7月,PHP5正式版本的发布,标志着一个全新的PHP时代的到来。它的核心是第二代Zend引擎,并引入了对全新的PECL模块的支持。 尽管PHP4的发展是如此迅…

    php 2025年1月2日
  • PHP避免SQL注入的常用方法

    在开发php网站时,经常需要和数据库交互来存储和获取数据。然而,如果不对用户输入的数据进行处理,就可能会导致SQL注入攻击。SQL注入是一种常见的安全漏洞,攻击者可以通过恶意构造的…

    php 2024年12月17日
  • PHP单文件实现代码去行首尾空格和去空行

    示例代码 <?php if($_GET[“x”] == “cha”){ $tips = isset($_POST[‘tips’]) ? $_POST[‘tips’] : ”…

    php 2024年12月17日
  • ubuntu中如何安装php7.2

    ubuntu安装高版本php7.2、卸载安装php7.0: 一、删除php的相关包及配置 sudo apt-get autoremove php7* 二、删除关联 sudo fin…

    php 2025年1月1日

发表回复

登录后才能评论