请教下各路大神， 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