Rabbitmq 页面推送: WebSocket connection to ‘ws://xxx/ws‘ failed: Could not decod a text frame as UTF-8

客官°小女子只卖身不卖艺 2022-11-20 08:28 170阅读 0赞

笔者最近在使用rabbitmq stomp 插件进行页面推送时， 发现使用sock接受消息的页面报: Could not decod a text frame as UTF-8 错误， 经排查发现是服务端发送消息时，未配置文本消息转换器导致的。

### 1. 接受消息页面 ###

stomp.js: [https://github.com/rabbitmq/rabbitmq-web-stomp-examples/blob/master/priv/stomp.js][https_github.com_rabbitmq_rabbitmq-web-stomp-examples_blob_master_priv_stomp.js]

<script src="../js/jquery.3.51.js" ></script>
    <script src="../js/stomp.js" ></script>
    <script type="text/javascript">
        $(function(){ 
            var ws = new WebSocket('ws://xxx.xxx.xxx.xxx:15674/ws');
            ws.binaryType="arraybuffer";
            var client = Stomp.over(ws);
    
            var on_connect = function() { 
                console.log("连接到服务器");
    
                client.subscribe("/queue/Q_ALARM_LEVEL_UP", function(data) { 
                    console.log("接受到消息:" + data)
                    var msg = data.body;
                    $("#message").append("<p>接收到数据:" + msg + "</p>")
    
                });
    
                console.log('connected');
            };
            var on_error =  function() { 
                console.log('error');
            };
            client.connect('guest', 'guest', on_connect, on_error, 'test');
        });

## 2. 解决方案 ##

笔者服务端使用的是spring-amqp 框架，而spring-amqp 默认消息体格式为字节，但是页面接受默认为字符串， 因此需要配置一个消息转换器， 将发送消息时也转换为字符串。

@Configuration
    public class RabbitConfig { 
    
        @Bean
        Jackson2JsonMessageConverter messageConverter() { 
            return new Jackson2JsonMessageConverter();
        }
    
    }

[https_github.com_rabbitmq_rabbitmq-web-stomp-examples_blob_master_priv_stomp.js]: https://github.com/rabbitmq/rabbitmq-web-stomp-examples/blob/master/priv/stomp.js

发表评论取消回复

表情：

评论列表（有 0 条评论，170人围观）

还没有评论，来说两句吧...

相关阅读

相关解决 Could not decode a text frame as UTF-8 错误

解决 Could not decode a text frame as UTF-8 错误在我们使用网络传输时，经常会遇到各种奇怪的错误，比如 Could not decod

约定不等于承诺〃/ 2024年03月24日 09:52/ 0 赞/ 44 阅读

相关基于 Hyperf 实现 RabbitMQ + WebSocket 消息推送

思路利用 WebSocket 协议让客户端和服务器端保持有状态的长链接，保存链接上来的客户端 id。订阅发布者发布的消息针对已保存的客户端 id 进行广播消息。我的

爱被打了一巴掌/ 2023年05月22日 06:45/ 0 赞/ 41 阅读

相关 Rabbitmq 页面推送: WebSocket connection to ‘ws://xxx/ws‘ failed: Could not decod a text frame as UTF-8

笔者最近在使用rabbitmq stomp 插件进行页面推送时，发现使用sock接受消息的页面报: Could not decod a text frame as UTF-8

客官°小女子只卖身不卖艺/ 2022年11月20日 08:28/ 0 赞/ 171 阅读

相关 innobackupex: Error: Failed to connect to MySQL server as DBD::mysql module is not installed

innobackupex同时支持备份innodb和MyISAM(会加一个全局的读锁)。 \[mysql@gdsDB bin\]$ ./innobackupex --us

ゝ一纸荒年。/ 2022年09月30日 14:57/ 0 赞/ 3 阅读

相关 websocket消息推送

关于websocket等反向ajax技术介绍在实时web应用中，常见的方法是反向Ajax。反向Ajax的定义：反向Ajax（Reverse Ajax）本质上则是这样的一

ゞ浴缸里的玫瑰/ 2022年08月09日 00:39/ 0 赞/ 28 阅读

相关 beego：通过 websocket 向页面推送数据

这篇文章我们要基于 https://blog.csdn.net/u012210379/article/details/72901387 把功能整合到beego项目中去。一

淩亂°似流年/ 2022年04月22日 15:48/ 0 赞/ 528 阅读

相关 kali中启动msf提示Failed to connect to the database: could not connect to server: Connection refused

今天在kali中用msfconsole启动Metasploit时，提示： Failed to connect to the database: could not conne

落日映苍穹つ/ 2022年04月14日 04:28/ 0 赞/ 492 阅读

相关 websocket消息推送

参考 [http://www.cnblogs.com/best/p/5695570.html][http_www.cnblogs.com_best_p_5695570.htm

傷城~/ 2022年03月17日 06:14/ 0 赞/ 404 阅读

相关 Could not connect to '192.168.10.101' (port 22): Connection failed.

![20190412184222415.png][] 出现问题：xshell连接虚拟机时连接不上；问题诊断：使用root用户登录到虚拟机中，打开teminal,如下图：

客官°小女子只卖身不卖艺/ 2022年02月20日 06:29/ 0 赞/ 405 阅读

相关 utf8_decode() 函数

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xlbmd5

末蓝、/ 2022年02月16日 05:08/ 0 赞/ 226 阅读