最后我们再处理一下用户断开连接的时候的处理工作。首先,我们需要在websocket断开的时候,去调用MessageController中的clo...
在用户订阅之后,我们就可以给用户发消息了,只要有用户向服务器发送了消息,就推送给其他所有用户。首先,我们需要在messageController...
首先,新建一个注册类,在这个类中,写用户注册的具体实现。 在这个类中,并没有写通知的具体内容,只是首先需要继承一下CommonService,在...
用户订阅的流程分为三步1.根据用户发送的json数据的type判断消息类型。2.如果是登录用户,就将用户的信息存储到redis中。3.返回给用户...
首先我们需要在根目录下新建一个db目录,然后在db目录下新建一个RedisInstance类文件,内容如下: 这是一个单例,在每次获取Redis...
我们首先看一下swoole官网上的文档。将上面的websocket面向对象示例拷贝一下。 可以看到在其生命周期中,执行了三个方法,分别是open...
首先编写一个autoload.php文件,以便所有的文件都可以自动载入,而不需要频繁的include. 然后需要引入一个config文件,在里面...
在聊天室工作的过程中,用户首先应该订阅(登录),在数据库中存储了用户与直播ID的对应信息之后,才能让用户去收发消息。订阅的数据结构按照MQ的方式...
首先确定一下目录结构。 app目录是应用文件目录config目录存放所有的配置logs是日志文件存放的目录pool是连接池文件,包括redis和...
文集作者