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个回答

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

Jennyleee
jennyleee 解决了吗朋友,我遇到同样的问题
大约一年之前 回复
wc936248
wc936248 发送消息的socket和接收消息的socket对象是同一个对象吗
一年多之前 回复
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
websocket推送
java版本的demo,可以直接导入运行 需要布署在tomcat7及以上的服务器
beego + websocket 向页面推送数据(二)
这篇文章我们要基于beego + websocket 向页面推送数据(一)把功能整合到beego项目中去。 一个新的beego项目长这样: router.go:package routersimport ( "WebSocketInBeego/controllers" "github.com/astaxie/beego" )func init() { beego.Ro
beego + websocket 向页面推送数据(一)
我已经用了3年的beego,虽然beego的版本在不断更新,但当别人谈论到它时,我越来越“冷静“,它对新手很友好,同时也发现了各种限制,尝试不同的框架还是好的。 Go语言的伟大之处在于:如果你也不是写网站出身,没有时间去学tomcat的配置,看到Java厚重的SSH框架书籍就脑袋疼,看到python群里各种2、3版本争论不休,Go可以在最短的时间内把自己的服务器搭起来,在最短的时间内把自己的工资提
dwr+spring实现后台向前台推送实例
本实例是在一些网络资料的基础上整合出来的一个:以后台向前台页面推送消息的一个完整实例工程,采用了spring、dwr反转,实现的是后台向前台不断推送消息,并管理相关用户退出;可以用在如定时任务的桌面消息提醒之类的场景。改变传统的前台定时刷新/请求后台的工作模式,真正意义上实现了后台向前台推送数据!本例子可以直接在eclipse里运行!
WebSocket协议接收ActiveMQ
WebSocket协议接收ActiveMQWebSocket协议接收ActiveMQWebSocket协议接收ActiveMQWebSocket协议接收ActiveMQ
给Web端Websocket推送
1、在pom中引入jar包         <dependency>             <groupId>org.springframework.boot</groupId>             <artifactId>spring-boot-starter-websocket</artifactId>            ...
websocket定时推送
后端代码: public class WebSocketConfig implements WebSocketMessageBrokerConfigurer { public void registerStompEndpoints(StompEndpointRegistry registry) { registry.addEndpoint("/daoshu/socket")...
android websocket 推送 长连接
android利用autobahn和服务器端websocket长连接以用来推送 经测试可以运行成功,实现服务器,android间相互通信
WebSocket 推送实例
WebSocket推送实例,在Oracle创建触发器使用utl_http通知WebSocket服务器推送消息到客户端,压缩包包含了WebSocket服务器的实现和Oracle触发器和utl_http的实现,和acl的创建
websocket日志实时推送
websocket日志实时推送,web网站,利用tail -f 和websocket实时推送到页面
Nginx + Websocket 实现推送
Nginx + Websocket 实现推送 , 实现思路 : http://blog.csdn.net/shangmingtao/article/details/76639821 . 代码可以直接线上运行.
websocket 实现推送业务
1.ningx配置 location ^~ /websocket { access_log /var/log/nginx/come-websocket.log; proxy_pass http://ip:port/websocket; proxy_set_header Host $host; proxy_set_header X-Real_IP $remote_addr...
websocket推送告警
功能:将采集到的告警利用websocket推送到前端 public class AlarmServiceImpl implements AlarmService { static{ startPushThread(); startCloseThread(); } // // public static void pushAllAlarm
WebSocket后台推送实现
本课程将核心讲解微框架Spring Boot,以深入浅出的方式,从入门到各配置的详细讲解,同时整合JDBC以及MyBatis等的使用,让学员能从碎片学习到整合应用。n课程主要采用Spring 4.x,Spring Boot 1.5.9,MyBatis 3.4.6等框架技术;
android websocket推送
tomcat7.47及以上版本实现websocket推送 包括 1、WebSocketServlet来实现 2、@ServerEndpoint实现 android与pc ie10等等推送 来知网络
activeMQ 推送之mqtt客户端
NULL 博文链接:https://hw1287789687.iteye.com/blog/2067736
activemq推送学习
1.activemq相关依赖 <dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-core</artifactId> <version>5.7.0</version> <exclusions>
websocket消息实时推送
做的一个简单的小案例,websocket实时推送消息,当执行一个操作后可以通知页面刷新
广播式的websocket 推送
WebSocket 为浏览器和服务器端提供异步通信的功能,即浏览器可以向服务器发送消息,服务器也可以向浏览器发送消息。WebSocket 需要浏览器的支持,如IE 10+、Chrome 13+、Firefox 6+。因为js插件对浏览器版本有要求。 Websocket 是通过一个socket来实现双工异步通讯的能力,开发时使用STOMP协议。 本事例基于springboot。 ...
websocket实时推送例子
demo基于spring框架来写的。 第一步:自己搭建一个springmvc项目,很简单,网上百度都有;pom文件添加以下: org.springframework spring-websocket 4.2.4.RELEASE org.springframework
websocket推送方式
@SendTo注解和SimpMessageingTemplate的区别1. SendTo 不通用,固定发送给指定的订阅者2.
抓取WebSocket推送的消息
介绍 很多直播或对数据及时性要求比较高的网站,使用了WebSocket。这种数据要怎么抓呢? 我们这里以socket.io为例,我们可以查看网站网页源代码看使用的H5的WebSocket还是socket.io等JS库。 这里以java语言为例说明。假定网站使用的是socket.io库来实现消息推送。我们如何通过java来获取服务端推送的信息呢? socket.io提供了java的客户端实现...
定时推送后台数据到前台websocket和sse实现
前言:本文的实现环境基于springboot2 1、websocket的实现 前端页面: &amp;lt;!DOCTYPE html&amp;gt; &amp;lt;html&amp;gt; &amp;lt;head lang=&quot;en&quot;&amp;gt;     &amp;lt;meta charset=&quot;UTF-8&quot; /&amp;gt;     &amp;lt;title&amp;gt;&amp;lt;/title&amp;gt; &amp;lt;/head&
WebSocket之基于Spring实现前台消息实时推送
目录 一、需求(前台消息实时推送) 二、前端代码 三、后台代码 1.如何获取HttpSession(可略过) 2.获取HttpSession 3.接收前端请求并发送数据 四、Websocket url 404错误 一、需求(前台消息实时推送) 后台管理员创建公告,前台实时更新 二、前端代码 $(function () { init(); //启动...
11、websocket结合springboot定时推送,实时监控JVM系统负载
websocket入门到项目实战系列课程,20节左右的课程,每节课有课堂笔记和源码,主要讲解其的概念、基础开发,项目实战,nginx集群部署;采用的是java语言,框架是spring和springBoot;课程讲解有单播广播的介绍和使用场景,服务端定时推送,spring针对websocket的握手拦截器、频道拦截器开发和应用;采用nginx负载均衡器,后端多节点集群部署的问题和解决方案;购买后加进技术问答群Q群699347262备注订单号后四位
webSocket前台实现
webSocket前台实现简单实现:&amp;lt;!DOCTYPE html&amp;gt; &amp;lt;html lang=&quot;en&quot;&amp;gt; &amp;lt;head&amp;gt; &amp;lt;meta charset=&quot;UTF-8&quot;&amp;gt; &amp;lt;title&amp;gt;Title&amp;lt;/title&amp;gt; &amp;lt;script type=&quot;application/
ActiveMQ与Spring的结合
activemq与spring 的结合案例,有三个案例,项目有点杂乱,不过相关配置以及代码是完全没问题的,项目中的jar由maven的pom.xml进行管理。
ActiveMQ 与Spring结合示例
NULL 博文链接:https://extrimlycold20070206121610.iteye.com/blog/510814
ActiveMQ结合Spring的使用
ActiveMQ结合Spring收发消息 直接使用ActiveMQ的方式需要重复写很多代码,且不利于管理,Spring 提供了一种更加简便的方式————Spring JMS ,通过它可以更加方便地使用ActiveMQ。 Maven 依赖 结合Spring使用ActiveMQ的依赖如下: &amp;lt;!-- Spring JMS --&amp;gt; &amp;lt;de...
ActiveMQ与mqtt.js的结合应用
项目结构Program.csusing System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks;using Apache.NMS; using Apache.NMS.ActiveMQ; using Apache.NMS.ActiveMQ.C
activeMQ 与 php的结合使用
1、首先需要安装stomp的php扩展,如下文件支持php5.6版本: 将该文件放入php的扩展库ext文件夹中。 2、在php.ini中加入扩展配置:extension=php_stomp.dll,然后重启服务。 3、activeMQ主要有两个操作,即生产端与消费端 生产端代码如下: <?php use Yii; use app\components\Curl;
ActiveMQ 之Spring结合实例
包括1、ActiveMQ java实例 2、ActiveMQ Spring结合实例 3、代码亲测,无问题。 4、资源分5分绝对值 注意:请先安装ActiveMQ 服务。
Activemq 结合Spring的常用配置
[size=large][b]需要配置的参数:[/[/b]size] [b]消息消费者的配置[/b] [b]一、connectionFactory:[/b] [code=&quot;java&quot;] [/code] 以上配置指明MQ服务所在的服务器。 [b]二、配置queue:[/b] [code=&quot;java&quot;] [/code] 服务器上有几个Q,这里就配置几个,p...
WebSocket 与 webrtc结合
用websocket发送信令消息,用WebRtc传输音视频消息。测试通过,对需要的人妖帮助
ActiveMQ平台搭建 python推送接收
activemq queue python 分布式
kafka和websocket实时数据推送
需求 ​ 已有Kafka服务,通过kafka服务数据(GPS)落地到本地磁盘(以文本文件存储)。现要根据echarts实现一个实时车辆的地图。 分析 前端实时展现:使用websocket技术,实现服务器端数据推送到前端展现 通过Java的kafka client端获取数据,并且通过websock推送到前端。 websocket 简介 ​ websocket是HTML5开始提供的一种在单位TCP...
Spring集成WebSocket实现推送
1、pom.xml &amp;lt;!-- WebSocket --&amp;gt; &amp;lt;dependency&amp;gt; &amp;lt;groupId&amp;gt;org.springframework&amp;lt;/groupId&amp;gt; &amp;lt;artifactId&amp;gt;spring-websocket&amp;lt;/artifactId&amp;gt; &amp;lt;version&amp;gt;${spring.version}&amp
聊天消息实时推送(springBoot,webSocket)
使用springBoot集成的webSocket实现实时消息推送(模仿聊天) java代码 package com.lsbj.biz.scoket; import org.apache.commons.lang3.StringUtils; import org.springframework.stereotype.Component; import javax.websocket.*; ...
使用websocket实现实时推送
1.Websocket概述       websocket是客户端和服务器端进行交互的简单协议,在websocket中,服务器和浏览器只需要进行一次握手,两者之间就可以建立持久的连接性,并可以进行双向的数据传送。 2.Websocket的使用 // 初始化websocket initWebsocket() { this.userInfo = Tools.get...
websocket 推送图像 Js显示
通过WebSocket实现服务器主动推送 图像数据通过Base64编码,定义为Json格式传输 前端收到Json数据后 将图像还原 代码有任何问题可以和我联系 liangji@csu.ac.cn 一起学习,此外也可以看我的博客 博客有更详细的介绍博客搜索qq_20038925即可
相关热词 c++和c#哪个就业率高 c# 批量动态创建控件 c# 模块和程序集的区别 c# gmap 截图 c# 验证码图片生成类 c# 再次尝试 连接失败 c#开发编写规范 c# 压缩图片好麻烦 c#计算数组中的平均值 c#获取路由参数