laravel5.5 laravel echo实现实时应用(私信)

╰+攻爆jí腚メ 2022-04-03 01:47 162阅读 0赞

### 文章目录 ###

*   *   *   *  场景
             *  分析
             *  实现(pusher driver)
             *   *  效果
                 *  监听private channel
                 *  注册Broadcast Event源码
                 *  register broadcast

#### 场景 ####

*  一个类知乎网站的私信功能

#### 分析 ####

*  实现方式
    
     *  vue
     *  [laravel echo ][laravel echo]
     *  [pusher][]
     *  [supervisor][]
 *  私信功能的实现见我的另一篇博文 [网站私信表(留言表)的设计 && 空间换性能的思路][Link 1]

#### 实现(pusher driver) ####

*  安装
    
     *  composer require pusher/pusher-php-server “~3.0”
     *  npm install --save laravel-echo pusher-js
 *  注册pusher 服务
    
     *  [地址][pusher]
 *  配置
    
     *  .env 配置 pusher相关参数
     *  config/app.php 注册App\\Providers\\BroadcastServiceProvider::class,
     *  resources/assets/js/bootstrap.js 去掉关于Pusher相关的注释 && 填写相关的配置信息
     *  注册Broadcast Event源码
        
         *  注意channel是private
         *  MessageModel中绑定$dispatchesEvents属性,自动触发事件
     *  [Defining Authorization Callbacks][]
        
         *  `Broadcast::channel('message-to-created.{user_id}', function($user, $user_id){return (int)$user_id === (int) $user->id;});`
     *  监听channel
        
         *  在需要的组件中定义 源码

##### 效果 #####

[效果在线查看][Link 2]

##### 监听private channel #####

mounted: function () { 
                // 监听channel
                this.listenMessageChannel();
    
                // 初始化列表
                this.requestMessage();
            },
            methods: { 
                listenMessageChannel : function(){ 
                      let vm = this;
                      window.Echo.private('message-to-created.' + window.Laravel.user_id).listen('MessageCreateEvent', function(e){ 
                          let message = e.message;
                          message.from_user = e.from_user;
                          vm.list_message.unshift(e.message);
                      });
                },
               }

##### 注册Broadcast Event源码 #####

##### register broadcast #####

<?php
    
    namespace App\Events;
    
    use App\Message;
    use Illuminate\Broadcasting\Channel;
    use Illuminate\Contracts\Broadcasting\ShouldBroadcastNow;
    use Illuminate\Queue\SerializesModels;
    use Illuminate\Broadcasting\PrivateChannel;
    use Illuminate\Broadcasting\PresenceChannel;
    use Illuminate\Foundation\Events\Dispatchable;
    use Illuminate\Broadcasting\InteractsWithSockets;
    use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
    
    class MessageCreateEvent implements ShouldBroadcast
    { 
        use Dispatchable, InteractsWithSockets, SerializesModels;
    
        public $from_user;
        public $message;
    
        public $broadcastQueue = 'private-message-to-created';
    
        public function broadcastWhen()
        { 
            return $this->message->user_id == $this->message->to_user_id;
        }
    
        /** * Create a new event instance. * * @param Message $message */
        public function __construct(Message $message)
        { 
            $this->message = $message;
            $this->from_user = $this->message->fromUser;
        }
    
        /** * Get the channels the event should broadcast on. * * @return \Illuminate\Broadcasting\Channel|array */
        public function broadcastOn()
        { 
            $private_counter_channel = new PrivateChannel('message-to-counter.' . $this->message->user_id);
            $private_created_channel = new PrivateChannel('message-to-created.' . $this->message->user_id);
            return [
                $private_counter_channel,
                $private_created_channel
            ];
        }
    }

[laravel echo]: https://laravel.com/docs/5.5/broadcasting
[pusher]: https://dashboard.pusher.com/
[supervisor]: http://supervisord.org/installing.html
[Link 1]: https://blog.csdn.net/cominglately/article/details/81300173
[Defining Authorization Callbacks]: https://laravel.com/docs/5.5/broadcasting#defining-authorization-routes
[Link 2]: https://zhihu.carsonlius.vip/