HelloWorld

前言

这里我们弱化broker内部构造。将整体分为三部分。

P：producer。生产者。

C：Consumer。消费者。

queue:队列。

后面的代码都依赖于 the php-amqplib API

composer安装php-amqplib

1. 新建composer.json

{"require": {"php-amqplib/php-amqplib": ">=2.6.1"}
}

2. composer.phar install

Hello World

talk is cheap , show you the code

sender.php

require_once __DIR__ . '/vendor/autoload.php';
use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;$connection = new AMQPStreamConnection('127.0.0.1', 5672, 'guest', 'guest');
$channel = $connection->channel();$channel->queue_declare('hello', false, false, false, false);$data = implode(" ", array_slice($argv, 1));
empty($data) && $data = "Hello World!";$msg = new AMQPMessage($data);$channel->basic_publish($msg, '', 'hello');echo " [x] Sent '$data'\n";//close the channel and connection;
$channel->close();
$connection->close();

receive.php

require_once __DIR__ . '/vendor/autoload.php';
use PhpAmqpLib\Connection\AMQPStreamConnection;$connection = new AMQPStreamConnection('127.0.0.1', 5672, 'guest', 'guest');
$channel = $connection->channel();$channel->queue_declare('hello', false, false, false, false);
echo ' [*] Waiting for messages. To exit press CTRL+C', "\n";$callback = function($msg) {echo "[x] Received ", $msg->body, "\n";sleep(substr_count($msg->body, '.'));echo "[x] Done\n";
};
$channel->basic_consume('hello', '', false, true, false, false, $callback);while(count($channel->callbacks)) {$channel->wait();
}

执行

打开两个终端,分别执行两个脚本。

终端一：

终端二：

终端一收到终端二发送的消息。

转载于:https://www.cnblogs.com/hejun695/p/7687380.html

RabbitMq初探——Hello World相关推荐

RabbitMq初探——安装
rabbitmq Server安装 rabbitmq server安装很简单. 安装erlang环境 rpm -ihv erlang-18.1-1.el6.x86_64.rpm rpm -ihv ra ...
RabbitMQ初探--用C#简单实现通信服务
MQ全称为Message Queue, 消息队列(MQ)是一种应用程序对应用程序的通信方法.应用程序通过读写出入队列的消息(针对应用程序的数据)来通信,而无需专用连接来链接它们. 消息传递指的是程序之 ...
[Erlang 0079] RabbitMQ 初探
最近在项目中实践RabbitMQ,比较幸运现在除了官方网站,还有一本非常棒的书可以读:RabbitMQ in Action;这本书目前还没有中文版或者影印版,但是从网上很容易找到PDF版本和epub ...
RabbitMQ初探
1. MQ是什么 MQ全称为Message Queue, 消息队列(MQ)是一种应用程序对应用程序的通信方法.应用程序通过写和检索出入列队的针对应用程序的数据(消息)来通信,而无需专用连接来链接它们 ...
初探 RabbitMQ 消息队列
初探 RabbitMQ 消息队列 rabbitmq基础概念常见应用场景导入依赖属性配置具体编码定义队列实体类控制器消息消费者主函数测试总结说点什么 SpringBoot 是为了简化 Spring 应用 ...
初探RabbitMQ与简单实现
RabbitMQ 简介: RabbitMQ是一个由Erlang语言开发的AMQP的开源实现,高级消息队列协议即Advanced Message Queuing Protocal,是应用层协议的一个开放 ...
初探RabbitMQ
官网安装教程视频安装简单模式入门案例环境搭建生产者代码消费者代码测试工作队列模式入门案例创建公共类(复用代码) 消费者代码生产者代码测试消息应答自动应答手动应答消息自动重 ...
从壹开始微服务 [ DDD ] 之一 ║ D3模式设计初探与我的计划书
缘起哈喽大家周四好!又是开心的一天,时间过的真快,我们的 <从壹开始 .net core 2.1 + vue 2.5 >前后端分离系列共 34 篇已经完结了,当然以后肯定还会有更新和修改 ...
一个winform带你玩转rabbitMQ
源码已放出 https://github.com/dubing/MaoyaRabbit 本章分3部分一.安装部署初探二.进阶三.api相关安装部署初探先上图一. 安装部署下载 rab ...

RabbitMq初探——Hello World