之前写了一个安卓app,其中使用了即时通信,简单的用了websocket,这里简单说明一下
- websocket是什么
http://www.ruanyifeng.com/blog/2017/05/websocket.html
简单理解就是能在两个端通信的一个协议,也可以用socket。
两边都监听自己的一个端口,端口收到数据就展示出来,想要发送数据就发送到这个端口即可
注意,执行流程是:服务端先启动,然后客户端向服务端发起连接,这样就建立了1对连接,每个客户端都向服务器发起连接,建立n对连接,每个客户端都可以和服务端进行通信
- 两个app如何通信
这里需要服务器做转发了,A->SERVER->B
;B->SERVER->A
;就是app把信息发给服务器,服务器再转发给另一个app,那么服务器怎么知道谁是另一个呢?我们可以做一个简单的注册和转发。具体如下:
每个客户端app都要连接websocket服务端,连接之后服务器端会保存这个客户端的连接信息,可以从这个连接获取信息或者发送信息给这个连接
现在服务端就有了所有已连接的app信息了,但是还是不知道谁是谁,所以要求app在连接的时候通报服务端用户id 是 什么,在服务端把用户id和连接信息关联起来,然后根据用户id找到连接信息去转发。
在app发消息的时候,我们可以简单规定一个格式,fromid:toid:msg
,当然也可以规定一个更复杂的协议,服务端收到之后拿到toid去转发。
// 服务端收到信息的操作
list($fromId,$toId,$msg) = explode(":",$data);
Log::info("receive-"."from=".$fromId."To=".$toId."msg=".$msg);
if (!array_key_exists($fromId,$worker->uidConnections) || $worker->uidConnections[$fromId] != $connection) {
$worker->uidConnections[$fromId] = $connection;
Log::info("this user first comes,his email=".$fromId);
}
// 安卓端点击发送的操作,拼接了我们说的格式
sendBtn.setOnClickListener(v -> {
String content=inputText.getText().toString();
if("".equals(content))
return;
if (client != null && client.isOpen()) {
Log.i("WebSocket",content);
client.send(myEmail+":"+toEmail+":"+content);
}
msgList.add(new Msg(content, Msg.TYPE.SENT));
//如果有新消息,则设置适配器的长度(通知适配器,有新的数据被插入),并让 RecyclerView 定位到最后一行
int newSize = msgList.size() - 1;
adapter.notifyItemInserted(newSize);
msgRecyclerView.scrollToPosition(newSize);
//清空输入框中的内容
inputText.setText("");
});
- 用到的框架
安卓用的是implementation "org.java-websocket:Java-WebSocket:1.4.0"
这个工具
php用的是ThinkPHP
+WorkerMan
- 源代码
近期代码不能公开,需要交流的可以留言