docker 安装rabbitmq并配置hyperf使用

这里我想完成的是
制作消息(多个协程制造)——》推送到rabbitmq——》订阅消息队列——》消费消息(ws协程客户端【一次消费多条】/ws前端)
利用 WebSocket 协议让客户端和服务器端保持有状态的长链接,保存链接上来的客户端 id。订阅发布者发布的消息针对已保存的客户端 id 进行广播消息。

一,安装rabbitmq

  • pull镜像
docker search rabbitmq
docker pull rabbitmq
  • 构建rabbitmq容器并加入hyperf环境组网
    这里我们构建容器的的就将他加入到了hyperf环境的网络lnmp_default(使用docker inspect hyperf 查看)
docker run -d --network=lnmp_default --hostname my-rabbit --name rabbit -p 15672:15672 -p 5673:5672 rabbitmq
-d 后台运行容器;--name 指定容器名;-p 指定服务运行的端口(5672:应用访问端口;15672:控制台Web端口号);-v 映射目录或文件;--network 网络名称--hostname  主机名(RabbitMQ的一个重要注意事项是它根据所谓的 “节点名称” 存储数据,默认为主机名);-e 指定环境变量;(RABBITMQ_DEFAULT_VHOST:默认虚拟机名;RABBITMQ_DEFAULT_USER:默认的用户名;RABBITMQ_DEFAULT_PASS:默认用户名的密码)
  • 进入容器并运行
docker exec -it rabbit /bin/bash
rabbitmq-plugins enable rabbitmq_management

这里须要修改配置文件,不然有的地方会报错 docker rabbitmq Management API returned status code 500

cd /etc/rabbitmq/conf.d/
echo management_agent.disable_metrics_collector = false > management_agent.disable_metrics_collector.conf

用户名和密码 guest
在这里插入图片描述

二,rabbitmq配置

生成配置文件 php bin/hyperf.php vendor:publish hyperf/amqp
并修改配置文件,这里的AMQP_HOST 就是lnmp_default 网络组中 rabbitmq的ip地址,可使用docker inspect rabbit 查看,端口即为容器内部映射ip这里默认是5672

三,测试代码

php bin/hyperf.php gen:amqp-producer DemoProducer
  • 生产者
<?phpdeclare(strict_types=1);namespace App\Amqp\Producer;use Hyperf\Amqp\Annotation\Producer;
use Hyperf\Amqp\Message\ProducerMessage;
use function Hyperf\Coroutine\co;//routingKey是指定路由到哪里,可以决定到哪个队列。队列通过路由键绑定到交换器
#[Producer(exchange: 'hyperf', routingKey: 'hyperf-queue.sj')]
//生产者方指定了exchange(交换机)和routing key,但是不指定queue(队列)也不将queue(队列)绑定到exchange,
//队列声明和绑定队列到exchange的工作由消费者方完成
//费者在消费消息时,需要声明队列(队列名字随便),并将声明的队列通过routing key绑定到exchange,这样才能接收到数据
class DemoProducer extends ProducerMessage
{public function __construct($id){$pdata['id']=$id;$pdata['time']=date("Y-m-d H:i:s",time());$pdata['name']=array_rand(['张三','李四','王虎','陆风','牛犇','冯晨','丁酉','郑和']);;$pdata['say']=bin2hex(random_bytes(10));$pdata['score']=array_rand(['61','80','75','77','99','88','97','81']);$this->payload = $pdata;}
}
  • 消费者
<?phpdeclare(strict_types=1);namespace App\Amqp\Consumer;use Hyperf\Amqp\Result;
use Hyperf\Amqp\Annotation\Consumer;
use Hyperf\Amqp\Message\ConsumerMessage;
use PhpAmqpLib\Message\AMQPMessage;#[Consumer(exchange: 'hyperf', routingKey: 'hyperf-queue.sj', queue: 'hyperf', name: "DemoConsumer", nums: 1)]
class DemoConsumer extends ConsumerMessage
{public function consumeMessage($data, AMQPMessage $message): Result{print_r($data);return Result::ACK;}
}
  • 控制器
 public function productMessage(){try {//这里使用协程创建100条消息$wg = new \Hyperf\Coroutine\WaitGroup();$wg->add(100);for($i=0;$i<100;$i++){//创建协程co(function () use ($wg){$message=new DemoProducer(1);//获取一个生产者实例$producer = ApplicationContext::getContainer()->get(Producer::class);//传递消息$producer->produce($message);$wg->done();});}$wg->wait();} catch (\Exception $exception) {throw new \Swoole\Exception($exception->getMessage());}return ['info' => "100条消息创建成功",];}

在这里插入图片描述

保存后重启服务 php hyperf.php start ,定义的消费者会自动消费,详见文档。

在这里插入图片描述
ps:这里有个小问题时间不对。这里实际上在composer hyperf的时候第一步就是可以设置时区Asia/Shanghai
都是我没设置,现在可以偷个懒在入口文件添加 date_default_timezone_set(‘Asia/Shanghai’); 即可。(或修改php.ini)

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

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

相关文章

Grind 75 | 1. Two Sum | 2. valid parentheses

来刷刷Grind 75, Blind 75作者更新版. Leetcode1 两数之和 经典题 link 思路&#xff1a; 很明显用hash table&#xff0c;一开始思考遍历2遍数组&#xff0c;第一遍加入hash table中&#xff0c; 第二遍对每个元素看能不能找到sum target&#xff0c;但思考如果有重复元素…

阿里云2核4G服务器支持多少人同时在线?

2核4G服务器支持多少人在线&#xff1f;阿里云服务器网账号下的2核4G服务器支持20人同时在线访问&#xff0c;然而应用不同、类型不同、程序效率不同实际并发数也不同&#xff0c;2核4G服务器的在线访问人数取决于多个变量因素&#xff1a; 2核4G&#xff1a;2核CPU和4G内存对…

学习笔记-cmake

cmake的版本号说明&#xff1a; CMAKE_MINIMUM_REQUIRED(VERSION 3.10) # 指定编译 C 版本 set(CMAKE_CXX_STANDARD 17) 创建一个工程&#xff1a; project(preprocess) 工程下创建一个项目&#xff1a; SET(PROGRAM WorkStation) include路径&#xff1a; set (INCLUD…

Nginx原理以及基础知识详解

Nginx是一个高性能的HTTP和反向代理服务器&#xff0c;具有高并发性、高可靠性、低内存消耗等特点。其工作原理和基础知识如下&#xff1a; 一、Nginx的工作原理 Nginx采用多进程模型&#xff0c;主进程负责接收客户端的连接请求&#xff0c;然后将连接请求分发给工作进程来处…

读算法的陷阱:超级平台、算法垄断与场景欺骗笔记02_大数据

1. 大数据分析 1.1. 随着“大数据军备竞赛”与定价算法的广泛应用&#xff0c;线上购物平台与实体商铺的界限也变得越来越模糊 1.2. 在沃尔玛疯狂扩张的时代&#xff0c;它给地区性商业带来的伤害不亚于一场地震 1.2.1. 当地的小型商铺往往…

浏览器工作原理与Javascript高级(异步)

总体介绍 浏览器运行是多进程的&#xff0c;包括主进程、渲染进行、网络进程和GPU进程等等 解析HTML时(渲染进程)用到两大引擎&#xff0c;一个是渲染引擎&#xff08;用于渲染页面&#xff09;、一个是JS引擎用于解析JS代码。又JS引擎运行是单线程的&#xff0c;所以渲染和 …

Dubbo基础入门一

1、什么是Dubbo3 Apache Dubbo 是一款易用、高性能的 WEB 和 RPC 框架&#xff0c;同时为构建企业级微服务提供服务发现、流量治理、可观测、认证鉴权等能力、工具与最佳实践。 “Dubbo3 已在阿里巴巴内部微服务集群全面落地&#xff0c;成功取代运行多年的 HSF 框架。” 2、…

【Linux】Linux原生异步IO(二):libaio相关结构体、函数详解

1、结构体 1.1 iocb struct iocb成员变量详解: struct iocb {PADDEDptr(void *data, __pad1); /1、在io完成事件中返回,与io_getevents方法返回的io_event结构体data成员一致一般存放用户自定义数据、用户数据、回调函数*/PADDED(unsigned key, aio_rw_flags

5G 网络切片VLAN ID配置错误导致业务不可用

【摘要】随着电联5G共建共享工作的开展&#xff0c;无法及时有效观测到单逻辑站点的相关指标&#xff0c;导致单运营商用户业务出现异常。本案例中着重对单运营商用户无法使用网络进行相关参数排查&#xff0c;从KPI性能指标结合故障告警发生时间&#xff0c;从而分析由于网络切…

稀碎从零算法笔记Day6-LeetCode:长度最小的子数组

前言&#xff1a;做JD的网安笔试题&#xff0c;结果查找子串&#xff08;单词&#xff09;这个操作不会。痛定思痛&#xff0c;决定学习滑动数组 题型&#xff1a;数组、双指针、滑动窗口 链接&#xff1a;209. 长度最小的子数组 - 力扣&#xff08;LeetCode&#xff09; 来…

(学习日记)2024.03.06:UCOSIII第八节:空闲任务+阻塞延时+main函数修改

写在前面&#xff1a; 由于时间的不足与学习的碎片化&#xff0c;写博客变得有些奢侈。 但是对于记录学习&#xff08;忘了以后能快速复习&#xff09;的渴望一天天变得强烈。 既然如此 不如以天为单位&#xff0c;以时间为顺序&#xff0c;仅仅将博客当做一个知识学习的目录&a…

CSS字体样式值,前端开发基础学习

元素特点&#xff1a; 块状元素&#xff1a; 在页面中以矩形区域显示。自上而下排列&#xff0c;独占一行可以直接添加宽高一般情况下&#xff0c;作为其他元素或内容的容器 行内元素&#xff1a; 在页面中最小单位也是矩形。在一行内逐个排列。不可以直接添加宽高&#xf…

VGG16-CF-VGG11实验报告

说明&#xff1a;VGG16和CF-VGG11是论文《A 3D Fluorescence Classification and Component Prediction Method Based on VGG Convolutional Neural Network and PARAFAC Analysis Method》使用的两种主要模型。其对应代码仓库提供了实验使用的数据集、平行因子分析结果和CNN模…

vue3 (二)v-model高级用法

1、子组件可以无需使用事件&#xff0c;直接通过this.$emit(update:modelValue, newValue) 修改父组件的数据 前置条件&#xff1a; (1).父组件通过 v-model 绑定自身数据&#xff08;可传递给子组件&#xff09; (2).子组件通过props中的 modelValue 来接收数据 (3).子组件通…

5.47 BCC工具之oomkill.py解读

一,工具简介 oomkill工具用于跟踪 Linux 的内存溢出(OOM)查杀,并在每行显示一个 OOM 杀死的基本详细信息。 二,代码示例 #!/usr/bin/env pythonfrom bcc import BPF from time import strftime# linux stats loadavg = "/proc/loadavg"# 定义 BPF程序 bpf_te…

OWASP Top 10 网络安全10大漏洞——A01:2021-访问控制中断

10大Web应用程序安全风险 2021年top10中有三个新类别、四个类别的命名和范围变化&#xff0c;以及一些合并。 A01&#xff1a;2021-访问控制中断 从第五位上升到top1&#xff0c;94%的应用程序都经过了某种形式的访问控制破坏测试&#xff0c;平均发生率为 3.81%且在贡献的…

flutter弹窗输入,Android学习的三个终极问题及学习路线规划

题库非常全面包括&#xff1a; Android基础知识: 基本涵盖Android所有知识体系&#xff0c;四大组件&#xff0c;Fragment,WebView,事件分发&#xff0c;View绘制…Java基础知识&高阶知识点: 基础部分不谈了&#xff0c;高阶部分&#xff1a;泛型&#xff0c;反射&#xff…

蓝桥杯刷题(一)

一、 import os import sys def dps(s):dp [0] * len(s)dp[0] ord(s[0]) - 96if len(s) 1:return dp[-1]dp[1] max(ord(s[0]) - 96, ord(s[1]) - 96)for i in range(2, len(s)):dp[i] max(dp[i - 1], dp[i - 2] (ord(s[i])) - 96)return dp[-1] s input() print(dps(s))…

【SpringBoot3.x教程 01】SpringBoot简介及工程搭建

前言&#xff1a;什么是SpringBoot&#xff1f; SpringBoot是一个开源的Java基础框架&#xff0c;它被设计来简化Spring应用的初始搭建以及开发过程。这个框架利用了“约定优于配置”的理念&#xff0c;提供了一系列大型项目中常用的默认配置&#xff0c;让开发者可以快速启动和…

stm32学习笔记:I2C通信外设原理(未完)

软件实现和硬件实现 串口通信为异步时序&#xff0c;用软件实现很麻烦&#xff0c;基本上用硬件实现 而I2C协议通信为同步时序&#xff0c;软件实现简单且灵活&#xff0c;硬件实现比较麻烦&#xff0c;故软件比较常用 但I2C硬件实现功能比较大&#xff0c;执行效率高&#xff…