jms activemq进行数据传输 接收返回值问题 5C

请教大家一个问题,用jms activemq 进行两个数据源间的数据传输。
发送端发送消息给接收端,接收端接收后需要进行存储。
现在发送端需要知道接收端存储成功。
发送端如何获取这个返回结果呢?这样是不是就成同步了?

Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
【JMS】JMS之ActiveMQ的使用
这篇文章主要是简单介绍一下JMS和ActiveMQ,以及使用ActiveMQ来写两个demo。1. JMS是啥百度百科的解释: JMS即Java消息服务(Java Message Service)应用程序接口,是一个Java平台中关于面向消息中间件(MOM)的API,用于在两个应用程序之间,或分布式系统中发送消息,进行异步通信。Java消息服务是一个与具体平台无关的API,绝大多数MOM提供商都
关于jMS activemq的问题
客户端 服务器端互传消息的时候 模式应该是下面的那种啊 ? rn --->是数据传送方向rn1.rn客户端---->客户端启动的ACTIVEMQ--------->服务器端启动的ACTIVEMQ----->服务器端rnrn服务器端---->服务器端启动的activemq---->客户端启动的activemq--->客户端rnrnrnrn2.rn客户端-------->服务器端启动的activemq----->服务器端rn服务器端---->客户端启动的activemq----->客户端rnrnrn(传到activemq 我指的是传到相应的broker 上)
JMS ActiveMQ
MQ简介、JMS基础、ActiveMQ基础应用、ActiveMQ高级特性
activemq jms
NULL 博文链接:https://xiaolng.iteye.com/blog/2265328
ActiveMq,JMS的问题,请教!
ActiveMq4.1和Spring2.0应用到Tomcat服务部署到Linux服务器,JMS的url为jmx:rmi:///jndi/rmi://localhost:1099/jmxrmirn启动Tomcat服务后一段时间内能够正常使用,然后报警告:rnWARN [org.apache.activemq.ActiveMQConnection] - rnjava.io.EOFExceptionrn at java.io.DataInputStream.readInt(DataInputStream.java:358)rn at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)rn at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:156)rn at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:136)rn at java.lang.Thread.run(Thread.java:595)rn再次使用的时候报错:rnERROR [org.jbpm.graph.def.GraphElement] - rnorg.springframework.jms.UncategorizedJmsException: Uncategorized exception occured during JMS processing; nested exception is org.apache.activemq.ConnectionFailedException: The JMS connection has failed: java.io.EOFException; nested exception is java.io.EOFExceptionrnCaused by: rnorg.apache.activemq.ConnectionFailedException: The JMS connection has failed: java.io.EOFExceptionrn at org.apache.activemq.ActiveMQConnection.checkClosedOrFailed(ActiveMQConnection.java:1234)rn at org.apache.activemq.ActiveMQConnection.createSession(ActiveMQConnection.java:275)rn at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)rn at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)rn at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)rn at java.lang.reflect.Method.invoke(Method.java:585)rn at org.springframework.jms.connection.SingleConnectionFactory$SharedConnectionInvocationHandler.invoke(SingleConnectionFactory.java:417)rn at $Proxy122.createSession(Unknown Source)rn……rn有人遇到过这种情况吗,问题可能出在哪里?
jms之ActiveMQ
ActiveMQ的原理及其应用详解,有详细的图解和说明。
JMS与ActiveMQ
 JMS是一种与厂商无关的 API,用来访问消息收发系统。它类似于 JDBC(Java Database Connectivity):这里,JDBC 是可以用来访问许多不同关系数据库的 API,而 JMS 则提供同样与厂商无关的访问方法,以访问消息收发服务。许多厂商目前都支持 JMS,包括 IBM 的 MQSeries、BEA的 Weblogic JMS service和 Progress 的 SonicMQ,这只是几个例子。 JMS 使您能够通过消息收发服务(有时称为消息中介程序或路由器)从一个 JMS 客户机向另一个 JMS客户机发送消息。消息是 JMS 中的一种类型对象,由两部分组成:报头和消息主体。报头由路由信息以及有关该消息的元数据组成。消息主体则携带着应用程序的数据或有效负载。根据有效负载的类型来划分,可以将消息分为几种类型,它们分别携带:简单文本 (TextMessage)、可序列化的对象 (ObjectMessage)、属性集合 (MapMessage)、字节流 (BytesMessage)、原始值流 (StreamMessage),还有无有效负载的消息 (Message)。
activemq使用JMS发送消息和接收消息
1.发送消息 package com.activemq; import javax.jms.Connection; import javax.jms.DeliveryMode; import javax.jms.Destination; import javax.jms.JMSException; import javax.jms.MessageProducer;
JMS 中间件:activeMQ, JMS 入门
JMS入门,使用activeMQ 发送,接收消息。首先,下载 apache-activemq-5.4.0。http://activemq.apache.org/download.html,解压,然后双击 bin/activemq.bat。把 activemq-all-5.3.0.jar 加入 classpath. 构建Sender.java 和Receiver.java : import ja...
【ActiveMQ】JMS中间件ActiveMQ详解
1.JMS介绍 Java Message Service(JMS)是SUN提出的旨在统一各种MOM(Message-Oriented Middleware )系统接口的规范,它包含点对点(Point to Point,PTP)和发布/订阅(Publish/Subscribe,pub/sub)两种消息模型,提供可靠消息传输、事务和消息过滤等机制。 简单的说,JMS制定了一个发消息的规范,是一个与具
ActiveMQ(二、 结合jms进行详细了解)
1、了解基本的同步异步的概念 同步:发送消息以后堵塞当前自身的进程  等待接收方的响应 得到响应之后继续向下运行异步:发送消息以后  不用等接收方的响应 发送和接受是独立的  jms 是异步通信   用于两个应用程序之间或者分布式系统之间发送消息 客户端获取消息时  不需要主动发送请求,消息会自动发送给可用的客户端  接受消息的也分异步和同步 (这就是为什么ActiveMQ分为同步异步的地方)  ...
activeMQ JMS 对象消息的问题
1.在消息生产端发送对象消息User user;在消费端接收消息是报错java.lang.ClassNotFoundException: com.bobo.activemq.User 提示找不到该对象。在消费端新建User对象也没用。应该怎么才能让消费端接收到对象数据。rnrn2.生产端发送消息1,2,3,4 消费端接收消息1,2,3,4。rn 这是关闭消费端连接,再次打开一个消息都接收不到。rn 再次在生产端发送消息5,6 消费端接收消息1,2,3,4,5,6。rn 怎么才能让消费端不重复接收。rnrn使用的pub/sub模式 发送消息持久化到数据库中,消费端持久订阅。
jms接收消息问题
使用queue发送objectMessage类型消息,第一次能正常发送和接收,第二次可以正常发送出去,但接收方收不到消息,因为第一次可以正常收发,所以发送和接收的代码应该没问题,只是不知道为什么第二次就是收不到这个消息?
jms的接收问题
weblogic做中间件,已配置好.rnMDB也部署到weblogic上了,没有错误,rn消息产生端也写好,经运行也没有错误,去weblogic那里看,也确实有消息了。rn但就是在接收端,总是正在接收消息,等了很久很久也没有要接收的消息出来,好象是陷入一个死循环似的,也不报错.rn分别用Topic和Queue测试,都为此结果.rn急刹小弟了,那位高手能否指点一二,高分送上.
activeMQ JMS WEB 例子
activeMQ JMS WEB 例子
Jms 之 ActiveMQ学习资料
ActiveMQ学习资料 linux下activemq安装
JMS事例,ActiveMQ服务器
java开发实现JMS通信机制 服务器为 ActiveMQ java开发实现JMS通信机制 服务器为 ActiveMQ java开发实现JMS通信机制 服务器为 ActiveMQ
activeMq jms需要的jar包
activeMq jms需要的jar包
JMS简介(ActiveMQ)
Java Messsage Service Java消息服务 为Java应用程序提供了完整的异步消息服务机制。 JMS源于企业应用对于消息中间件的需求,使应用程序可以通过消息进行异步处理而互不影响。Sun公司和它的合作伙伴设计的JMS API定义了一组公共的应用程序接口和相应语法,使得Java程序能够和其他消息组件进行通信。JMS有四个组成部分:JMS服务提供者、消息管理对象、消息的生产者消费者和消息本身。
使用jms 操作ActiveMQ
该用例使用jms 对Activemq进行基本操作,包含生产者和消费者。
消息中间件之JMS实践(ActiveMQ)
1、消息中间件作用     作为一个消息传递中间层,方便信息发送者和接受者通信。2、消息中间件好处    1、信息解耦:信息发送方和接收方通过中间件通信,不需要直接通信。    2、异步:消息被中间件处理,发送方和接收方都不用直接通信。    3、安全可靠:中间件做的还是很可靠地。。    4、横向扩展:支持多信息发送方和接收方    5、顺序保证:中间件功能。3、常见消息中间件    JMS(J...
JMS消息队列之ActiveMQ
最近学到消息队列JMS,所以写个博客记录一下。 环境这里我就不介绍了,我用的windows,并且安装了activemq的包,没有的可以自己去下载安装。然后修改包里的配置,目录在:D:\Softwares\apache-activemq-5.12.1\conf\activemq.xml,修改其中如下所示的代码:
JMS之——ActiveMQ消息持久化
之前的几篇博文中,我们实现的ActiveMQ消息未实现消息的持久化,一旦ActiveMQ服务重启则未发送的消息全部丢失,所以实现ActiveMQ消息的持久化也是很重要的。那么,这篇文章,我就带着大家一起来实现ActiveMQ消息的持久化。本博文主要是将ActiveMQ消息持久化到MySQL数据库。实现ActiveMQ消息的持久化主要是修改ActiveMQ conf目录下的activemq.xml文
jms的js源码(activemq)
jms在js中的实现,是activemq实现的jms
JMS实战——ActiveMQ
安装 官网下载地址:http://activemq.apache.org/ 小编这里以5.9.0版本为例,做简单介绍。 下载之后解压到制定路径,目录结构如下: 启动 直接运行bin下的activemq.bat,出现如下界面。 浏览器输入http://localhost:8161进行访问,这只是一个安装成功的页面。一般用admin访问,在地址后加/adm...
【消息中间件】Apache ActiveMQ + JMS
ActiveMQ是一种开源的,实现了JMS规范的,面向消息(MOM)的中间件; https://www.bilibili.com/video/av43526645?from=search&seid=12361186176438141280 MOM 面向消息中间件(Message-oriented middleware) 为了解决消息集中处理、集中转发; ActiveMQ是MOM的一个具体...
ActiveMq jms通信
Exception in thread "main" java.lang.NoClassDefFoundError: org/slf4j/LoggerFactoryrn at org.apache.activemq.ActiveMQPrefetchPolicy.(ActiveMQPrefetchPolicy.java:38)rn at org.apache.activemq.ActiveMQConnectionFactory.(ActiveMQConnectionFactory.java:88)rn at com.cattsoft.utility.jms_activemq.common.Globals.dealConfig(Globals.java:171)rn at com.cattsoft.utility.jms_activemq.common.Globals.readConfig(Globals.java:107)rn at com.cattsoft.utility.jms_activemq.common.Globals.(Globals.java:58)rn at com.cattsoft.utility.jms_activemq.common.Globals.get(Globals.java:234)rn at com.cattsoft.utility.jms_activemq.impl.DefaultJMSReceiver.init(DefaultJMSReceiver.java:122)rn at com.cattsoft.jms.Receiver.start(Receiver.java:39)rnrnrn从网上查的说是缺少jar包,但是他说的jar我都包含进去了,他还是报错,帮忙看看吧
JMS之ActiveMQ视频教程
此资源包括JMS之ActiveMQ视频教程+课程课件+课程代码,有意者请自取。
JMS与ActiveMQ的基本概念
JMS是什么 JMS是java的消息服务,JMS的客户端之间可以通过JMS服务进行异步的消息传输。 JMS的消息模型 1)点对点(P2P) 模型 2)发布/订阅模型 通讯模型图 4.两种模型的区别与特点 点对点模型(Queue): 1)每个消息只有一个消费者, 如果一条消息被消息者接收,消息就不存在于消息队列queue中了,那么其他的消费者接收不到这条消息。2)发送和接受
关于activeMQ,JMS。
今天老大让我研究activeMQ。我查了一下,是基于jms的实现。rn但是我从来没有写过jms的程序。所以不知学习activeMQ是不是要先学习jms。需要怎么入手呢?rn请赐教。
JMS之activemq的安装与使用
在上一篇《初识JMS》的博文中,小编已经带大家了解了JMS的基本情况,今天小编就和大家一起分享 在消息系统中比较常用的activemq这个传统的消息中间件: 一、基本介绍        简单来说,activemq就是一个消息的接收和转发的容器,用于消息推送;它是Apache公司出品的一个开源的消息队列软件,运行在jvm下,支持多种语言。        那么接下来小编就从基本的下载安装一点点的
JMS消息传送机制ActiveMQ
JMS(Java Message Service) 消息服务是一个面向消息中间件(MOM)的API,用于在两个应用程序之间,或者分布式系统中发送消息消费消息,进行异步通信,数据交互。JMS提供的API与具体厂商无关,抽象出接口提供给厂商去实现。类似于JDBC是可以用来访问许多不同关系数据库的 API.JMS 使您能够通过消息收发服务(有时称为消息中介程序或路由器)从一个 JMS 客户机向另一个
JMS中间件ActiveMQ介绍
Java Message Service(JMS)是SUN提出的旨在统一各种MOM(Message-Oriented Middleware )系统接口的规范,它包含点对点(Point to Point,PTP)和发布/订阅(Publish/Subscribe,pub/sub)两种消息模型,提供可靠消息传输、事务和消息过滤等机制
消息中间件(一)JMS与ActiveMQ
JMS基础参见:http://blog.csdn.net/zhangxs_3/article/category/625599 实践中存在的问题(引自《大型网站系统与Java中间件实践》第六章): 一、如何解决消息发送一致性 1.消息发送一致性定义 消息发送一致性是指产生消息的业务动作与发送消息的一致,也就是说,如果业务操作成功了,那么由这个操作产生的消息一定要发送出去,
JMS,ActiveMQ 之消息中间件
其实最初接触到消息的机制是在项目中,是个消息队列的概念,比如我给用户发券的时候也要给用户发送短信给手机推送消息,同步发送的话量大,耗时,不现实,而且我半夜发券,也不能半夜给用户发消息,所以我把信息先推到消息队列中(当时用的阿里云的),合适的时间再开始做这件事情。所以消息队列给我的印象是存储,异步,通信。下面我们来正式说。一:什么是消息队列?消息中间件?消息队列:用于两边传送信息的队列。消息中间件是...
消息中间件jms之activeMQ(2)
启动成功后 打开浏览器输入地址 http://ip地址:8161/ 即可进入ActiveMQ(默认的端口是8161)管理页面 点击上图位置默认用户名和密码都是admin 进入主界面 列表各列信息含义如下: Number Of Pending Messages :等待消费的消息 这个是当前未出队列的数量。 Number Of Consumers :消费者 这个是消费者端的消
JMS规范及ActiveMQ的使用
1. 初步认识消息中间件 1.1什么是消息中间件? 消息中间件是值利用高效可靠的消息传递机制进行平台无关的数据交流,并基于数据通信来进行分布式系统的集成。通过提供消息传递和消息排队模型,可以在分布式架构下扩展进程之间的通信。 1.2消息中间件能做什么? 消息中间件主要解决的就是分布式系统之间消息传递的问题,它能够屏蔽各种平台以及协议之间的特性,实现应用程序之间的协同。 1.3应用场景 ...
Jms与activeMQ的实现步骤
jms即Java Message Server(Java消息服务)在生活中就好像是顺风,申通,圆通一样,像是个快递机制,我们把快递交给快递员,快递员负责将你想要发的东西通过他自己的方式发送到目的地,jms有两种方式p2p,即点对点;和发布订阅两种方式消息生产者产生消息发送到消息队列,然后等待消费者来取走消息接下来是点对点的方式:1.创建连接工厂2.创建连接3.打开连接4.创建会话5.创建消息生产者...
JMS Apache ActiveMQ 安装包
Apache ActiveMQ JMS实现
基于ActiveMQ的jms通讯
简单的实现了jms的发送与接收,实现了异步通讯的功能 是一个与spring相结合的代码实例
相关热词 c# stream 复制 android c# c#监测窗口句柄 c# md5 引用 c# 判断tabtip 自己写个浏览器程序c# c# 字符串变成整数数组 c#语言编程写出一个方法 c# 转盘抽奖 c#选中treeview