IM-DEMO

//laravel-server地址
var api_host = 'http://localhost:8001';
//websocket服务地址
var websocket_host = 'ws://localhost:1024';

//启动websocket服务,监听所有地址的1024端口
$server = new swoole_websocket_server("0.0.0.0", 1024);
//连接redis服务
$redis->connect('127.0.0.1', 6379);

php artisan migrate

php artisan queue:work

php server.php start

public function __construct(Users $from_user, Users $to_user, Messages $message)
    {
        $this->message = $message;
        $this->to_user = $to_user;
        $this->from_user = $from_user;
        $this->client = new Client('ws://127.0.0.1:1024');
    }
    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        try{

            $this->client->send(json_encode([
                'type'=>'send_to_friend',
                'friend_id'=>$this->to_user->id,
                'msg'=>$this->message->content,
                'from'=>$this->from_user->user_name
            ]));
            $this->client->close();
            $this->message->status = '1';
            $this->message->save();
        } catch (\Exception $exception)
        {

        }

    }

public function __construct($user_id)
    {
        $this->user_id = $user_id;
        $this->client = new Client('ws://127.0.0.1:1024');
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        try{
            $message = new Messages();
            $user = new Users();
            $msg_list = $message->where(['to'=>$this->user_id,'status'=>'0'])->get();

            foreach ($msg_list as $k=>$v) {
                $this->client->send(json_encode([
                    'type'=>'send_to_friend',
                    'friend_id'=>$v->to,
                    'msg'=>$v->content,
                    'from'=>$user->find($v->from)->value('user_name')
                ]));
                $v->status = '1';
                $v->save();
            }

            $this->client->close();

        } catch (\Exception $exception)
        {

        }

    }