php activemq 类库,php activemq

电玩女神 2023-01-17 10:49 145阅读 0赞

require\_once("Stomp.php");

error\_reporting(E\_ALL);

$config = array(

'active'=>array(//ActiveMQ 参数

'destination' => '/queue/test',//监听ID

'active\_usr' => 'guest',

'active\_psw' => 'password',

'stomp\_uri' => 'tcp://192.168.10.189:61613',

),

);

$result = array(

"message"=>array(

"username"=>"消息发送人用户名1",

"pushtime"=>"消息发送时间",

"pushjob"=>"消息发送人身份",

"getonname"=>"消息发送人上车地点",

"getoutname"=>"消息发送人下车地点",

"comeid"=>"消息发送人uid",

"getid"=>"接收消息人uid",

"type"=>"消息类型(确认拼1，取消消息2)",

"carpooled"=>"行程id",

"poolmsgid"=>"消息发送人拼车信息id",

"pooledmsgid"=>"接收消息人拼车信息id",

)

);

$detail = json\_encode($result);

try \{

$stomp = new Stomp($config\['active'\]\['stomp\_uri'\]);//uri

$stomp->connect($config\['active'\]\['active\_usr'\], $config\['active'\]\['active\_psw'\],array('persistent'=>'true'));

$row = $stomp->send($config\['active'\]\['destination'\],$detail);

if($row)\{

$status = 0; $res = '数据发送成功';

\}else\{

$status = 104; $res = '数据发送失败';

\}

print $res;

\} catch(StompException $e) \{

$result = array('status'=>103,'res'=>$e->getMessage());

print\_r(json\_encode($result));

exit();

\}

rective.php

require\_once("Stomp.php");

// make a connection

$con = new Stomp("tcp://192.168.10.189:61613");

// connect with authentication

$con->connect("guest", "password");

// set read timeout

$con->setReadTimeout(1);

// subscribe to the queue

$con->subscribe("/queue/test");//, array("transformation" => "jms-map-json")

// receive a message from the queue

$msg = $con->readFrame();

// do what you want with the message

if ( $msg != null) \{

//echo "Received message : ";

print\_r($msg->body);

// mark the message as received in the queue

$con->ack($msg);

\} else \{

echo "Failed to receive a message/n";

\}

// disconnect

$con->disconnect();

配置：

activemq.xml

xmlns="http://www.springframework.org/schema/beans"

xmlns:amq="http://activemq.apache.org/schema/core"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd

http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd">

file:$\{activemq.conf\}/credentials.properties

发表评论取消回复

表情：

评论列表（有 0 条评论，145人围观）

还没有评论，来说两句吧...

相关阅读

相关 ActiveMQ —— Spring 整合 ActiveMQ

前文 [消息中间件 —— 简介][Link 1] [ActiveMQ 下载、安装][ActiveMQ] [ActiveMQ —— Java 连接 ActiveMQ（点

柔情只为你懂/ 2023年02月11日 07:28/ 0 赞/ 30 阅读

相关 php 图表类库,相对简约的PHP图表类库

简介： include "../libchart/classes/libchart.php"; $chart = new HorizontalBarChart(600, 1

「爱情、让人受尽委屈。」/ 2023年01月17日 15:49/ 0 赞/ 187 阅读

相关 php activemq 类库,php activemq

require\_once("Stomp.php"); error\_reporting(E\_ALL); $config = array( 'active'=>arra

电玩女神/ 2023年01月17日 10:49/ 0 赞/ 146 阅读

相关 ActiveMQ

[http://www.uml.org.cn/zjjs/201802111.asp][http_www.uml.org.cn_zjjs_201802111.asp] [ht

Bertha 。/ 2022年11月06日 14:54/ 0 赞/ 179 阅读

相关 ActiveMQ

在 Java 里有 JMS 的多个实现。其中 apache 下的 ActiveMQ 就是不错的选择。用 ActiveMQ 最好还是了解下 JMS ConnectionFa

迷南。/ 2022年06月18日 08:10/ 0 赞/ 161 阅读

相关 ActiveMQ

一、概述 ActiveMQ是apache出的，市面上流行且能力突出的开源消息总线，可以作为JMS中间件。完全支持JMS1.1和J2EE1.4规范。特色是支持多种语言和

你的名字/ 2022年05月26日 06:52/ 0 赞/ 137 阅读

相关 ActiveMQ

说明 ActiveMQ是消息队列机制，分两种模式，第一种是生产者给消费者发一条消息，第二种类似观察者模式，一个人发消息，订阅了的一群人收消息。 ActiveMQ在Li

亦凉/ 2022年05月24日 12:11/ 0 赞/ 173 阅读

相关 ActiveMQ

一、ActiveMQ安装 1.windows安装 2.Linux安装二、ActiveMQ应用 1.点

向右看齐/ 2022年05月22日 06:16/ 0 赞/ 200 阅读

相关 ActiveMQ

1.3.1下载官方网站下载：[http://activemq.apache.org/][http_activemq.apache.org] 1.3.2安装（Linu

朴灿烈づ我的快乐病毒、/ 2022年05月15日 04:21/ 0 赞/ 190 阅读

相关 ActiveMQ（一）安装ActiveMQ

一、ActiveMQ简介直接上官网，看最权威的解释 ![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_a

柔情只为你懂/ 2022年01月10日 00:21/ 0 赞/ 469 阅读