1
const WebSocket = require('ws');
2

3
let ws;  // 保存连接用的变量
4

5
function connect() {
6
  // 服务器地址和密钥
7
  const serverUrl = 'ws://127.0.1.1:32768';
8
  const token = 'abc12345';  // 这是访问密钥喵
9

10
  console.log('正在连接服务器...');
11

12
  // 创建 WebSocket 连接
13
  ws = new WebSocket(`${serverUrl}/?access_token=${token}`);
14

15
  // 连接成功时的处理
16
  ws.on('open', () => {
17
    console.log('✅ 连接成功，服务器已经准备好接收消息了！');
18
  });
19

20
  // 连接断开时的处理喵 (´;ω;｀)
21
  ws.on('close', () => {
22
    console.log('💔 啊啦~ 连接断开');
23
    console.log('🔄 3秒后重新连接');
24
    setTimeout(connect, 3000);  // 3秒后自动重连
25
  });
26

27
  // 出错时的处理
28
  ws.on('error', (error) => {
29
    console.log('连接出错了:', error.message);
30
  });
31
}
32

33
// 开始连接喵！
34
connect();

1
// 像这样把密钥放在链接里
2
// ws://服务器地址:端口号/?access_token=你的密钥
3

4
const ws = new WebSocket('ws://127.0.0.1:32768/?access_token=abc12345');

1
// 通用的消息发送函数
2
function sendMessage(messageData) {
3
  if (ws && ws.readyState === WebSocket.OPEN) {
4
    const jsonString = JSON.stringify(messageData);
5
    ws.send(jsonString);
6
    console.log('📤 消息发送成功');
7
  } else {
8
    console.log('连接还没准备好，不能发送消息');
9
  }
10
}

1
// 发送普通的群聊文字消息
2
function sendTextToGroup(groupId, text) {
3
  const message = {
4
    "action": "send_group_msg",
5
    "params": {
6
      "group_id": groupId,
7
      "message": [
8
        {
9
          "type": "text",
10
          "data": {
11
            "text": text
12
          }
13
        }
14
      ]
15
    }
16
  };
17

18
  sendMessage(message);
19
}
20

21
// 使用示例喵：
22
sendTextToGroup(123456, "大家好，我是可爱的猫娘~");

1
// 发送 @ 特定用户的消息喵~
2
function sendAtMessage(groupId, userId, text) {
3
  const message = {
4
    "action": "send_group_msg",
5
    "params": {
6
      "group_id": groupId,
7
      "message": [
8
        {
9
          "type": "at",
10
          "data": {
11
            "qq": userId.toString(),  // 要 @ 的用户ID喵
12
            "text": text              // 显示的文字喵
13
          }
14
        }
15
      ]
16
    }
17
  };
18

19
  sendMessage(message);
20
}
21

22
// 使用示例喵：
23
sendAtMessage(123456, 789012, "主人~");

1
// 设置消息监听器喵~
2
ws.on('message', (data) => {
3
  try {
4
    const message = JSON.parse(data);
5
    console.log('📥 收到新消息', message);
6

7
    // 在这里处理收到的消息喵
8
    // 比如回复、执行命令什么的...
9

10
  } catch (error) {
11
    console.log('❌ 消息解析失败了...');
12
  }
13
});