使用Apache ActiveMQ的JMS开发基础

去年是我尝试JMS的时候。 背后的想法和概念让我有些困惑,但是当我知道它的用途后,我很快就掌握了它。 在本文中,我将展示使用Apache ActiveMQ作为后端使用Java开发简单的生产者/消费者的基础。

让我们首先从概念开始,这是一个简单的JMS架构:

必须首先创建连接工厂才能连接到目标。 客户端(应用程序)必须创建一个连接实例并创建一个生产者类,以便它可以创建将发送到目的地的消息。 消息使用者类(外部应用程序)必须订阅目标,才能使用生产者产生的消息。

考虑一下这种情况(如果您紧急需要示例,请跳过此部分):您想开发一个问答应用程序,希望它对用户非常有效。 您不希望用户登录并登录网站来检查问题和答案,而是希望在遇到任何问题或找到新答案时尽快通知他们。 然后,您想到了放置桌面应用程序并放置通知栏的方式,这样,将通知用户,他们可以答复或检查新存储的数据。

显然,您不希望用户单击“刷新”只是为了检查新数据,您不允许这样做吗? 那对于使用它的任何人来说都是低效率的。 轮询怎么样? 使用goog方法,但这可能会分配过多的资源。 您想要的是每次将新数据推入数据库时​​向客户端创建一个自动拉取请求。 执行客户端推送的服务器。

像这样思考:将消息引发到数据库后,同一条消息将引发到消息目标(主题或队列)上,并将其发送给所有订阅目标的客户端。 :) 就像订阅时事通讯一样,您作为用户已订阅,并且每次发送时事通讯时,所有用户都将收到时事通讯电子邮件。

这只是JMS在您的开发方案中可以解决的众多可能性之一。 显然,使用此功能,您可以想象它有多有用。
那么,我如何显示一个小例子来说明如何做到这一点呢?,只需按照以下说明进行操作,然后自己检查一下即可:

首先,下载并设置ActiveMQ( http://activemq.apache.org/ )-“ Apache ActiveMQ ™是最流行,功能最强大的开源消息传递和集成模式服务器。 ” –根据其网站。 实际上,除了强大而开放的源代码之外,我不会争辩说,它是迄今为止我使用过的最轻便的消息传递服务器(我已经使用WeblogicMQ并尝试了JBossMQ)。

下载源代码后,将其放在您喜欢的目录中并运行activemq命令。 该文件位于<activemq root> / bin。

运行ActiveMQ之后,您现在应该可以访问MQ Admin Console网站。 在这里可以看到MQ的所有指标,包括使用者,主题,队列,消息等。默认情况下,它使用端口8161(http:// localhost:8161 /)。

如果您可以看到上面的站点,则意味着您已经成功启动了Apache ActiveMQ! 现在开始发展我们的客户。 在本文中,我将使用Eclipse开发代码,但是您可以使用自己喜欢的任何IDE。

打开Eclipse并创建一个新的Java项目。
获取并将activemq-all- <version> .jar文件导入您的项目。 请注意,这是重要的一步,因为我们将使用jar中的类来访问MQ管理服务。 培养生产者:–生产者将是发送实际消息的人。

制片人
开发消费者–消费者将是接收生产者创建的消息的人。

消费者
在此处下载完整项目。

请享用!

参考: JCG合作伙伴 Alvin Reyes 使用Apache ActiveMQ的JMS开发基础   在Alvin“ Jay” Reyes博客上 。


翻译自: https://www.javacodegeeks.com/2012/03/jms-development-fundamentals-using.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/373498.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

vijos p1460——拉力赛

描述 车展结束后&#xff0c;游乐园决定举办一次盛大的山道拉力赛&#xff0c;平平和韵韵自然也要来参加大赛。 赛场上共有n个连通的计时点&#xff0c;n-1条赛道&#xff08;构成了一棵树&#xff09;。每个计时点的高度都不相同&#xff08;父结点的高度必然大于子结点&#…

mysql acid_Mysql中ACID的原理

原子性 (Atomicity)原子性是指一个事务是一个不可分割的工作单位&#xff0c;其中的操作要么都做&#xff0c;要么都不做。隔离性 (Isolation)隔离性是指多个事务并发执行的时候&#xff0c;事务内部的操作与其他事务是隔离的&#xff0c;并发执行的各个事务之间不能互相干扰…

MongoDB 自动删除集合中过期的数据——TTL索引

简介 ​ TTL (Time To Live, 有生命周期的) 索引是特殊单字段索引&#xff0c;MongoDB可以用来在一定时间后自动从集合中删除文档的特殊索引。 这对于某些类型的数据非常好&#xff0c;例如机器生成的事件数据&#xff0c;日志和会话信息&#xff0c;这些信息只需要在数据库中…

PLSQL 经常自动断开失去连接的解决过程

问题背景&#xff1a; 情况是这样的&#xff0c;很多开发同事的PLSQL上班时间开着8个小时&#xff0c;有时候他们出去抽烟后或者中午吃完饭&#xff0c;回来在PLSQL上面执行就报错无响应&#xff0c;然后卡住了半天动弹不了&#xff0c;非得重新登录plsql才生效&#xff0c;我猜…

使用Cobertura,JUnit,HSQLDB,JPA涵盖您的测试

你好&#xff01;你好吗&#xff1f; 今天让我们谈谈一个非常有用的工具&#xff0c;名为“ Cobertura”。 该框架与我们在另一篇文章中看到的Emma框架具有相同的功能。 Cobertura和Emma之间的主要区别在于Cobertura显示带有图形的简历页面。 如果要查看有关该主题的其他主题…

fedora mysql gui_fedora8安装 mysql++失败!!装了一个晚上没搞定!!伤心阿!

fedora8安装 mysql失败&#xff01;&#xff01;装了一个晚上没搞定&#xff01;&#xff01;伤心阿&#xff01;发布时间:2008-02-24 05:15:27来源:红联作者:lygzx[rootF8 mysql-3.0.0]# ./configure --w/usr/lib/mysqlconfigure: error: unrecognized option: --w/usr/lib/my…

MongoDB 数组类型查询 —— $elemMatch 操作符

描述 $elemMatch 数组查询操作用于查询数组值中至少有一个能完全匹配所有的查询条件的文档。语法格式如下&#xff1a; { <field>: { $elemMatch: { <query1>, <query2>, ... } } }如果只有一个查询条件就没必要使用 $elemMatch。 限制 不能指定 $where 查…

MVC4 Action 方法的执行

1. ActionInvoker 的执行&#xff1a; 在MVC 中 包括Model绑定与验证在内的整个Action的执行是通过一个名为ActionInvoker的组件来完成的。 它同样具有 同步/异步两个版本。 分别实现了接口 IActionInvoker /IAsyncActionInvoker。 ASP.NET MVC 中真正用于Action方法同步和异步…

C# 基础知识总结

要学好C#&#xff0c;基础知识的重要性不言而喻&#xff0c;现将常用到的一些基础进行总结&#xff0c;总结如下&#xff1a; 01. 数据类型转换&#xff1a; 强制类型转换(Chart--> int): char crA; int i (int)(cr); 02. 委托/匿名函数/Lamda表达式&#xff1a; 委托是匿…

Java注释和真实世界的Spring示例

“注释”是编程语言定义的一种&#xff0c;用作“标记”。 可以将它们视为编程语言引擎可以理解的注释行。 它们不会直接影响程序的执行&#xff0c;但是会在需要时间接影响。 定义 注释使用interface关键字定义&#xff0c;并且与接口相似。 它具有定义类似于接口方法的属性。…

scrapy+mysql+pipeline+更新数据_python3+Scrapy爬虫实战(二)—— 使用pipeline数据保存到文本和数据库(mysql)...

前言保存本地存储Json数据配置setting保存数据库创建数据库创建表编写pipelines配置setting本文是对上篇文章所讲的代码进一步优化&#xff0c;回看可以点这里&#xff0c;代码就直接在上一篇代码中进行改造&#xff0c;没有的小伙伴可以在这里下载。前言Scrapy 提供了 pipelin…

NYOJ 44 子串和

子串和 时间限制&#xff1a;5000 ms | 内存限制&#xff1a;65535 KB难度&#xff1a;3描述 给定一整型数列{a1,a2...,an}&#xff0c;找出连续非空子串{ax,ax1,...,ay}&#xff0c;使得该子序列的和最大&#xff0c;其中&#xff0c;1<x<y<n。 输入 第一行是一个…

学习进度条

学习进度条 周次 学习时间 新编写代码行数 博客量&#xff08;篇&#xff09; 学到知识点 第一周 160 0 1 github的使用和认识软件工程这门课的价值。 第二周 160 130 3 复利的计算和Github的一些简单操作还有就是进行项目的开发分析&#xff0c;还有就是对…

ARM基础

1.  将32位a的【7&#xff1a;4】改成0101 -> a a&(~(0xF << 4)) | (0x5 << 4)&#xff1b; 2.  32位&#xff1a;单次处理数据32位。 3.  对于CPU而言&#xff0c;一切皆内存&#xff1b; 4.  DMA总线&#xff1a;不经过CPU直接在内存和内存间交换…

使用Jolokia和JMX进行客户端服务器监视

Java监视工具的选择非常广泛&#xff08;由Google提供的随机选择和顺序&#xff09;&#xff1a; javamelody 压力探头 JVisualVM 控制台 贾蒙 Java JMX Nagios插件不适用 此外&#xff0c;还有各种专用工具&#xff0c;例如ActiveMQ &#xff0c; JBoss &#xff0c; Qu…

图书管理系统数据字典_2. 结构化——数据字典

返回目录&#xff1a;Chilan Yuk&#xff1a;软件工程分析设计图库目录​zhuanlan.zhihu.com一、基本知识用于定义数据流和数据存储的结构&#xff0c;并给出构成所给的数据流和数据存储的各数据项的基本数据类型。数据字典中应该包括关于数据的如下信息一般信息&#xff08;名…

HDOJ 5184 Brackets 卡特兰数扩展

既求从点(0,0)仅仅能向上或者向右而且不穿越yx到达点(a,b)有多少总走法... 有公式: C(ab,min(a,b))-C(ab,min(a,b)-1) /// 折纸法证明卡特兰数: http://blog.sina.com.cn/s/blog_6917f47301010cno.html Brackets Time Limit: 2000/1000 MS (Java/Others) Memory Limit: 65…

010-python基础-数据类型-字符串操作

1、移除空白 1 username.strip() 2、分割 1 names "alex,jack,rain" 2 names_1 names.split(",") #  字符串分割之后变成列表 3 print(names_1) 4 #输出 5 [alex, jack, rain] 3、合并列表各元素成为字符串 1 names_1 [alex, jack, rain]2 names_2…

重复次数最多的 子串_每日算法系列【LeetCode 424】替换后的最长重复字符

题目描述给你一个仅由大写英文字母组成的字符串&#xff0c;你可以将任意位置上的字符替换成另外的字符&#xff0c;总共可最多替换 k 次。在执行上述操作后&#xff0c;找到包含重复字母的最长子串的长度。示例1输入&#xff1a; s "ABAB", k 2 输出&#xff1a; …

python基础(一)简单入门

一.第一个python程序 1.交互式编程 直接在命令行里面输入python即可进入python交互式命令行&#xff0c;linux下一样&#xff1a; 在 python 提示符中输入以下文本信息&#xff0c;然后按 Enter 键查看运行效果&#xff1a; 2.脚本式编程 把代码都写到文件里面&#xff0c;然后…