php activemq 类库,php activemq

电玩女神 2023-01-17 10:49 109阅读 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 条评论，109人围观）

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

相关阅读

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

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

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

相关 php activemq 类库,php activemq

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

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

相关 ActiveMQ

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

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

相关 ActiveMQ

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

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

相关 ActiveMQ

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

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

相关 ActiveMQ

> 此为博主(yjclsx)原创文章，如若转载请标明出处，谢谢！ > \一、JMS > 当前CORBA、DCOM、RMI等RPC中间件技术已广泛应用于各个领域，但是面对

ゝ一世哀愁。/ 2022年05月21日 02:23/ 0 赞/ 131 阅读

相关 ActiveMQ

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

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

相关 ActiveMQ

什么是activemq activeMQ是一种开源的，实现了JMS1.1规范的，面向消息(MOM)的中间件，为应用程序提供高效的、可扩展的、稳定的和安全的企业级消息通信。

古城微笑少年丶/ 2022年03月16日 07:10/ 0 赞/ 177 阅读

相关 ActiveMQ（一）安装ActiveMQ

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

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

相关 ActiveMQ

一、什么是消息中间件（MQ） 1.1 为什么会需要消息队列(MQ)？　　主要原因是由于在高并发环境下，由于来不及同步处理，请求往往会发生堵塞，比如说，大量的insert，

清疚/ 2021年10月19日 23:52/ 0 赞/ 272 阅读