php监听mq消息,客户端监听服务端获取rabbitmq消息队列，rabbitmq有消息的时候客户端刷新页面才能获取到消息，监听没起到作用，请求各位大神指点迷津...

header("Content-Type:text/html;charset=utf-8");

use Workerman\Worker;

require_once __DIR__ . '/Autoloader.php';

// 注意：这里与上个例子不同，使用的是websocket协议

$ws_worker = new Worker("websocket://192.168.1.218:5556");

// 启动4个进程对外提供服务

$ws_worker->count = 4;

// 当收到客户端发来的数据后返回hello $data给客户端

$ws_worker->onMessage = function($connection, $data)

{

$data = json_decode($data, true);

$conn_arg = array(

'host' => '192.168.1.100',

'port' => '5672',

'login' => 'qifaoa',

'password' => 'qifaoa@123',

'vhost' => '/',

);

foreach ($data as $k => $v) {

$exchange = $v;//交换机

$routing_key = $v;//路由key

$queue = $v;//队列

if (empty($exchange) || empty($routing_key) || empty($queue)) {

$connection->send('参数错误');

die();

}

//创建连接和channel

$conn = new AMQPConnection($conn_arg);

if (!$conn->connect()) {

$connection->send('rabbitmq连接失败');

die();

} else {

// echo '连接成功'."\n";

}

$channel = new AMQPChannel($conn);

//创建队列

$q = new AMQPQueue($channel);

$q->setName($queue);

$q->setFlags(AMQP_DURABLE);//设置队列持久化

$q->declareQueue();//声明创建队列

$q->bind($exchange, $routing_key);//绑定交换机，指定路由键

//消息获取

$message = $q->get(AMQP_AUTOACK);//自动应答机制

//判断消息是否存在

if ($message) {

$connection->send($message->getBody());

} else {

// echo json_encode('空');

}

$conn->disconnect();//关闭

}

};

//连接关闭

$ws_worker->onclose = function($connection) {

echo "connection close\n";

};

//连接错误

$worker->onError = function($connection, $code, $msg)

{

echo "error $code $msg\n";

};

// 运行worker

Worker::runAll();

php监听mq消息,客户端监听服务端获取rabbitmq消息队列，rabbitmq有消息的时候客户端刷新页面才能获取到消息，监听没起到作用，请求各位大神指点迷津...相关推荐

渡一教育_Java每日一练：建立Statement的作用是什么、前端Console.log( Boolean(‘‘))输出的是什么、如果希望1监听TCP端口为9000，服务端应该怎样创建socket
系列文章目录文章目录系列文章目录题目1java部分建立Statement的作用是什么(答案在最后公布) 题目1 - 答案 ==解析== ==答案== 题目2 前端 js部分 ==答案== 题目3 ...
卡达8梯控系统怎么破解求大神指点迷津谢谢！！！
这里写自定义目录标题欢迎使用Markdown编辑器新的改变功能快捷键合理的创建标题,有助于目录的生成如何改变文本的样式插入链接与图片如何插入一段漂亮的代码片生成一个适合你的列表创建一 ...
Unity中进行网络通信：三：unity客户端和Unity服务端互相发消息
目录一.目的 1.想知道:Unity中进行网络通信:unity客户端和Unity服务端互相发消息二.参考 1.unity3D中使用Socket进行数据通信(三) 三.操作:一:完成:在同一个Uni ...
请求各位大神只有微信头像和昵称怎么查到微信号
有个很中意的姑娘请求各位大神只有微信头像和昵称怎么查到微信号
grpc 客户端的context 服务端获取不到_MLamp;DEV[10] | gRPC的应用
上一期和大家谈到了gRPC的快速开始,我么哪知道了gRPC是什么以及怎么快速启动,那么现在,我们来看看这个玩意具体内部是怎么运作的,这里我们同样以helloworld这个为例子来去谈.首先上期内容在这 ...
Linux Socket 两个客户端通信，服务端作为中转
Socket 两个客户端通信,服务端作为中转 Socket两个客户端通信,服务端作为中转,通过sockket的通信原理,简单的做了一个以c语言写的服务端,与自己制作的Android app 与树莓派为 ...
oracle 客户端无法连接,Oracle客户端无法连接服务端解决方法及步骤
客户端无法连接服务端数据库,原因有网络,配置,文件访问权限,数据库服务是否已启动等问题导致,一般排查的步骤如下: 1.检查操作系统级别网络是否通畅 ping 192.168.10.1 2.检查数据库 ...
附件统一处理starter,含附件客户端和附件服务端
文章目录附件统一处理starter,可分别作为附件客户端和附件服务端使用一关于项目中附件的概述二概要描述三附件starter功能划分 3.1 附件服务器,真实的存储附件 3.1.1 为前 ...
android 仿微信demo————微信消息界面实现（服务端）
android 仿微信demo----微信启动界面实现 android 仿微信demo----注册功能实现(移动端) android 仿微信demo----注册功能实现(服务端) android 仿微 ...

php监听mq消息,客户端监听服务端获取rabbitmq消息队列，rabbitmq有消息的时候客户端刷新页面才能获取到消息，监听没起到作用，请求各位大神指点迷津...

php监听mq消息,客户端监听服务端获取rabbitmq消息队列，rabbitmq有消息的时候客户端刷新页面才能获取到消息，监听没起到作用，请求各位大神指点迷津...相关推荐

最新文章

热门文章