关于laravel5 消息订阅/发布的理解初

laravel5.4
感觉官网文档说滴不够详细...安装predis官网很详细,这里略过....

生成命令

直接使用 Artisan 命令 make:command,该命令会在 app/Console/Commands 目录下创建一个新的命令类。如果该目录不存在,不用担心,它将会在你首次运行 Artisan 命令 make:command 时被创建。生成的命令将会包含默认的属性设置以及所有命令都共有的方法,

这里我生成一个RedisSubscribe.php类,执行下面命令:

php artisan make:command RedisSubscribe

引用官网上说的

Redis 还提供了调用 Redis 的publish 和 subscribe 命令的接口。这些 Redis 命令允许你在给定“频道”监听消息,你可以从另外一个应用发布消息到这个频道,甚至使用其它编程语言,从而允许你在不同的应用/进程之间轻松通信。

首先,让我们使用 subscribe 方法通过 Redis 在一个频道上设置监听器。由于调用 subscribe 方法会开启一个常驻进程,我们将在 Artisan 命令中调用该方法:

redis必须开启一个轮询监听频道滴服务进程,也就是上面说的 在 Artisan 命令中调用,如何调用?稍后测试下,
执行上诉命令后会看到:

<?php

namespace App\Console\Commands;

use Illuminate\Console\Command;
use Illuminate\Support\Facades\Redis;
class RedisSubscribe extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = ‘redis:subscribe‘;

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = ‘Subscribe to a Redis channel‘;

    /**
     * Create a new command instance.
     *
     * @return void
     */
    public function __construct()
    {
        parent::__construct();
    }

    /**
     * Execute the console command.
     *
     * @return mixed
     */
    public function handle()
    {
        \Redis::psubscribe([‘user-channel‘], function($message) {
            echo $message;
        });
    }
}
$signature 这里的配置会执行以下命名后看到:
php artisan list

比如我滴是:

现在,我们可以使用 publish 发布消息到该频道:

在执行以下代码前 现在控制台中输入:php artisan redis:subscribe 启动服务进程

Route::get(‘test‘, function () {
    // 路由逻辑...
  \Redis::publish(‘user-channel‘, json_encode([‘username‘ => ‘fantasy‘,‘message‘=>‘i miss you‘]));
 });

浏览器访问localhist:/test 执行上面的路由发布消息,会看到窗口中会接受到消息推送

一个消息发布/订阅基本实现了,那么问题来了,如何在web端实现消息订阅呢?
官网是这样说滴:

通过代码调用命令

有时候你可能希望在 CLI 之外执行 Artisan 命令,比如,你可能希望在路由或控制器中触发 Artisan 命令,你可以使用 Artisan 门面上的call 方法来完成这个功能。call 方法接收被执行的命令名称作为第一个参数,命令参数数组作为第二个参数,退出代码被返回:

那么我这里应该是

Route::get(‘/get‘, function () {
    $exitCode = \Artisan::call(‘redis:subscribe‘);//这里应该是代码启动进程监听的命令了
});

结果一直超时并不成功!...

对于laravel 的消息订阅模式..web端如何完整实现?如果有路过大神玩过,请留下宝贵的笔迹在下参考学习下额

时间: 2024-08-07 05:28:56

关于laravel5 消息订阅/发布的理解初的相关文章

redis的消息订阅发布介绍

1.redis的消息订阅发布: 进程间的一种消息通信模式:发送者(pub)发送信息,订阅者(sub)接收信息. 注: 图1为 三个客户端 client2.client5.client1 通过 subscribe 命令订阅 频道 channel1 ,图二为 当有新消息通过 publish 命令发送给频道 channel1时,这个消息就会被发送给订阅它的三个客户端. 2.消息订阅发布的相关命令: PSUBSCRIBE pattern [pattern...]: 订阅一个或者多个符合给定模式的频道 P

基于Redis的消息订阅/发布

在工业生产设计中,我们往往需要实现一个基于消息订阅的模式,用来对非定时的的消息进行监听订阅. 这种设计模式在 总线设计模式中得到体现.微软以前的WCF中实现了服务总线 ServiceBus的设计模式.然并卵.WCF已经好像是上个世纪的产物................ 基于事件订阅的模式,比如 EventBus类的组件产品.但是往往设计比较复杂. 如果依赖于 Redis做事件消息推送.那就大大简化了这种设计模式,而且性能也比较客观. Redis在 2.0之后的版本中 实现了 事件推送的  pu

【并发】9、借助redis 实现生产消费,消息订阅发布模式队列

这个就是一个消息可以被多次消费的范例了 其实这个实现的方式可以参考我之前的设计模式,观察者模式 https://www.cnblogs.com/cutter-point/p/5249780.html 不过有一点需要注意一下啊,这个消息发布的时候,好像是不支持字节数据的,里面好像会对字节进行转换,这样的结果就是导致我最后无法吧相应的字节转换成我之前序列化的对象 不知道是不是ObjectInputStream和ObjectOutputStream实现不是很好的原因,还是什么,反正反序列化的时候,有些

C# 数据推送 实时数据推送 轻量级消息订阅发布 多级消息推送 分布式推送

前言 本文将使用一个NuGet公开的组件技术来实现数据订阅推送功能,由服务器进行推送数据,客户端订阅指定的数据后,即可以接收服务器推送过来的数据,包含了自动重连功能,使用非常方便 nuget地址:https://www.nuget.org/packages/HslCommunication/            github地址:https://github.com/dathlin/HslCommunication                                 如果喜欢可以s

消息订阅发布系统Apache Kafka分布式集群环境搭建和简单测试

一.什么是kafka? kafka是LinkedIn开发并开源的一个分布式MQ系统,现在是Apache的一个孵化项目.在它的主页描述kafka为一个高吞吐量的分布式(能将消息分散到不同的节点上)MQ.Kafka仅仅由7000行Scala编写,据了解,Kafka每秒可以生产约25万消息(50 MB),每秒处理55万消息(110 MB) 二.kafka的官方网站在哪里? http://kafka.apache.org/ 三.在哪里下载?需要哪些组件的支持? kafka2.9.2在下面的地址可以下载:

何实现类似JMS的消息订阅/发布机制? 用.net编写的客户端程序如何与使用JMS进行消息

baozoumanhua.com/users/17557217 baozoumanhua.com/users/17557217/forum_articles baozoumanhua.com/users/17557217/followings baozoumanhua.com/users/17557217/talkings baozoumanhua.com/users/17557217/following_articles baozoumanhua.com/users/17557217/arti

基于Redis消息的订阅发布应用场景

原文:基于Redis消息的订阅发布应用场景 目录 基于Redis消息的订阅发布应用场景 1.应用背景 2.困境 2.1 锁表风险 2.2 实时性差 2.3 增加编程复杂性 2.4 实时效果 3.解决方案 3.1 前端传值给服务端 3.2 服务端通过消息传给采集控制端 4.详细代码设计 4.1 CSRedisCore 4.2 接口设计如下 4.3 接口实现如下 4.4 ConfigureServices中依赖注入 4.5 创建一个RedisMQ的消息对象 4.6 实现层代码设计 5.效果 5.1

详谈:Redis事务和消息订阅

一.Redis事务 1.概念 可以一次执行多个命令,本质是一组命令的集合.一个事务中的 所有命令都会序列化,按顺序地串行化执行而不会被其它命令插入,不许加塞. 事务能做的事: 一个队列中,一次性.顺序性.排他性的执行一系列命令 常用命令: DISCARD: 取消事务,放弃执行事务块内的所有命令: EXEC : 执行所有事务块内的命令: MULTI : 标记一个事务块的开始: WATCH key([key ....]) : 监视一个(或多个) key,如果在事务执行之前这个(或这些)key被其他命

linux下使用hiredis异步API实现sub/pub消息订阅和发布的功能

最近使用redis的c接口--hiredis,使客户端与redis服务器通信,实现消息订阅和发布(PUB/SUB)的功能,我把遇到的一些问题和解决方法列出来供大家学习. 废话不多说,先贴代码. redis_publisher.h /************************************************************************* > File Name: redis_publisher.h > Author: chenzengba > Ma