如何使用Swift连接Socket.IO及实现一对一聊天？

嗨，很高兴看到你已经搞定了Socket.IO的群聊和基础连接！下面我就针对你的两个问题详细说说：

既然你已经完成了连接，我还是把标准步骤梳理一遍，方便你核对或者扩展：

• 第一步：安装依赖
  如果用CocoaPods，在Podfile里添加：

  pod 'Socket.IO-Client-Swift', '~> 15.0'
  

  然后执行pod install；如果用Swift Package Manager，直接在Xcode里添加仓库地址即可。

• 第二步：初始化Socket连接
  导入模块后，创建Socket实例并配置连接参数：

  import SocketIO
  
  class SocketManagerHelper {
      static let shared = SocketManagerHelper()
      private let manager: SocketManager
      var socket: SocketIOClient
  
      private init() {
          // 替换成你的服务器地址
          manager = SocketManager(socketURL: URL(string: "http://your-server-ip:3000")!, config: [
              .log(true),
              .compress,
              .connectParams(["userId": "your-user-id"]) // 可以带初始参数，比如用户ID
          ])
          socket = manager.defaultSocket
      }
  
      func connect() {
          socket.connect()
  
          // 监听连接事件
          socket.on(clientEvent: .connect) { _, _ in
              print("Socket连接成功！")
          }
  
          // 监听断开事件
          socket.on(clientEvent: .disconnect) { _, _ in
              print("Socket断开连接")
          }
  
          // 监听错误
          socket.on(clientEvent: .error) { data, _ in
              if let error = data.first as? String {
                  print("Socket错误：\(error)")
              }
          }
      }
  
      func disconnect() {
          socket.disconnect()
      }
  }
  

  之后在需要的地方调用SocketManagerHelper.shared.connect()就能建立连接了。

你猜的没错，一对一聊天最优雅的实现方式就是利用Socket.IO的房间功能——本质上就是给两个用户创建一个专属的“小聊天室”，只有这个房间里的用户能收到消息。具体步骤如下：

1. 服务器端（Node.js）的关键逻辑 #

首先得给每个连接的Socket绑定用户ID（用户登录时传递），然后处理房间的创建和消息转发：

const io = require('socket.io')(3000, {
  cors: {
    origin: "*", // 开发环境可以放开，生产环境要指定你的App域名
    methods: ["GET", "POST"]
  }
});

io.on('connection', (socket) => {
  // 1. 用户登录：绑定Socket和用户ID
  socket.on('user_login', (userId) => {
    socket.userId = userId;
    console.log(`用户 ${userId} 已连接`);
  });

  // 2. 加入一对一专属房间
  socket.on('join_private_room', (targetUserId) => {
    // 生成唯一房间名：把两个用户ID按字典序拼接，避免重复（比如userA_userB和userB_userA是同一个房间）
    const roomName = [socket.userId, targetUserId].sort().join('_');
    // 当前用户加入房间
    socket.join(roomName);
    // 通知目标用户也加入这个房间（如果对方在线）
    io.to(targetUserId).emit('invite_join_room', roomName);
  });

  // 3. 处理一对一消息发送
  socket.on('send_private_msg', (msgData) => {
    const { targetUserId, content } = msgData;
    const roomName = [socket.userId, targetUserId].sort().join('_');
    // 只给房间里的用户发消息
    io.to(roomName).emit('receive_private_msg', {
      fromUserId: socket.userId,
      content: content,
      timestamp: Date.now()
    });
  });
});

2. Swift客户端的对应实现 #

在客户端，你需要处理登录、加入房间、发送消息和接收消息的逻辑：

// 1. 用户登录时发送ID给服务器
SocketManagerHelper.shared.socket.emit("user_login", currentUserId)

// 2. 发起一对一聊天：加入专属房间
func startPrivateChat(with targetUserId: String) {
    SocketManagerHelper.shared.socket.emit("join_private_room", targetUserId)
    // 监听服务器发来的加入房间通知（如果是被邀请方）
    SocketManagerHelper.shared.socket.on("invite_join_room") { data, _ in
        guard let roomName = data.first as? String else { return }
        // 这里可以记录房间名，后续用它管理聊天状态
        print("加入房间：\(roomName)")
    }
}

// 3. 发送一对一消息
func sendPrivateMessage(to targetUserId: String, content: String) {
    let msgData: [String: Any] = [
        "targetUserId": targetUserId,
        "content": content
    ]
    SocketManagerHelper.shared.socket.emit("send_private_msg", msgData)
}

// 4. 监听一对一消息
func setupPrivateMessageListener() {
    SocketManagerHelper.shared.socket.on("receive_private_msg") { [weak self] data, _ in
        guard let msgDict = data.first as? [String: Any],
              let fromId = msgDict["fromUserId"] as? String,
              let content = msgDict["content"] as? String else { return }
        // 根据发送者ID，把消息显示到对应的聊天窗口
        self?.updateChatWindow(for: fromId, with: content)
    }
}

额外注意点 #

• 房间名唯一性：一定要用排序后的用户ID拼接，这样不管是A发起还是B发起，房间名都是一样的，避免创建重复房间。
• 离线处理：如果目标用户不在线，服务器可以把消息暂存到数据库，等用户上线后再推送。
• 重连后重新加入房间：客户端断开重连后，需要重新向服务器请求加入之前的聊天房间，不然收不到后续消息。

内容的提问来源于stack exchange，提问作者Bittoo Praveen