spring整合RabbitMQ,启动项目后不自动接收消息,访问任意页面后才自动接收消息。

感觉很奇怪,队列里有消息,但是启动消费者程序后并没有获取到消息,
然后访问该项目的任意页面,就可以获取消息了。
基本上都是网上的常规配置,有遇到过的同学能帮忙解答的吗?小生不胜感激!
还请各路大神帮忙解答,没C币。。。不好意思,抱歉。。。

3个回答

如果能贴源码就可以知道问题了,不贴的化你可以看下我的demo https://github.com/airlove/spring-amqp-demo

原因是没有将DispatcherServlet设置为项目启动的时候就初始化,1

Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
Spring整合ActiveMQ接收消息
操作步骤 第一步:把Activemq相关的jar包,添加到工程中 第二步:创建一个MessageListener的实现类,负责监听 第三步:配置MessageListener监听器 第四步:初始化Spring容器,进行监听 添加jar包 <!-- activemq的jar包 --> <dependency> <groupId>org.apac...
rabbitmq发送&接收消息
发送端配置: rabbitmq-send-config.xml: <?xml version="1.0" encoding="UTF-8"?><beans xmlns="http://www.springframework.org/schema/beans"    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" ...
RabbitMQ消息的发送和接收C#
ch.ExchangeDeclare(exchange, exchangeType);//direct必须要routingKey //声明一个队列 ch.QueueDeclare("q", true, false, false, null); //将一个队列和一个路由绑定起来。并制定路由关键字 // ch.QueueBind("q", exchange, routingKey); ch.ExchangeDeclare("fanoutE", "fanout"); //声明一个队列 ch.QueueDeclare("fanoutQ", true, false, false, null); //将一个队列和一个路由绑定起来。并制定路由关键字 //ch.QueueBind("q", "fanoutE", routingKey); ch.QueueBind("fanoutQ", "fanoutE", "fanoutk");//fanout模式publish的时候不需要routingKey,只要绑定了的Q都能接收
RabbitMQ 发送接收消息过程
-
RabbitMQ(一)发送接收消息
首先下载并安装rabbitmq,与springboot整合: pom依赖: <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </...
线程不接收消息了!!!
我写了一个WIN32程序,程序只有一个窗口----对话框。但是在主线程调用DialogBox(...)函数弹出对话框后,在销毁这个对话框之前,该线程不能接收我发送给它的自定义消息。这是为什么?若想实现这个功能,应该怎么做?rnrn拜托!解决了马上给分。
微信企业号接收消息并自动响应
花了2天时间做了企业号接收消息功能测试,微信官方的文档给了我很大的帮助,但是恰恰卡时间最长的,也是官方文档上的一段有误导性的说明。带我细细道来 首先把微信发送信息到企业号服务器,然后企业号自动响应的过程图示下,网上找的,感觉描述的很好: 这里有几个地方很重要,在开发过程中不能搞错,不然会浪费很多测试时间: 1、消息的回调url就是每个应用模式选择中,回调模式里面设置的url。要使用一
请教网络消息自动接收方法
#define WM_SOCKA WM_USER+0x100rnBEGIN_MESSAGE_MAPrn VCL_MESSAGE_HANDLER(WM_SOCK,TMessage,OnRecv);rnEND_MESSAGE_MAP(TForm);rnWSAAsyncSelect(m_Socket,Handle,WM_SOCK,FD_READ|FD_CLOSE);rn我将客户端接收到的m_Socket消息在OnRecv()中接收,但是必须等到所有消息发送完后,OnRecv()才能接收到消息,而在发送消息过程中收到的消息也得等到所有消息发送后才能收到。rn怎样实现在发送消息的同时也能自动接收服务器的消息呢?rn要用线程吗?rn期待指教
微信公众平台开发【接收消息】接收普通消息
当普通微信用户向公众账号发消息时,微信服务器将POST消息的XML数据包到开发者填写的URL上。服务器在解析此数据包,获取相关参数的值从而做出回复。接收普通消息主要包括:文本消息、图片消息、语音消息、视频消息、小视频消息、地理位置消息、链接消息。XML数据包结构和相关参数如下: 1、文本消息 1348831860 1234567890123456 参数
接收消息与事件(关注/接收普通消息)
带你走进当下比较火爆的微信开发企业平台开发,畅享现有互联网的开发资源
窗体接收消息转成控制台接收消息。。。
窗体程序中,调用rnSetFileEndMsg(0,this.Handle, WM_FILE_END);rn可以在特定时间向本窗体this.Handle发送WM_FILE_END窗体消息rn然后重写窗体消息接收函数如下:rn[code=C#]rn /// rn /// 重写窗体接收信息rn /// rn /// rn protected override void WndProc(ref Message m)rn rn if (m.Msg == WM_FILE_END)rn //当播放完成(即合并完成的时候,会发送消息给窗体)rn OnMyCommand(m.WParam, m.LParam);rn rn base.WndProc(ref m);rn rnrn rn //接收到完成的信号时,调用rn public static void OnMyCommand(IntPtr wParam, IntPtr lParam)rn rn //---------------------------rn rn[/code]rn现在要将该窗体程序改为控制台,可是控制台并没有窗体。。也就不能用那个SetFileEndMsg来发送结束消息了~~rnhow can i do。。。rn
接收消息
相关网址:http://mp.weixin.qq.com/wiki/7/9f89d962eba4c5924ed95b513ba69d9b.html    1. 关注/取消关注事件     用户在关注与取消关注公众号时,微信会把这个事件推送到开发者填写的URL。方便开发者给用户下发欢迎消息或者做帐号的解绑。    ①微信服务器在五秒内收不到响应会断掉连接,并且重新发起请求,
ActiveMQ暂停接收消息与恢复接收消息
目录   ●问题起因 ●解决方案 ●测试结果 ●问题起因 使用ActiveMQ的过程中,有这么一个很常见的需求:如果我的消息消费者压力过大,接收消息来不及处理,我想暂停接收消息,先处理完已接收到的消息后,再恢复继续接收新的消息。 比较诡异的是,这样一个看似简单的功能,百度上居然没有一个适用的方案,大家不信的话可以搜索试试: 第一篇文章看似OK,但是点进去你会发现他的实现方式依旧...
消息的接收
从基础到项目的深入化讲解,手把手带你玩儿转微信公众平台nn开发基础准备、 开发模式接入、消息的接收与响应、n被关注回复与关键词回复、图文消息的发送与响应n、获取access_token、上传素材与图片消息回复n、自定义菜单实现、第三方API接口调用n天气查询项目实战
MPI接收任意源任意标志消息
在MPI中的MPI_Recv函数中:int MPI_Sendrecv(const void *sendbuf, int sendcount, MPI_Datatype sendtype, int dest, int sendtag, void *recvbuf, int recvcount, MPI_Datatype recvtype,
CreateThread后,线程是否能立即接收消息?
最近遇到一个问题:rnrn有一个工作线程,会创建一个新线程作为音频处理线程,然后再调用WaveInOpen、WaveInReset、WaveInStart等函数来操作录音设备。音频处理线程处理录音设备的MM_WIN_OPEN、MM_WIN_DATA等消息。rnrn程序执行顺序是先创建音频处理线程,然后再调用WaveInOpen函数。rn在某些情况下,WaveInOpen调用成功,但音频处理线程无法收到MM_WIM_OPEN消息。rnrn因此LZ怀疑在CreateThread返回之前,线程是否已经完成所有的初始化工作并可以立即接收消息。
Spring整合JMS、IBM MQ发送和接收消息
最近才接触到MQ,由于之前完全不知道是干嘛用的,还是很花了一点时间研究的~先来简单解释一下名词啦一、名词解释 MQMQ(message queue)指消息队列,是应用程序对应用程序的通信方法。可以利用消息队列暂存数据报文。 MQ的原理其实就是生产者-消费者模式。有关生产者-消费者模式的详细解释可以看这篇博文http://blog.csdn.net/yolanda_nuonuo/article/de
窗口隐藏后为何接收不到消息?
有一个基于对话框的程序,另一个程序使用sendmessage或者postmessage向它发送消息。rn如果用showwindow隐藏了对话框,它就接收不到消息;rn如果将其显示出来,它就立刻能够接收到了。rn为什么?
淘淘商城系列——ActiveMQ与Spring整合接收消息
我们测试接收消息时换个工程来测试,就用taotao-search-service工程,要用这个工程来接收ActiveMQ消息就要先添加对activemq-all的依赖,如下图所示。 下面我们新建一个接收ActiveMQ队列消息的监听器类,该类继承自MessageListener,如下图所示。 为方便大家复制,现把MyMessageListener类的代码贴出。/** * 接收Activ
用socket UDP发送接收消息怎么不自动停止
只要客户端向服务器发送一个消息,仅仅只是一个字符,那么服务器就一直不停的recvfrom不会停止,而且得到的都是乱码rn客户端:[code=C/C++]rnm_mainsocketUDP=::socket(AF_INET,SOCK_DGRAM,0);rn::WSAAsyncSelect(m_mainsocketUDP,m_hWnd,WM_SOCKET,FD_READ|FD_ACCEPT|FD_CLOSE);rn...///代码略过rn...rn...LRESULT CBabyDlg::OnSocket(WPARAM wParam, LPARAM lParam)rnrn CString gettext;rn CString cut;rn CString sqlchat;rn int npos;rn int len=sizeof(m_mainaddr);rn CTime time=CTime::GetCurrentTime();rn int hour=time.GetHour();rn int minute=time.GetMinute();rn int second=time.GetSecond();rnrn switch(LOWORD(lParam))rn case FD_READ:rn FlashWindow(TRUE);rn char szgettext[1024];rn if(wParam==m_mainsocketUDP)rn recvfrom(m_mainsocketUDP,szgettext,1024,0,(sockaddr*)&(m_mainaddr),&len);rn rn...rn...rn...////这些代码略过,。。。rnrnsendto(m_mainsocketUDP,"123",3,0,(sockaddr*)&m_mainaddr,sizeof(m_mainaddr));rn[/code]rnrn服务器端:[code=C/C++]rnm_sUDP=::socket(AF_INET,SOCK_DGRAM,0);rnsockaddr_in sinaddr;rn sinaddr.sin_family=AF_INET;rn sinaddr.sin_port=htons(66);rn sinaddr.sin_addr.S_un.S_addr=INADDR_ANY;rn CString x=inet_ntoa(sinaddr.sin_addr);rn if(::bind(m_sUDP,(LPSOCKADDR)&sinaddr,sizeof(sinaddr))==SOCKET_ERROR)rn MessageBox("关联C败。。。");rn rn::WSAAsyncSelect(m_sUDP,m_hWnd,WM_SOCKET,FD_READ|FD_ACCEPT|FD_CLOSE);rn...rn...rn...rnLRESULT CBabyDlg::OnSocket(WPARAM wParam, LPARAM lParam) rnrn int size=sizeof(m_laopoaddr);rn int npos;rn CString gettext;rn CString cut;rn CString sqlchat;rn CTime time=CTime::GetCurrentTime();rn int hour=time.GetHour();rn int minute=time.GetMinute();rn int second=time.GetSecond();rn switch (LOWORD(lParam))rn rn case FD_ACCEPT:rn m_laoposocket=::accept(m_s,(sockaddr*)&m_laopoaddr,&size);rn GetDlgItemText(IDC_EDIT1,gettext);rn gettext+="\r\n\t已连接上~~";rn SetDlgItemText(IDC_EDIT1,gettext);rn m_outedit.LineScroll(m_outedit.GetLineCount());rn shake();rn m_napaccept=1;rn m_bconectOK=TRUE;rn break;rn case FD_READ: ////这个一直出现,无限次。。。。rn FlashWindow(TRUE);rn char szgettext[1024];rn int len;rn if(wParam==m_sUDP)rn recvfrom(m_sUDP,szgettext,10,0,&m_UDPaddr,&len);rn rn else recv(m_laoposocket,szgettext,1024,0);rn[/code]
一个界面线程CreateThread后,什么时间才可以接收消息?
CMyThread 从CWinThread继承.rn然后:rnCMyThread * pThread=new CMyThread;rnpThread->m_bAutoDelete=true;rnpThread->CreateThread(); //创建线程rnpThread->PostThreadMessage(UD_MACFILTER_MONITOR_START,0,0);//发送一个自定义消息rnrn但实际上,该线程被创建后并不能马上就接收消息.所以有的时候可以工作,有的时候不能工作.rn我应该怎么做?rn
接收普通消息文本消息
“微信公众平台深度开发Java版 v2.0”系列课程共有6季,使用JAVA语言,系统讲解微信公众平台订阅号、服务号官方列出的全部功能接口,包括:自定义菜单、个性化菜单(按需定制菜单)、群发消息、客服消息(有限次消息推送)、模板消息接(无限次消息推送)、微信网页开发(微信WEB开发、微信游戏)、微信JSSDK开发、用户管理、获取用户基本信息、网页授权获取用户基本信息(通过WEB得到用户信息)、二维码(临时二维码、永久二维码)、事件推送、接收普通消息、被动回复用户消息,等知识点。 rn以及,针对微信公众号开发的服务端架构设计方案。课程以微信公众号开发视角,讲解JAVA开发微信公众号所需的框架、第三方工具。 rn购买套餐还赠送经典微信开发课程——[微信公众号_独立知识点]环境搭建。该课程针对各种复杂的网络环境,讲解如何构建开发环境,已解决“没有服务器”、“没有固定IP”等开发者遇到的窘境。 rn课程采用独立知识点讲解,一个知识点,一组课程,真正做到“简单、高效、”以短的时间、实现的学习。更多课程信息请访问CSDN。网址:http://edu.csdn.net/lecturer/631 rn“微信公众平台企业号开发Java版”陆续上线。rn详情 qq2326321088
服务端收到消息后丢给线程,在接收消息有延时
[code=c]rn case bMainMessage::MSG_WHILE_REQ:rn rn return subClientWhile(sClientObj->Socket, (tagWhileReq *)pvBuffer, dwLength);rn rn case bMainMessage::MSG_USER_REG_REQ:rn rn return subClientRegister(sClientObj->Socket, (bUserRegisertReq *)pvBuffer, dwLength);rn rn[/code]rnrn接收到MSG_USER_REG_REQ消息以后,里面直接AfxBeginThread(ThreadAccountOpt, (LPVOID)pUserAccountOpt, 0, 0, NULL);丢给了ThreadAccountOpt线程去处理rnrnrn而MSG_WHILE_REQ消息我模拟设定为客户端3秒发送1次,测试发现,在未接收到MSG_USER_REG_REQ时,每3秒都有数据正常,但是接收到MSG_USER_REG_REQ消息后,必须要等MSG_USER_REG_REQ消息里建立的线程ThreadAccountOpt结束以后 MSG_WHILE_REQ才能继续接收到消息(这里我直接打印日志看到的 所以不会有误)rnrn线程不是非阻塞的么,建立完线程就返回了,怎么线程不结束就接收不到MSG_WHILE_REQ消息呢rnrn注:线程里执行的是连接数据库操作。
SpringBoot整合Rabbitmq发送接收消息实战
SpringBoot整合Rabbitmq发送接收消息实战 另外,博主发起了SpringBoot整合Rabbitmq这一系列的gitchat交流会。刚兴趣的童鞋可以进入交流:https://gitbook.cn/gitchat/activity/5b90f9214fb1bd5c9acd4338 交流QQ:1974544863
RabbitMq学习(六)消息确认之接收确认
为什么需要接收确认 RabbitMQ默认会在消息被消费者接收后,立即确认。但存在丢失消息的可能,如果消费端消费逻辑抛出异常,也就是消费端没有处理成功这条消息,那么就相当于丢失了消息。 另外一种情况就是,我们在spring中处理消息时,即使消息处理没出异常,但是后续代码出异常造成回滚,这样其实也相当于丢失消息。 所以一般情况下,手动确认要比较好一些。 消息确认模式 AcknowledgeMode.N...
SpringBoot之RabbitMQ的消息发布与接收(Docker)
安装RabbitMQ 在Docker中直接使用pull命令拉取RabbitMQ镜像: docker pull rabbitmq:3-management 然后运行镜像: docker run -d -p 5672:5672 -p 15672:15672 --name rabbitmq01 image_id 测试:在浏览器访问,初始化账号密码都是guest SpringBoot中...
Spring 整合RabbitMQ消费者接收消息乱码问题
/ /问题代码 --接收到的消息中文经常乱码 public void handle(MessageExt message) { String msgContent = new String(message.getBody()); LOGGER.info("base info report JMS=====<<<<< msgContent:{}",...
Android接收RabbitMQ推送过来的消息
Android消息推送
RabbitMQ消息确认(发送确认,接收确认)
消息确认 每个 Consumer 可能需要一段时间才能处理完收到的数据。如果在这个过程中,Consumer 出错或异常退出,而数据还没有处理完成,那么这段数据就丢失了。因为我们采用 no-ack 的方式进行确认,也就是说,每次 Consumer 接到数据后,不管是否处理完成,RabbitMQ Server 会立即把这个 Message 标记为完成,然后从 Queue 中删除。 为了保证数据不被...
Android端接收RabbitMQ推送出来的消息
消息推送方式挺多的,这次用了下RabbitMQ这一款,下面简单介绍一下android端应该如何接受服务端那边发送的消息 import android.os.Bundle; import android.os.Handler; import android.os.Message; import android.support.v7.app.AppCompatActivity; import and
.Net下RabbitMQ的使用(2) -- 发送接收消息
在安装和配置完成RabbitMQ之后,我们就可以尝试做一个最简单的例子:发送和接收消息。   我们先来看客户端也就是发送者的代码: using RabbitMQ.Client; using System; using System.Collections.Generic; using System.IO; using System.Linq; using System.Text;...
RabbitMQ(四)消息确认(发送确认,接收确认)
前面几篇记录了收发消息的demo,今天记录下关于 消息确认方面的 问题. 下面是几个问题: 1.为什么要进行消息确认? 2.rabbitmq消息确认 机制是什么样的? 3.发送方如何确认消息发送成功?什么样才算发送成功? 4.消费方如何告知rabbitmq消息消费成功或失败? 5.使用spring的代码示例 1.为什么要进行消息确认? 经常会听到丢消息的字眼, 对于前面
SpringBoot整合RabbitMQ之发送接收消息实战
实战前言 前几篇文章中,我们介绍了SpringBoot整合RabbitMQ的配置以及实战了Spring的事件驱动模型,这两篇文章对于我们后续实战RabbitMQ其他知识要点将起到奠基的作用的。特别是Spring的事件驱动模型,当我们全篇实战完毕RabbitMQ并大概了解一下RabbitMQ相关组件的源码时,会发现其中的ApplicationEvent、ApplicationListener、...
使用RabbitMQ简单发送接收消息
参考:http://blog.csdn.net/lmj623565791/article/details/37607165            http://blog.csdn.net/anzhsoft/article/details/19563091            http://www.rabbitmq.com/tutorials/tutorial-one-java.htmlhttps...
RabbitMQ与Spring整合之消息生产方
RabbitMQ与Spring整合之消息生产方
RabbitMQ与Spring整合之消息消费方
RabbitMQ与Spring整合之消息消费方
SendMessage中带wParam参数后消息为何接收不到了
在我主线程的CMainFrame中有消息响应函数:rn afx_msg void OnStepArrive(WPARAM wParam,LPARAM lParam);rn定义的消息映射形式为:rn ON_MESSAGE(STEPDEBUGARRIVE, OnStepArrive)rn函数原型为:rnvoid CMainFrame::OnStepArrive(WPARAM wParam, LPARAM lParam)rnrn ....rnrn在另一个线程中,使用代码:rnAfxGetApp()->m_pMainWnd->PostMessage(STEPDEBUGARRIVE, 1);rn向主窗口发消息,可在CMainFrame::OnStepArrive中下断点却没有中断,即主窗口中没有接收到这个消息,而如果使用:rnAfxGetApp()->m_pMainWnd->PostMessage(STEPDEBUGARRIVE, 0);rn则可以中断,即接收到消息.rn将wParam设成其它值也收不到消息,whyrnrn
不的ListCtrl不接收创建消息的????
我派生一个ListCtrl类.rn我重载了三个函数和一个消息,设了断点,没有一个有起作用的.rnrnBOOL CMyListCtrl::PreCreateWindow(CREATESTRUCT& cs)rnrn return CListCtrl::PreCreateWindow(cs);rnrnrnBOOL CMyListCtrl::Create(DWORD dwStyle, const RECT& rect, CWnd* pParentWnd, UINT nID)rnrn return CListCtrl::Create(dwStyle, rect, pParentWnd, nID);rnrnrnint CMyListCtrl::OnCreate(LPCREATESTRUCT lpCreateStruct)rnrn if (CListCtrl::OnCreate(lpCreateStruct) == -1)rn return -1;rn return 0;rn
微信-接收消息(5)
注意:微信公众平台文档已经明确的说明当普通用户向公众号发送消息时,微信服务器将通过post方式把xml数据包发送到开发者设置的URL上。 以文本消息为例:xml结构如下 //开发者微信号 //发送方账号(微信提供的OpenId) 1348831860 //消息创建的时间(long型) //消息类型text //
即时通讯接收消息
接收到消息,应该怎么处理呢?rn怎么存放,我说的是多条消息同时到达的情况...rn
相关热词 c# 标准差 计算 c#siki第五季 c#入门推荐书 c# 解码海康数据流 c# xml的遍历循环 c# 取 查看源码没有的 c#解决高并发 委托 c#日期转化为字符串 c# 显示问号 c# 字典对象池