`
文章列表
ActiveMQ in Action(5) 关键字: activemq 2.5 Clustering    ActiveMQ从多种不同的方面提供了集群的支持。2.5.1 Queue consumer clusters    ActiveMQ支持订阅同一个queue的consumers上的集群。如果一个consumer失效,那么所有未被确认(unacknowledged)的消息都会被发送到这个queue上其它的consumers。如果某个consumer的处理速度比其它consumers更快,那么这个consumer就会消费更多的消息。    需要注意的是,笔者发现AcitveMQ5.0版本的Q ...
ActiveMQ in Action(4) 关键字: activemq 2.4 Security    ActiveMQ支持可插拔的安全机制,用以在不同的provider之间切换。2.4.1 Simple Authentication Plugin    Simple Authentication Plugin适用于简单的认证需求,或者用于建立测试环境。它允许在XML配置文件中指定用户、用户组和密码等信息。以下是ActiveMQ配置的一个例子: Xml代码 <plugins>     ...      <simpleAuthenticationPlugin>  ...
ActiveMQ in Action(3) 关键字: activemq 2.3 Persistence2.3.1 AMQ Message Store    AMQ Message Store是ActiveMQ5.0缺省的持久化存储。Message commands被保存到transactional journal(由rolling data logs组成)。Messages被保存到data logs中,同时被reference store进行索引以提高存取速度。Date logs由一些单独的data log文件组成,缺省的文件大小是32M,如果某个消息的大小超过了data log文件的大小,那 ...
ActiveMQ in Action(2) 关键字: activemq 2.2 Transport    ActiveMQ目前支持的transport有:VM Transport、TCP Transport、SSL Transport、Peer Transport、UDP Transport、Multicast Transport、HTTP and HTTPS Transport、Failover Transport、Fanout Transport、Discovery Transport、ZeroConf Transport等。以下简单介绍其中的几种,更多请参考Apache官方文档。   2 ...
ActiveMQ in Action(1) 关键字: activemq 1 JMS    在介绍ActiveMQ之前,首先简要介绍一下JMS规范。1.1 JMS的基本构件1.1.1 连接工厂    连接工厂是客户用来创建连接的对象,例如ActiveMQ提供的ActiveMQConnectionFactory。 1.1.2 连接    JMS Connection封装了客户与JMS提供者之间的一个虚拟的连接。 1.1.3 会话    JMS Session是生产和消费消息的一个单线程上下文。会话用于创建消息生产者(producer)、消息消费者(consumer)和消息(message)等。会话 ...
为ActiveMQ服务器添加简单验证机制 关键字: Java, JMS ActiveMQ现在无疑成为JMS领域开源产品的龙头,基于开源框架的J2EE开发者大多用它来进行异步数据的传递工作。 比较搞的是截至ActiveMQ4.1.1版本的缺省配置仍然没有做任何的安全性配置,也就是说如果没有在软硬件防火墙层面上做限制的话,任何客户端都可以连接上JMS提供者发送和接收消息!估计大部分开发者用的都是缺省设置吧,呵呵。 当然,ActiveMQ的开发者还不至于弱智到这种程度,连最起码的权限验证都不支持。在org.apache.activemq.security包下面是提供了两种可选验证机制的:用户名/密码 ...
Sender:import java.io.BufferedReader;import java.io.InputStreamReader;import java.util.Hashtable;import javax.jms.Queue; import javax.jms.QueueConnection; import javax.jms.QueueConnectionFactory; import javax.jms.QueueSender; import javax.jms.QueueSession; import javax.jms.Session; import javax.jms.T ...
/***作者:andyao,email:andyaoy@gmail.com*http://andyao.iteye.com/blog/154092*/ ActiveMQ5.0实战一: 安装配置ActiveMQ5.0 ActiveMQ5.0实战三:使用Spring发送,消费topic和queue消息 简介 上一篇http://www.iteye.com/topic/15317介绍了ActiveMQ5.0的安装,这一篇将介绍的配置。ActiveMQ包含了很多features(详见http://activemq.apache.org/features.html ),   不同的需求,不同的环境,需要 ...
当应用中需要使用到上十张表时,DAO的维护变得日益困难,主要表现在这几个方面: 1)dao类的繁多,很多设计都是一个entity对应一个dao 2)dao接口需要维护的method庞大。 3)业务逻辑改变时,dao需要同时修改两个类文件(接口和实现类) 出于上述问题,有必要从新设计dao包。要求 1)减少dao类的数目,dao包暴露的接口稳定且易于扩展新的查询。 2)减少dao接口的method 3)可以动态增加dao提供的数据访问逻辑,比如增加相应的查询实现等等 我的分析: 可以使用Criteria,NamedQuery来构造复杂的查询逻辑。 对于改动最多的read/find逻辑,可以作一个抽 ...
Java SE 6 新特性: JMX 与系统管理 文档选项 <script type="text/javascript"></script> <noscript></noscript>
oracle10g下JDBC驱动包的区别 2008年06月27日 星期五 下午 03:55 这些是oracle10g下的驱动包的名称和它们的作用,其他版本的oracle基本类似。   支持所有平台的JDBC Thin驱动   classes12.jar (1,417,089 bytes) - JDK 1.2 和 JDK 1.3下使用      classes12_g.jar (1,794,418 bytes) - 和classes12.jar相同, 但是包中的类使用"javac -g"命令编译,包含调试信息.      classes12dms.jar (1,424, ...
ActiveMQ中的消息持久性     ActiveMQ很好的支持了消息的持久性(Persistence)。消息持久性对于可靠消息传递来说应该是一种比较好的方法,有了消息持久化,即使发送者和接受者不是同时在线或者消息中心在发送者发送消息后宕机了,在消息中心重新启动后仍然可以将消息发送出去,如果把这种持久化和ReliableMessaging结合起来应该是很好的保证了消息的可靠传送。       消息持久性的原理很简单,就是在发送者将消息发送出去后,消息中心首先将消息存储到本地数据文件、内存数据库或者远程数据库等,然后试图将消息发送给接收者,发送成功则将消息从存储中删除,失败则继续尝试。消息中 ...

jms P-T-P和Pub/Sub

    博客分类:
  • JMS
如前所述,JMS分两大类:PTP和Pub/Sub主要的几个对象:ConnectionFactory、Connection、Destination、Session、MessageProducer、MessageConsumer其相互关系如下图:1.PTP:简单回顾7个对象:QueueConnectionFactory、QuequeConnection、Queue、QueueSession、QueueSender、QueueReceiver、QueueBrowser    1) Sender    try {        //具体怎么得到就不写了,各个系统肯定都不一样,但终究都是通过jdni来获得 ...
Tomcat性能调优(2) 原文出处:http://www.lybbs.net/news_read.do?newsPath=2007/8/20/1187575202868.html Tomcat性能调优(2) http://www.lybbs.net 2007-08-20 10:00:02 CSDN 四. 自身调整   本节将向您详细介绍一些加速可使Tomcat实例加速运行的技巧和方法,无论是在什么操作系统或者何种Java虚拟机上。在有些情况下,您可能没有控制部署环境上的操作系统或者Java虚拟机。在这种情况下,您就需要逐行了解以下的的一些建议,然而你应该在修改后使之生效。我认为以下方法是Tom ...
Activemq实现JMS和异步调用 转载 关键字: jms activemq java 代码: Hello.java import java.io.Serializable;        /**Hello.java用来传递JAVA对象   * Author: cjp   * Date: 2005-11-8   * Time: 22:24:02   */    public class Hello implements Serializable {    private String id;    private Hello hello;    
Global site tag (gtag.js) - Google Analytics