文档章节

用 PHP 收发 RabbitMQ 消息

mac_zhao
 mac_zhao
发布于 2014/09/26 17:41
字数 521
阅读 18
收藏 0
点赞 0
评论 0

AMQP

扩展的安装参照《给

PHP

安装

amqp

扩展》

 

 

消费者:接收消息

 

逻辑:

创建连接

-->

创建

channel-->

创建交换机

-->

创建队列

-->

绑定交换机

/

队列

/

路由键

-->

接收

消息

 

<?php    

/************************************* 

 * PHP amqp(RabbitMQ) Demo - consumer 

 * Author: Linvo 

 * Date: 2012/7/30 

 *************************************/  

//

配置信息

  

$conn_args = array(  

    

'host' => '192.168.1.93',   

    

'port' => '5672',   

    

'login' => 'guest',   

    

'password' => 'guest',  

    

'vhost'=>'/'  

);    

$e_name = 'e_linvo'; //

交换机名

  

$q_name = 'q_linvo'; //

队列名

  

$k_route = 'key_1'; //

路由

key  

  

//

创建连接和

channel  

$conn = new AMQPConnection($conn_args);    

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

    

die("Cannot connect to the broker!\n");    

}    

$channel = new AMQPChannel($conn);    

  

//

创建交换机

     

$ex = new AMQPExchange($channel);    

$ex->setName($e_name);  

$ex->setType(AMQP_EX_TYPE_DIRECT); //direct

类型

   

$ex->setFlags(AMQP_DURABLE); //

持久化

  

echo "Exchange Status:".$ex->declare()."\n";    

    

//

创建队列

     

$q = new AMQPQueue($channel);  

$q->setName($q_name);    

$q->setFlags(AMQP_DURABLE); //

持久化

   

echo "Message Total:".$q->declare()."\n";    

  

//

绑定交换机与队列,并指定路由键

  

echo 'Queue Bind: '.$q->bind($e_name, $k_route)."\n";  

  

//

阻塞模式接收消息

  

echo "Message:\n";    

while(True){  

    

$q->consume('processMessage');    

    

//$q->consume('processMessage', AMQP_AUTOACK); //

自动

ACK

应答

   

}  

$conn->disconnect();    

  

/** 

 * 

消费回调函数

 

 * 

处理消息

 

 */  

function processMessage($envelope, $queue) {  

    

$msg = $envelope->getBody();  

    

echo $msg."\n"; //

处理消息

  

    

$queue->ack($envelope->getDeliveryTag()); //

手动发送

ACK

应答

  

}  

 

生产者:发送消息

 

逻辑:创建连接

-->

创建

channel-->

创建交换机对象

-->

发送消息

 

<?php    

/************************************* 

 * PHP amqp(RabbitMQ) Demo - publisher 

 * Author: Linvo 

 * Date: 2012/7/30 

 *************************************/  

//

配置信息

  

$conn_args = array(  

    

'host' => '192.168.1.93',   

    

'port' => '5672',   

    

'login' => 'guest',   

    

'password' => 'guest',  

    

'vhost'=>'/'  

);    

$e_name = 'e_linvo'; //

交换机名

  

//$q_name = 'q_linvo'; //

无需队列名

  

$k_route = 'key_1'; //

路由

key  

  

//

创建连接和

channel  

$conn = new AMQPConnection($conn_args);    

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

    

die("Cannot connect to the broker!\n");    

}    

$channel = new AMQPChannel($conn);    

  

//

消息内容

  

$message = "TEST MESSAGE! 

测试消息!

";    

  

//

创建交换机对象

     

$ex = new AMQPExchange($channel);    

$ex->setName($e_name);    

  

//

发送消息

  

//$channel->startTransaction(); //

开始事务

   

for($i=0; $i<5; ++$i){  

    

echo "Send Message:".$ex->publish($message, $k_route)."\n";   

}  

//$channel->commitTransaction(); //

提交事务

  

  

$conn->disconnect();    

 

需要注意的地方是:

 

queue

对象有两个方法可用于取消息:

consume

get

 

前者是阻塞的,无消息时会被挂起,适合循环中使用;

 

后者则是非阻塞的,取消息时有则取,无则返回

false

 

 

测试截图:

 

运行消费者,收消息:

 

 

 

运行生产者,发消息:

 

 

消费者接收到消息:

 

 

 

 

 

© 著作权归作者所有

共有 人打赏支持
mac_zhao
粉丝 40
博文 249
码字总数 304575
作品 0
普陀
程序员
消息中间件—RabbitMQ(集群监控篇1)

摘要:任何没有监控的系统上线,一旦在生产环境发生故障,那么排查和修复问题的及时性将无法得到保证 一、为何要对消息中间件进行监控? 上线的业务系统需要监控,然而诸如消息队列、数据库、...

癫狂侠 ⋅ 05/28 ⋅ 0

消息中间件—RabbitMQ(集群原理与搭建篇)

摘要:实际生产应用中都会采用消息队列的集群方案,如果选择RabbitMQ那么有必要了解下它的集群方案原理 一般来说,如果只是为了学习RabbitMQ或者验证业务工程的正确性那么在本地环境或者测试...

癫狂侠 ⋅ 05/25 ⋅ 0

Docker下RabbitMQ三部曲之一:极速体验(单机和集群)

从本章开始,我们一起在Docker环境实战RabbitMQ环境部署和对应的Java开发,当前是《Docker下RabbitMQ三部曲》系列的第一篇,整个三部曲由以下三篇文章组成: 1. 第一篇,即本章,我们用最快的...

boling_cavalry ⋅ 05/12 ⋅ 0

消息中间件—RabbitMQ(初探篇)

文章摘要:本篇文章为RabbitMQ的入门文章,不像其他一些程序代码和应用实战性的文章会带着大家从一个“Hello World”的简单例子出发,在该篇幅中主要给大家讲下RabbitMQ消息队列的起源、为何...

癫狂侠 ⋅ 05/23 ⋅ 0

Docker下RabbitMQ四部曲之四:高可用实战

本章是《Docker下RabbitMQ四部曲》系列的终篇,今天的我们一起来体验Rabbit’MQ集群的高可用能力,看看RabbitMQ集群中的部分节点宕机时,是否还能生产和消费消息; 原文地址:https://blog....

boling_cavalry ⋅ 05/19 ⋅ 0

openstack 最简单的 RabbitMQ 监控方法

先来看张图: 这是 Nova 的架构图,我们可以看到有两个组件处于架构的中心位置:数据库和Queue。数据库保存状态信息,而几乎所有的 nova-* 服务都直接依赖于 Queue 实现服务之间的通信和调用...

zhongbeida_xue ⋅ 05/09 ⋅ 0

Spring Boot+RabbitMQ学习笔记

RabbitMQ RabbitMQ 是一个由 Erlang 语言开发的 的开源实现。最初起源于金融系统,用于在分布式系统中存储转发消息,在易用性、扩展性、高可用性等方面表现不俗。 消息队列 先从基础开始,加...

听_风 ⋅ 06/07 ⋅ 0

SpringBoot笔记(十一)RabbitMQ

安装Erlang RabbitMQ基于Erlang,所以得先安装Erlang http://www.erlang.org/downloads 根据自己的系统选择下载,安装完了,配置一下path即可 windows默认安装路径: 验证: 有时候可能需要重...

世外大帝 ⋅ 04/25 ⋅ 0

RabbitMQ消息中间件介绍

一、基础介绍 随着分布式应用的发展消息队列中间件成为C/S架构中解耦的一个重要环节,传统的消息传输模型中,C端发出消息,S端必须在线,否则将无法继续进行,而在拥有消息中间件的模型下消息...

qiao645 ⋅ 06/21 ⋅ 0

RabbitMQ系列(一):Windows下RabbitMQ安装及入门

1.Windows下安装RabbitMQ需要以下几个步骤 (1):下载erlang,原因在于RabbitMQ服务端代码是使用并发式语言erlang编写的,下载地址:http://www.erlang.org/downloads,双击.exe文件进行安装就...

xiaomin0322 ⋅ 05/09 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

volatile和synchronized的区别

volatile和synchronized的区别 在讲这个之前需要先了解下JMM(Java memory Model :java内存模型):并发过程中如何处理可见性、原子性、有序性的问题--建立JMM模型 详情请看:https://baike.b...

MarinJ_Shao ⋅ 29分钟前 ⋅ 0

深入分析Kubernetes Critical Pod(一)

Author: xidianwangtao@gmail.com 摘要:大家在部署Kubernetes集群AddOn组件的时候,经常会看到Annotation scheduler.alpha.kubernetes.io/critical-pod"="",以表示这是一个关键服务,那你知...

WaltonWang ⋅ 37分钟前 ⋅ 0

原子性 - synchronized关键词

原子性概念 原子性提供了程序的互斥操作,同一时刻只能有一个线程能对某块代码进行操作。 原子性的实现方式 在jdk中,原子性的实现方式主要分为: synchronized:关键词,它依赖于JVM,保证了同...

dotleo ⋅ 43分钟前 ⋅ 0

【2018.06.22学习笔记】【linux高级知识 14.4-15.3】

14.4 exportfs命令 14.5 NFS客户端问题 15.1 FTP介绍 15.2/15.3 使用vsftpd搭建ftp

lgsxp ⋅ 53分钟前 ⋅ 0

JeeSite 4.0 功能权限管理基础(Shiro)

Shiro是Apache的一个开源框架,是一个权限管理的框架,实现用户认证、用户授权等。 只要有用户参与一般都要有权限管理,权限管理实现对用户访问系统的控制,按照安全规则或者安全策略控制用户...

ThinkGem ⋅ 昨天 ⋅ 0

python f-string 字符串格式化

主要内容 从Python 3.6开始,f-string是格式化字符串的一种很好的新方法。与其他格式化方式相比,它们不仅更易读,更简洁,不易出错,而且速度更快! 在本文的最后,您将了解如何以及为什么今...

阿豪boy ⋅ 昨天 ⋅ 0

Python实现自动登录站点

如果我们想要实现自动登录,那么我们就需要能够驱动浏览器(比如谷歌浏览器)来实现操作,ChromeDriver 刚好能够帮助我们这一点(非谷歌浏览器的驱动有所不同)。 一、确认软件版本 首先我们...

blackfoxya ⋅ 昨天 ⋅ 0

线性回归原理和实现基本认识

一:介绍 定义:线性回归在假设特证满足线性关系,根据给定的训练数据训练一个模型,并用此模型进行预测。为了了解这个定义,我们先举个简单的例子;我们假设一个线性方程 Y=2x+1, x变量为商...

wangxuwei ⋅ 昨天 ⋅ 0

容器之查看minikue的environment——minikube的环境信息

执行如下命令 mjduan@mjduandeMacBook-Pro:~/Docker % minikube docker-envexport DOCKER_TLS_VERIFY="1"export DOCKER_HOST="tcp://192.168.99.100:2376"export DOCKER_CERT_PATH="/U......

汉斯-冯-拉特 ⋅ 昨天 ⋅ 0

mysql远程连接不上

设置了root所有hosts远程登录,可是远程登录还是失败,原因可能如下: 登录本地数据库 mysql -uroot -p123456 查询用户表 mysql> select user,host,password from mysql.user; 删除密码为空的...

冰公子 ⋅ 昨天 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部