Warning: Undefined variable $img_type in /www/wwwroot/www.zhaohaoblog.com/wp-content/plugins/wpjam-basic/cdn/remote.php on line 86
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 800
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 806
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 806
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 808
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 808
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 811
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 811
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 800
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 806
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 806
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 808
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 808
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 811
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 811
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 800
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 806
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 806
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 808
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 808
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 811
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 811
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 800
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 806
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 806
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 808
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 808
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 811
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 811
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 800
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 806
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 806
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 808
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 808
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 811
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 811
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 828
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 829
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 75
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 76
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 75
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 76
Warning: Undefined variable $img_type in /www/wwwroot/www.zhaohaoblog.com/wp-content/plugins/wpjam-basic/cdn/remote.php on line 86
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 75
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 76
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 800
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 806
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 806
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 808
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 808
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 811
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 811
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 800
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 806
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 806
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 808
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 808
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 811
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 811
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 800
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 806
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 806
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 808
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 808
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 811
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 811
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 800
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 806
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 806
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 808
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 808
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 811
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 811
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 828
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 829
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 75
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 76
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 75
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 76
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 75
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 76
Warning: Undefined variable $img_type in /www/wwwroot/www.zhaohaoblog.com/wp-content/plugins/wpjam-basic/cdn/remote.php on line 86
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 75
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 76
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 75
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 76
Warning: Undefined variable $img_type in /www/wwwroot/www.zhaohaoblog.com/wp-content/plugins/wpjam-basic/cdn/remote.php on line 86
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 75
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 76
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 75
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 76
Warning: Undefined variable $img_type in /www/wwwroot/www.zhaohaoblog.com/wp-content/plugins/wpjam-basic/cdn/remote.php on line 86
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 75
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 76
Warning: Undefined variable $img_type in /www/wwwroot/www.zhaohaoblog.com/wp-content/plugins/wpjam-basic/cdn/remote.php on line 86
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 75
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 76
文章目录
- 安装教程 rabbitmq和php的amqp扩展教程网上有很多,大家可以自行查询,例如:Linux系统安装RabbitMQ及PHP安装amqp拓展库详细教程
- 不清楚里面的api的可以在文档中查询 RabbitMQ 中文文档
- 创建 composer.json填写内容 { "require": { "php-amqplib/php-amqplib": "^2.12" } }
- <?php require_once __DIR__ . '/vendor/autoload.php';use PhpAmqpLibConnectionAMQPStreamConnection; use PhpAmqpLibMessageAMQPMessage;connect = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest', '/', false, 'AMQPLAIN', null, 'en_US', 5.0, 5.0);channel = connect->channel();exchange = 'log'; channel->exchange_declare(exchange, 'fanout', true, true, false); //异步回调消息确认 channel->set_ack_handler( function (AMQPMessagemessage) { echo '消息确认内容' . message->body . PHP_EOL; } ); //异步回调,消息丢失处理channel->set_nack_handler( function (AMQPMessage message) { echo '消息丢失' .message->body . PHP_EOL; } ); echo '生成扇形交换机' . exchange . PHP_EOL; for (i = 0; i
- <?php require_once __DIR__ . '/vendor/autoload.php';use PhpAmqpLibConnectionAMQPStreamConnection;connect = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest', '/', false, 'AMQPLAIN', null, 'en_US', 5.0, 5.0);channel = connect->channel();exchange = 'log'; channel->exchange_declare(exchange, 'fanout', true); //定义临时queue list(queue) =channel->queue_declare('', false, false, true, false); //绑定 channel->queue_bind(queue, exchange); //回调callback = function (msg) { echo '订阅消息:' .msg->body . PHP_EOL; }; channel->basic_consume(queue, '', false, false, false, false, callback); while (channel->is_consuming()) { channel->wait(); }channel->close(); $connect->close();
安装教程
rabbitmq和php的amqp扩展教程网上有很多,大家可以自行查询,例如:Linux系统安装RabbitMQ及PHP安装amqp拓展库详细教程
不清楚里面的api的可以在文档中查询 RabbitMQ 中文文档
创建
composer.json填写内容
{
"require": {
"php-amqplib/php-amqplib": "^2.12"
}
}
<?php
require_once __DIR__ . '/vendor/autoload.php';
use PhpAmqpLibConnectionAMQPStreamConnection;
use PhpAmqpLibMessageAMQPMessage;
connect = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest', '/', false, 'AMQPLAIN', null, 'en_US', 5.0, 5.0);channel = connect->channel();exchange = 'log';
channel->exchange_declare(exchange, 'fanout', true, true, false);
//异步回调消息确认
channel->set_ack_handler(
function (AMQPMessagemessage) {
echo '消息确认内容' . message->body . PHP_EOL;
}
);
//异步回调,消息丢失处理channel->set_nack_handler(
function (AMQPMessage message) {
echo '消息丢失' .message->body . PHP_EOL;
}
);
echo '生成扇形交换机' . exchange . PHP_EOL;
for (i = 0; i<100;i++) {
pushData = "嘻嘻---------i";
echo '发布消息' . pushData . PHP_EOL;msg = new AMQPMessage(pushData);channel->basic_publish(msg,exchange);
}
//等待消息确认
channel->wait_for_pending_acks();channel->close();
$connect->close();
<?php
require_once __DIR__ . '/vendor/autoload.php';
use PhpAmqpLibConnectionAMQPStreamConnection;
use PhpAmqpLibMessageAMQPMessage;
connect = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest', '/', false, 'AMQPLAIN', null, 'en_US', 5.0, 5.0);channel = connect->channel();exchange = 'log';
channel->exchange_declare(exchange, 'fanout', true, true, false);
//异步回调消息确认
channel->set_ack_handler(
function (AMQPMessagemessage) {
echo '消息确认内容' . message->body . PHP_EOL;
}
);
//异步回调,消息丢失处理channel->set_nack_handler(
function (AMQPMessage message) {
echo '消息丢失' .message->body . PHP_EOL;
}
);
echo '生成扇形交换机' . exchange . PHP_EOL;
for (i = 0; i<100;i++) {
pushData = "嘻嘻---------i";
echo '发布消息' . pushData . PHP_EOL;msg = new AMQPMessage(pushData);channel->basic_publish(msg,exchange);
}
//等待消息确认
channel->wait_for_pending_acks();channel->close();
$connect->close();
<?php
require_once __DIR__ . '/vendor/autoload.php';
use PhpAmqpLibConnectionAMQPStreamConnection;
connect = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest', '/', false, 'AMQPLAIN', null, 'en_US', 5.0, 5.0);channel = connect->channel();exchange = 'log';
channel->exchange_declare(exchange, 'fanout', true);
//定义临时queue
list(queue) =channel->queue_declare('', false, false, true, false);
//绑定
channel->queue_bind(queue, exchange);
//回调callback = function (msg) {
echo '订阅消息:' .msg->body . PHP_EOL;
};
channel->basic_consume(queue, '', false, false, false, false, callback);
while (channel->is_consuming()) {
channel->wait();
}channel->close();
$connect->close();
<?php
require_once __DIR__ . '/vendor/autoload.php';
use PhpAmqpLibConnectionAMQPStreamConnection;
connect = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest', '/', false, 'AMQPLAIN', null, 'en_US', 5.0, 5.0);channel = connect->channel();exchange = 'log';
channel->exchange_declare(exchange, 'fanout', true);
//定义临时queue
list(queue) =channel->queue_declare('', false, false, true, false);
//绑定
channel->queue_bind(queue, exchange);
//回调callback = function (msg) {
echo '订阅消息:' .msg->body . PHP_EOL;
};
channel->basic_consume(queue, '', false, false, false, false, callback);
while (channel->is_consuming()) {
channel->wait();
}channel->close();
$connect->close();
相关文章
RabbitMQ在php中的使用----生产者与消费者
安装扩展 安装教程 rabbitmq和php的amqp扩展教程网上有很多,大家可以自行查询,例如:Linux系统安装RabbitMQ及PHP安装amqp拓展库详细教程 RabbitMQ文档推荐 不清楚里面的api的可以在文档中查询 RabbitMQ 中文 …
hyperf框架使用rabbitMQ生产消息至laravel/lumen进行消费
背景 需要做项目迁移时,例如laravel迁移至hyperf时,因为基本上都是一步一步迁移的,仍有例如支付回调等依旧在laravel框架中进行消费的情况。需要接管处理消息的queue进行数据格式改造,利用构造同样命名空间 …
docker build centos8系统php8.1+swoole等各种扩展镜像dockerfile
目前这个build的dockerfile只用在测试开发环境哈，需要优化opcache啥的自己开启一下哈 FROM centos:8 MAINTAINER zhaohao731869706@163.com ENV PHP_VERSION=8.1 ENV LANG=C.UTF-8 RUN ln -sf /usr/share/z …
hyperf配合hyperf-swagger一条命令根据响应体生成生成swagger文档
先上实现代码 <?php declare(strict_types=1); /** * This file is part of hyperf-tt. * * @link https://github.com/zhaohao19941221/hyperf-tt * @document https://github.com/zhaohao19941221/hype …
带你学习hyperf-7.1 特性
特性 Channel 通道 类似于 go 语言的 chan，Channel 可为多生产者协程和多消费者协程模式提供支持。底层自动实现了协程的切换和调度。 Channel 与 PHP 的数组类似，仅占用内存，没有其他额外的资源申请，所 …
带你学习hyperf-6.1 问题汇总
6.1 问题汇总 1. Guzzle Http客户端 请求时未记录日志文件,并将日志打印至终端 解决方案: 升级swoole至最新 2. hyperf与laravel 队列事务失败处理 场景: 当前有数据1,2,3投入队列,假设1，2，3都有创建的需 …
带你学习hyperf-5.2 Guzzle Http客户端
5.2 Guzzle Http客户端 安装composer包 composer require hyperf/guzzle 配置 在实例化客户端的时候以参数的方式做配置 参数均来自于 Guzzle Http文档里的配置信息 使用 <?php namespace AppController; …
带你学习hyperf-5.1 Redis协程客户端
5.1 Redis协程客户端 安装composer包 composer require hyperf/redis 配置 在config/autoload/redis.php下 <?php return [ 'default' => [ 'host' => env('REDIS_HOST', 'localhost'), 'auth' =&g …
带你学习hyperf-4.1 数据库配置文件
4.2 配置文件 配置文件所在路径 config/autoload/databases.php 配置文件中的参数 读写分离 <?php return [ 'default' => [ 'driver' => env('DB_DRIVER', 'mysql'), // 读库 'read' => [ 'hos …
带你学习hyperf-4.1 数据库
4.1 须知 与laravel的 Eloquent ORM 操作基本相同 借鉴5.4版本改造,有一些细节上的区别,比如事务等级处理等具体会在下文问题汇总中详细说明 hyperf/db-connection 是在orm的基础之上实现连接池,它基于 hype …
太荒凉了。
路过赞一个吧！