websocket+layim实现一对一聊天流程

前端页面

在前端页面中，需要引入LayIM和WebSocket相关的库，同时需要进行初始化配置，如下所示：

// 引入LayIM库
<script src="layui/layui.js"></script>
// 引入WebSocket库
<script src="js/websocket.js"></script>

// 初始化LayIM
layui.use('layim', function(layim){
  // 配置LayIM
  layim.config({
    // 初始化个人信息
    init: {
      mine: {
        "username": "张三",
        "id": "1001",
        "avatar": "http://xxx.com/images/avatar.jpg",
        "sign": "这个人很懒，什么也没留下"
      }
    },
    // 初始化好友列表
    friend: [{
      "groupname": "好友",
      "id": 1,
      "list": [{
        "username": "李四",
        "id": "1002",
        "avatar": "http://xxx.com/images/avatar.jpg",
        "sign": "这个人很懒，什么也没留下"
      }]
    }]
  });

  // 监听发送消息事件
  layim.on('sendMessage', function(data){
    // 发送消息到WebSocket服务器
    websocket.send(JSON.stringify(data));
  });

  // 监听WebSocket消息事件
  websocket.onmessage = function(event){
    var data = JSON.parse(event.data);
    // 在聊天窗口中显示接收到的消息
    layim.getMessage(data);
  };
});

WebSocket服务器

在WebSocket服务器中，需要监听客户端的连接请求，同时需要实现一对一聊天的逻辑，如下所示：

import asyncio
import websockets

# 存储WebSocket连接和用户信息的字典
connections = {}

# 处理客户端连接请求
async def handle_connection(websocket, path):
    # 获取用户ID
    user_id = await websocket.recv()
    # 将WebSocket连接和用户信息存储到字典中
    connections[user_id] = websocket
    try:
        # 监听客户端消息
        async for message in websocket:
            # 解析消息
            data = json.loads(message)
            # 获取接收方ID
            to_user_id = data['to']['id']
            # 获取发送方信息
            from_user = data['mine']
            # 获取接收方信息
            to_user = data['to']
            # 如果接收方在线，则将消息发送给接收方
            if to_user_id in connections:
                await connections[to_user_id].send(json.dumps({
                    'username': from_user['username'],
                    'avatar': from_user['avatar'],
                    'id': from_user['id'],
                    'type': 'friend',
                    'content': data['mine']['content'],
                    'timestamp': new Date().getTime()
                }))
    finally:
        # 删除字典中的WebSocket连接和用户信息
        del connections[user_id]

# 启动WebSocket服务器
start_server = websockets.serve(handle_connection, 'localhost', 8000)

# 运行事件循环
asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()

流程说明

当用户在LayIM中向好友发送消息时，触发发送消息事件，将消息发送到WebSocket服务器。服务器接收到消息后，解析消息，获取接收方ID，如果接收方在线，则将消息发送给接收方。接收方在LayIM中收到消息后，将其显示在聊天窗口中