ActiveMQ之Stomp

最近和java对接在一个功能中java要求使用ActiveMQ推送队列过去,搜索论坛,大多数的都是RabbitMQ在某公众号搜到了ActiveMQ,话不多说直接开始;
先安装php的插件:stomp;每个系统安装的方法都不一样,此处就不详细的讲解了;
公众号给到的代码:

$stomp = new Stomp('tcp://192.168.1.222:61613');

$obj = new Stdclass();
//下面这些数据,实际中是用户通过前端页面post来的,这里只做演示
$obj->username = 'test';
$obj->password = '123456';
//发送一个注册消息到队列,我们这里模拟用户注册
$stomp->send('/queue/userReg', json_encode($obj));

经实验我写的报错:

ActiveMQ之Stomp

经过一番测试,查询stomp函数不用端口号:

$stomp = new Stomp('tcp://192.168.1.222');

$obj = new Stdclass();
//下面这些数据,实际中是用户通过前端页面post来的,这里只做演示
$obj->username = 'test';
$obj->password = '123456';
//发送一个注册消息到队列,我们这里模拟用户注册
$stomp->send('/queue/userReg', json_encode($obj));

结果:

ActiveMQ之Stomp

成功

本作品采用《CC 协议》,转载必须注明作者和本文链接
手写十万行代码
《L05 电商实战》
从零开发一个电商项目,功能包括电商后台、商品 & SKU 管理、购物车、订单管理、支付宝支付、微信支付、订单退款流程、优惠券等
《L03 构架 API 服务器》
你将学到如 RESTFul 设计风格、PostMan 的使用、OAuth 流程,JWT 概念及使用 和 API 开发相关的进阶知识。
讨论数量: 0
(= ̄ω ̄=)··· 暂无内容!

讨论应以学习和精进为目的。请勿发布不友善或者负能量的内容,与人为善,比聪明更重要!