activemq与websocket结合无法向前台推送 10C

activemq接收到消息后,调用websocket的convertAndSend接口向前台发送消息,前台接收不到。但是通过在controller里面编写测试代码,调用convertAndSend进行发送,前台是可以接收到信息的。请问是怎么回事呢。
activemq的接收端代码:
@Service
public class CalculateQueueReceiver implements MessageListener {
@Autowired
private MessageSendMaster messageSendMaster;

@Override
public void onMessage(Message message) {
    ActiveMQBytesMessage bytesMessage = (ActiveMQBytesMessage) message;
    String s = new String(bytesMessage.getContent().getData());
    System.out.println(new Date() + s);
    messageSendMaster.sendMessage(s);
}

}
@Component
public class MessageSendMaster {
private static Logger logger = Logger.getLogger(MessageSendMaster.class);
@Autowired
private SimpMessagingTemplate template;

public void sendMessage(String  message){
    try {
        template.convertAndSend("/topic/calculate", message);
    } catch (Exception e) {
        logger.error(e.getMessage(), e);
        e.printStackTrace();
    }
}

}

1

1个回答

断点看一下 有没有报错 或者堵塞

0
Jennyleee
jennyleee 解决了吗朋友,我遇到同样的问题
10 个月之前 回复
wc936248
wc936248 发送消息的socket和接收消息的socket对象是同一个对象吗
大约一年之前 回复
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
spring boot 整合activemq 进行服务端消息推送(web页面)
最近公司的项目里有需要服务端向web端实时推送消息的需求,网上搜索了一番,有前端页面通过定时任务向后台发送ajax请求刷新,有使用第三方提供的消息服务(GoEasy),前者因为会有很多请求是无用的,容易加大服务器负荷造成宕机,后者现在收费了(免费的也只能用一年并且使用上有所限制)。后来在网上看到activemq可以通过ajax请求访问订阅消息,于是便想到用activemq来实现此功能并记录下来,供自
springboot整合websocket实现消息推送.
springboot整合websocket实现消息推送 1.maven配置 2.书写后端代码 3.书写前端代码 4.测试 1.maven依赖 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spr...
ActiveMQ与spring整合,从后台发送消息,从前台接收消息。
关于ActiveMQ文档整理(以topic为例,从后台发送消息,从前台接收消息) 1、首先需要创建一个Web Project项目,引入ActiveMQ所需要的jar包,如图所示:   2、和spring进行整合,首先需要创建一个applicationContext.xml文件,在这个文件里面需要配置的内容。 (1)配置链接工厂,设置代理URL bean id="connectionFac
Spring+ActiveMQ消息队列+前台接收消息
整合Spring + ActiveMQ 的朋友可以下载看一下 简单易懂
RabbitMQ订阅发布的消息,通过WebSocket实现数据实时推送到前端上显
一、架构简单概述  RabbitMQ消息队列服务善于解决多系统、异构系统间的数据交换(消息通知/通讯)问题,并且可以订阅和发布,而随着HTML5诞生的WebSocket协议实现了浏览器与服务器的全双工通信,扩展了浏览器与服务端的通信功能,使服务端也能主动向客户端发送数据。  因此,我们可以使用RabbitMQ的订阅发布技术,订阅后,当RabbitMQ端有新的数据就直接发布到指定的queue,订
定时推送后台数据到前台websocket和sse实现
前言:本文的实现环境基于springboot2 1、websocket的实现 前端页面: <!DOCTYPE html> <html> <head lang="en">     <meta charset="UTF-8" />     <title></title> </head&
springboot websocket后台主动推送消息
springboot,websocket,后台主动推送消息1.2.pom<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schema...
C#基于websocket的前台及后台实时推送
 C# websocket实时消息推送   实现步骤如下: 1.        获取GoEasy appkey. 在goeasy官网上注册一个账号,并新建一个app. APP创建好后系统会为该app自动生成两个key, 一个既可以用来接收又可以用来推送 (supper key),另一个只可以用来接收(subscriber key). 2.        客户端订阅一个channel. ...
websocket后台自动推送消息
websocket后台自动推送消息目前网上实现的都是客户端与服务端双向通信的例子。例如聊天室。之前做项目遇到这样的问题:客户端仅仅负责接收服务器后台数据,不做发送,这样如何实现呢? 其实实现的方法很简单: 第一步: 将之前的WebSocket端点设置成静态公共 public static CopyOnWriteArraySet<MyWebSocket> webSocketSet = new C
SpringMVC 使用websocket向前端实时推送信息
一、maven项目添加websocket依赖 在pom.xml中添加依赖
PHP基于websocket的前台及后台实时推送
 PHP websocket实时消息推送   实现步骤如下: 1.        获取GoEasy appkey. 在goeasy官网上注册一个账号,并新建一个app. APP创建好后系统会为该app自动生成两个key, 一个既可以用来接收又可以用来推送 (supper key),另一个只可以用来接收(subscriber key). 2.        客户端订阅一个channel....
Java使用Websocket向客户端推送消息
需求:外卖平台收到订单后,向商家推送消息,有新订单了,并播放音频。 客户端  list.ftl &amp;lt;html&amp;gt; &amp;lt;#include &quot;../common/header.ftl&quot;&amp;gt; &amp;lt;body&amp;gt; &amp;lt;div id=&quot;wrapper&quot; class=&quot;toggled&quot;&amp;gt; &amp;lt;#--边栏sidebar--&amp;gt;
websocket+spring实现定时向前端推送数据
本文不介绍websocket的理论知识,直接进行代码的实现,并且只对服务端进行实现,没有前端页面代码,通过在线工具进行测试 开发环境:eclipse Mars Release(4.5.0) + jdk1.7.0_79 + apache-maven-3.3.9 + tomcat7.0.82 1.项目模块 2.pom.xml
ActiveMQ支持安全websocket连接
注意:在ActiveMQ5.11.1+jdk1.7环境中验证通过。 步骤: 1、使用JDK自带的证书生成工具,生成证书; keytool -genkeypair -alias "active" -keyalg "RSA" -keystore "d:\activemq.keystore" 记住生成证书过程中设置的password。 2、将activemq.keystore文件拷贝到Acti
PHP基于websocket的前台及后台实时推送
 PHP websocket实时消息推送   实现步骤如下: 1.        获取GoEasy appkey. 在goeasy官网上注册一个账号,并新建一个app. APP创建好后系统会为该app自动生成两个key, 一个既可以用来接收又可以用来推送 (supper key),另一个只可以用来接收(subscriber key). 2.        客户端订阅一个channel....
使用WebSocket协议接收ActiveMQ消息
ActiveMQ允许客户端使用多种协议接收消息,其中WebSocket协议的URL使用ws://开头,默认端口号是61614
websockt实现从后台到前台实时推送消息的需要的架构
1.在后台需要的是springBoot框架2.socketjs:    1. 是一个浏览器JavaScript库,提供了一个类似WebSocket的对象    2. 提供一个连贯的跨浏览器的JavaScriptAPI,在浏览器和Web服务器之间创建了一个低延迟,全双工,跨域的通信通道   3. 在底层SocketJs首先尝试使用本地webSocket,如果失败了,它可以使用各种浏览器特定的传输协议...
spring+websocket+quartz实现消息定时推送
websocket 简单的说,websocket是真正实现了全双工通信的服务器向客户端推的互联网技术。 全双工与单工、半双工的区别? 1. 全双工:简单地说,就是可以同时进行信号的双向传输(A-&amp;amp;amp;amp;amp;gt;B且B-&amp;amp;amp;amp;amp;gt;A),是瞬时同步的。 2. 单工、半双工:一个时间段内只有一个动作发生。 推送和拉取的区别? 1. 推:由服务器主动发消息给客户端,就像广播。优势在于,信息的主动性和及时性...
Java之消息推送之WebSocket
[b]一、问题背景[/b] HTTP 协议是单向协议。 [b]二、实现服务器端向客户端进行消息推送[/b] [url]http://www.cnblogs.com/best/p/5695570.html[/url] [b]三、WebSocket机制[/b] WebSocket 是 HTML5 一种新的协议。它实现了浏览器与服务器全双工通信,能更好的节省...
JavaWeb后台自动向前台发送消息
JavaWeb项目后台向前推送消息,主要是是利用第三方包Comet4J,附件中是MyEclipse开发的源码,可直接运行。
Java Spring WebSocket实现后端消息主动推送
这篇文章将介绍如何构建一个简单的WebSocket消息推送Demo使用eclipse建立maven项目后引入相关的依赖jar包,如下:&amp;lt;?xml version=&quot;1.0&quot; encoding=&quot;UTF-8&quot;?&amp;gt;&amp;lt;project xmlns=&quot;http://maven.apache.org/POM/4.0.0&quot; xmlns:xsi=&quot;http://www.w3.org/2001/X...
websocket的使用(不适用遍历,接受后台数据的推送)
websocket_test(){/*websocket的测试*/             let that=this;             let datas=JSON.stringify({                 name:&quot;quanholo&quot;,                 age:45             });             console.log(type...
websocket后台推送数据
介绍 现在很多网站为了实现即时通讯,所用的技术都是轮询(polling)。轮询是在特定的的时间间隔(如每1秒), 由浏览器对服务器发出HTTP request,然后由服务器返回最新的数据给客服端的浏览器。 这种传统的HTTP request 的模式带来很明显的缺点 – 浏览器需要不断的向服务器发出请求, 然而HTTP request 的header是非常长的,里面包含的数据可能只是一个很小
WebSocket实现前后端消息推送
环境jdk8 tomcat7 谷歌浏览器和火狐浏览器(浏览器得支持websocket) 本文用webSocket建立一个简单的聊天室,直接上代码。。。先准备一个普通的maven工程 springMVC框架后台代码:主要是建立拦截器拦截webSocket请求并交于handler进行处理。 webSocket配置如下: 1.MySocketConfig:注册拦截器+handlerimport or
RabbitMQ订阅发布的消息,通过WebSocket实现数据实时推送到前端
一、架构简单概述  RabbitMQ消息队列服务善于解决多系统、异构系统间的数据交换(消息通知/通讯)问题,并且可以订阅和发布,而随着HTML5诞生的WebSocket协议实现了浏览器与服务器的全双工通信,扩展了浏览器与服务端的通信功能,使服务端也能主动向客户端发送数据。  因此,我们可以使用RabbitMQ的订阅发布技术,订阅后,当RabbitMQ端有新的数据就直接发布到指定的queue,订
C/C++ 基于 websocket 的前台及后台实时推送
实现步骤如下: 1. 获取 GoEasy appkey. 在 goeasy 官网上注册一个账号,并新建一个 app. APP 创建好后系统会为该 app 自动生成两个 key, 一个既可以用来接收又可以用来推送 (supper key),另一个只可以用来接收(subscriber key). 2. 客户端订阅一个 channel. a. 在客户端引入 goeasy.js , js 地址:
WebSocket实现实时推送数据到前端
@Component @EnableWebSocket public class WebSocketConfig implements WebSocketConfigurer{ @Resource goodsWebSocketHandler handler; public void registerWebSocketHandlers(WebSocketHandler...
springBoot2.0整合webSocket 服务器主动推送数据到前端,并且弹框提示带有音乐提醒
springBoot2.0整合webSocket 服务器主动推送数据到前端,并且弹框提示带有音乐提醒
WebSocket 推送数据至前端接口实例
package com.xxxx.jcbigdata.websocket; import java.io.IOException; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.concurrent.CopyOnWriteArraySet; import javax.w...
web的实时推送技术--websocket
Python tornado websocket
.net websocket 消息推送
.net websocket 消息推送 该程序用vs2013编写的 主要看代码 别的版本都可仿照 适合初学者使用
学习jsSocket实现后台向前台发送实时消息
之前在做客户管理系统的时候,客户经常给我们提出实施通讯的需求。当时,我们讨论出的方案是客户端间隔时间发送请求,访问服务器的应用,如果状态改变,则弹出消息给用户显示。 今天,在隐心技术论坛上发现一片帖子,作者是高手,使用js+flex+java开发实施通信socket。 Js+Flex+Java模拟的JsSocket组件使用说明 说明:图片、附件都需要登陆才能查看和下载,若没有注册请先注册...
websocket实现后台给web端推送消息
websocket和socket的关系和区别 网络上的两个程序通过一个双向的通信连接实现数据的交换,这个连接的一端称为一个socket。     建立网络通信连接至少要一对端口号(socket)。socket本质是编程接口(API),对TCP/IP的封装,TCP/IP也要提供可供程序员 做网络开发所用的接口,这就是Socket编程接口;HTTP是轿车,提供了封装或者显示数据的具体形式;Socket...
redis+websocket 实现统计数据实时推送
刚刚进入这个公司是三年前,我也刚刚满打满算有了两年工作经验,开发时很少会考虑性能、安全这些方面的东西。那时候公司需要我做一个监控大屏,就是满是统计图表的一个页面,投影出来展示。刚刚接手的时候我觉得这个项目的难点有两个:图表插件和统计sql。经过一段时间的开发,项目基本完成,图表选择用的highchars,参照着demo里的数据格式传入数据并没有想象中的困难,sql也勉勉强强的写了出来了,但是性能一
消息队列:快速上手ActiveMQ消息队列的JMS方式使用(两种模式:Topic和Queue的消息推送和订阅)
1、实现功能希望使用一套API,实现两种模式下的消息发送和接收功能,方便业务程序调用1、发送Topic2、发送Queue3、接收Topic4、接收Queue2、接口设计根据功能设计公共调用接口/** * 数据分发接口(用于发送、接收消息队列数据) * * @author eguid * */ public interface MsgDistributeInterface { /**...
HTML5 WebSocket与消息推送
目录一、Socket简介 二、WebSocket简介与消息推送 三、WebSocket客户端 四、WebSocket服务器端 五、测试运行 六、小结与消息推送框架6.1、开源Java消息推送框架 Pushlet 6.2、开源DotNet消息推送框架SignalR七、代码下载7.1、Java实现的服务器端代码与客户端代码下载 7.2、DotNet服务器端手动连接实现代码下载 7.3、DotNet下使用
websocket定时推送
后端代码: public class WebSocketConfig implements WebSocketMessageBrokerConfigurer { public void registerStompEndpoints(StompEndpointRegistry registry) { registry.addEndpoint(&quot;/daoshu/socket&quot;)...
使用 Spring WebSocket 实现向用户推送消息的功能
1、websocket+spring http://tech.lede.com/2017/03/08/qa/websocket+spring/ 2、《Spring 5 官方文档》22. WebSocket Support http://ifeve.com/%E3%80%8Aspring-5-%E5%AE%98%E6%96%B9%E6%96%87%E6%A1%A3%E3%80%8B22-web...
Springboot+websocket+定时器实现消息推送
由于最近有个需求,产品即将到期(不同时间段到期)时给后台用户按角色推送,功能完成之后在此做个小结 1. 在启动类中添加注解@EnableScheduling import org.mybatis.spring.annotation.MapperScan; import org.springframework.boot.SpringApplication; import org.springf...
spring boot 集成websocket实现实时推送
websocket暂时能想到的应用是浏览器聊天和后台日志实时显示到前台。当后台启动程序后,等待前台连接,连接上之后,前后台就可以相互发送数据了。先贴上pom配置:<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</ar
文章热词 机器学习教程 Objective-C培训 交互设计视频教程 颜色模型 设计制作学习
相关热词 mysql关联查询两次本表 native底部 react extjs glyph 图标 深度学习结合大数据 数据库课程结合