rabbit 消息推送

作者: 响呼雷 | 来源:发表于2020-01-09 15:19 被阅读0次

1.首先需要安装PHP使用的RabbitMQ 包:php-amqplib

composer require php-amqplib/php-amqplib

2.引入stomp.js,官方地址:https://www.bootcdn.cn/stomp.js/

<script src="https://cdn.bootcss.com/stomp.js/2.3.3/stomp.js"></script>

3.上代码

server.php

require_once __DIR__ . '/vendor/autoload.php';
use PhpAmqpLib\Connection\AMQPStreamConnection;             //引入队列流连接类

//连接主机
$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');

//建立通道
$channel = $connection->channel();

//创建队列
$channel->queue_declare('hello', false, false, false, false);


//闭包回调函数
$callback = function ($msg) {
    print_r($msg);
};

//消费队列消息
$channel->basic_consume('hello', '', false, true, false, false, $callback);


//等待消息
while ($channel->is_consuming()) {
    $channel->wait();
}

client.php

require_once __DIR__.'/vendor/autoload.php';

//连接主机
$connection = new \PhpAmqpLib\Connection\AMQPStreamConnection('127.0.0.1', 5672, 'guest', 'guest');

//建立通道
$channel = $connection->channel();

//建立队列
$channel->queue_declare('hello', false, false, false, false);

//准备消息
$msg = new \PhpAmqpLib\Message\AMQPMessage('hello,我要发送的消息内容~~~'.time());

//公布消息
$channel->basic_publish($msg, '', 'hello');

//关闭通道
$channel->close();

//关闭链接
$connection->close();

相关文章

  • rabbit 消息推送

    1.首先需要安装PHP使用的RabbitMQ 包:php-amqplib composer require php...

  • RabbitMQ 参数属性

    RabbitMQ rabbit message queue的基本概念 producer:消息生产者,就是投递消息的...

  • 消息推送

    推送通知的呈现效果总结 推送通知有5种不同的呈现效果1、在屏幕顶部显示一块横幅(显示具体内容)2、在屏幕中间弹出一...

  • 消息推送

    1、.简述一下消息推送的流程 2、如果不依赖APNS,如何在App进入后台时保证能够接收到远程消息?

  • 消息推送

    推送概念? APNs:Apple Push Notification Service,远程通知只能APNs服务器发...

  • 消息推送

    本地推送 @implementation AppDelegate 远程推送http://blog.csdn.net...

  • 消息推送

  • 消息推送

    http://blog.csdn.net/showhilllee/article/details/8631734

  • 消息推送

    https://www.jianshu.com/p/c58f8322a278

  • 消息推送

    1 什么是消息推送 很多手机APP会不定时的给用户推送消息,例如一些新闻APP会给用户推送用户可能感兴趣的新闻,或...

网友评论

    本文标题:rabbit 消息推送

    本文链接:https://www.haomeiwen.com/subject/lybyactx.html