首页 > 专利查询

rabbitmq控制面板_rabbitMQ消息队列–面板介绍及简单demo

rabbitmq控制⾯板_rabbitMQ消息队列–⾯板介绍及简单demo ⾸先rabbit安装好之后，运维会给⼀个控制⾯板.

默认账号密码为guest

登⼊以后可以看到具体界⾯.

在此鸣谢百度翻译给予的⼤⼒⽀持..

###写⼀个简单的demo

编写之前..虽然说可以直接⽤底层扩展实现连接.但是还是⽤封装过的代码⽐较好⼀些.

所以我们使⽤了⽐较有名的类库来开发

假设你装有composer，并设置了国内源

可以在命令⾏创建⼀个⽬录，并执⾏命令

⾸先了解下类库结构,⽬录如下

\vendor\php-amqplib\php-amqplib\PhpAmqpLib

|-Channel 消息通道类库

|-Connection 链接类库

|-Exception 异常类库

|-Helper 助⼿类

|-Message 消息类

|-Wire 通讯类库

###链接类Connection

你可以⽤不同的⽅式链接MQ服务器，同时封装了

⽂件列举如下

|–AMQPConnection常⽤的，实际上就是AMQPStreamConnection套了个马甲

|–AMQPLazyConnection惰性链接，也是AMQPStreamConnection的⼦类

|–AMQPSocketConnection TCP/IP链接

|–AMQPSSLConnection 加密链接,AMQPStreamConnection的⼦类

|–AMQPStreamConnection 流式链接

>[info]实际上⼀共也就是两种链接⽅式Stream和Socket

木质精油PHP对Socket进⾏了封装形成的Stream_Socket⽀持更多通讯协议.如加密传输.

但是太具体的区别，确实不清楚.后续我们将使⽤AMQPConnection这个进⾏链接

链接类库的具体作⽤

实现登⼊

实现了消息通道的管理

###通道类Channel

|–AMQPChannel

主要功能么.进⾏绑定,⽐如交换机，队列名.发送消息.接收消息

###异常类Exception

|–AMQPBasicCancel

需整理实践

###助⼿类Helper

###消息类Message

###未知类Wire

//引⼊库引导⽂件

require 'vendor/autoload.php';

$conn_args = array(

'host'=>'127.0.0.1', //rabbitmq 服务器host

谭碧生

'port'=>5672, //rabbitmq 服务器端⼝

碎花刀刀'login'=>'guest', //登录⽤户

'password'=>'guest', //登录密码

节能转轮除湿机'vhost'=>'/' //虚拟主机

);

$e_name = 'e_demo';

$q_name = 'q_demo';

$k_route = 'key_1';

$conn = new AMQPConnection($conn_args);ktkp-073

加热搅拌反应釜

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

die('Cannot connect to the broker');

}

$channel = new AMQPChannel($conn);

$ex = new AMQPExchange($channel);

$ex->setName($e_name);

$ex->setType(AMQP_EX_TYPE_DIRECT);

$ex->setFlags(AMQP_DURABLE);

$status = $ex->declareExchange(); //声明⼀个新交换机，如果这个交换机已经存在了，就不需要再调⽤declareExchange()⽅法了. $q = new AMQPQueue($channel);

$q->setName($q_name);

$status = $q->declareQueue(); //同理如果该队列已经存在不⽤再调⽤这个⽅法了。

$ex->publish($msg, $k_route);

本文发布于:2024-09-22 05:23:02，感谢您对本站的认可！

本文链接：https://www.17tex.com/tex/4/183108.html

上一篇：ros回调函数多线程

下一篇：基于微服务的智慧校园消息中心构建研究

标签：消息链接类库队列交换机封装运维会

留言与评论（共有 0 条评论）