请教下各路大神， Flutter 连接 RabbitMQ 有人搞过吗？

《项目地址》有打包好的安卓安装包，测试账号testuser1、testuser2密码User001..，因为涉及到代码生成，如果使用不当会导致项目崩溃所以就不提供管理员账号了😂。

另外，贴一下代码

void onConnect(StompFrame frame) {
  print('onConnect');
  stompClient.subscribe(
    destination: '/exchange/room/6',
    callback: (frame) {
      List<dynamic>? result = json.decode(frame.body!);
      print(result);
    }
  );
  // Timer.periodic(const Duration(seconds: 10), (_) {
  //   stompClient.send(
  //     destination: 'ping',
  //     body: json.encode({'a': 123}),
  //   );
  // });
}

final stompClient = StompClient(
  config: StompConfig(
    useSockJS: true,
    url: 'ws://101.35.8.57:8005/ws',
    onConnect: onConnect,
    beforeConnect: () async {
      print('等待连接...');
      await Future.delayed(const Duration(milliseconds: 200));
      print('链接中...');
    },
    onWebSocketError: (dynamic error) => print(error.toString()),
    stompConnectHeaders: {
      "login": "guest",
      "passcode": "guest",
      "host": "/",
    },
    webSocketConnectHeaders: {
      "login": "admin",
      "passcode": "admin123..",
      "host": "/",
    },
  ),
);

谢谢大家，低级错误，已经解决了

报错的原因是使用了这个，把这个注释掉就发现OK了 webSocketConnectHeaders:

final stompClient = StompClient(
    config: StompConfig(
      // useSockJS: true, // 用了就收不到信息
      url: 'ws://IP:端口/ws',
      onConnect: onConnect,
      beforeConnect: () async {
        print('链接中...');
      },
      onWebSocketError: (dynamic error) => print(error.toString()),
      // webSocketConnectHeaders: // 不要用这个，会报错
      stompConnectHeaders: {
        'login': '账号',
        'passcode': '密码',
        "host": "/",
      },
    ));

dynamic onConnect(StompFrame frame) async {
  stompClient.subscribe(
      destination: '/exchange/room/6',// exchange+exchangeName+exchangeKey
      callback: (frame) async {
        print('/exchange/room/6-->');
        print(utf8.decode(frame.binaryBody!.toList()));
      }
  );
}

另外body返回的是null，需要转码一下binaryBody