- 浏览: 1591545 次
- 性别:
- 来自: 上海
最新评论
-
huihai:
有demo吗?
NamingStrategy实现动态表名映射 -
cangbaotu:
推荐给大家一些有用的爬虫源码:https://github.c ...
网络爬虫(源代码参考) -
tuspark:
除了.classpath文件以外,.project文件也应该了 ...
Eclipse .classpath文件浅谈 -
tuspark:
造成eclipse自动关闭的原因有很多,这里有很多介绍:ecl ...
eclipse 自动关闭 解决方案 -
DEMONU:
网上都是这些,这种文章。。。
ActiveMQ中的消息持久性
文章列表
Oracle是目前应用最广泛的数据库系统。一个完整的数据库系统包括系统硬件、操作系统、网络层、DBMS(数据库管理系统)、应用程序与数据,各部分之间是互相依赖的,对每个部分都必须进行合理的配置、设计和优化才能实现高性能的数据库系统。本文讨论笔者使用Oracle开发局域网中、小型数据库应用中,系统硬件的选择与使用、应用数据库系统设计与开发方面的一些心得和建议。应用数据库系统包含应用数据库和应用两方面的内容,应用数据库就是生产数据库,与系统数据库相对。 系统硬件的选择与使用 与数据库系统密切相关的硬件主要有CPU、内存、集群、存储设备等,这里不对集群进行讨论。 1、CPU CPU的数目和 ...
- 2008-10-17 23:47
- 浏览 1368
- 评论(0)
package askyaya.entity;import java.io.Serializable;import org.apache.commons.lang.builder.EqualsBuilder;import org.apache.commons.lang.builder.HashCodeBuilder;import org.apache.commons.lang.builder.ReflectionToStringBuilder;import org.apache.commons.lang.builder.ToStringBuilder;public class BaseEntit ...
最近一个项目要用到ActiveMq,并且需要最大程度的保证消息不丢失。以前对activeMq不是很熟悉,完全是摸着石头过河,目前基本配置都搞定了。只是对于它的自动重连一直找不到好的解决办法,我希望的效果是当一个broker(假设只有这一个,没有备用的)如果异常down掉的话,那么监听程序能够等待broker重启后再自动重新连接。看了它的文档似乎 设置一下failover:(tcp://localhost:61616) 就可以了
Failover Transport Failover Transport是一种重新连接的机制,它工作于其它transport的上层,用于建立可靠的传输。它的 ...
- 2008-09-18 14:39
- 浏览 23228
- 评论(4)
You can do the following to fix the issues:
1) Append max inactivity duration to your Uri in the format below: wireFormat.maxInactivityDuration=0
2) Use the same Uri at the client side as well as at the server side
Regards,如果不这样设置,对应的错误会出现:2008-05-07 09:22:56,343 [org.apache.activemq.ActiveMQConnec ...
- 2008-09-17 16:01
- 浏览 10688
- 评论(0)
是 String , StringBuffer 还是 StringBuilder ?
相信大家对 String 和 StringBuffer 的区别也已经很了解了,但是估计还是会有很多同志对这两个类的工作原理有些不清楚的地方,今天我在这里重新把这个概念给大家复习一下,顺 ...
- 2008-09-12 17:51
- 浏览 2075
- 评论(0)
在程序中,我们往往要把一个List(ArrayList or LinkedList)对应赋值给一个Array,这是可以用List提供的toArray()方法。但是要使用不好,就会有ClassCastExceptiony异常。看以下代码: List list = new ArrayList(); list.add(new Long(1)); list.add(new Long(2)); list.add(new Long(3)); list.add(new Long(4)); Long[] longArray = (Long[])list.toArray(); //抛出ja ...
- 2008-09-12 17:05
- 浏览 1483
- 评论(0)
StringTokenizer类的主要用途是将字符串以定界符为界,分析为一个个的token(可理解为单词),定界符可以自己指定。 构造器有下面三种形式: ·public StringTokenizer(String str,String delim,boolean returnTokens); ·public StringTokenizer(String str,String delim); ·public StringTokenizer(String str); 其中,str为需分析的字符串,delim为定界符,Tokens描述是否将定界符作为 ...
- 2008-09-12 16:58
- 浏览 1618
- 评论(0)
3.5 消息驱动的Bean 在前文讨论JMS消息接收处理逻辑的过程中,我们看到的代码仅仅适用于Servlet、JSP以及普通的Java应用程序,但不适用于EJB,因为在JMS的接收端使用EJB存在一些技术问题。一般地,JMS程序的交互模式分两种: ■ 发送-遗忘:JMS客户程序发出消息,但不需要应答。从性能的角度来看,这是最理想的处理模式,发送程序不需要等待对方响应请求,可以继续执行自己的任务。 ■ 同步请求-答复:JMS客户程序发出消息并等待答复。在JMS中,这种交互方式通过执行一个伪同步的接收方法(前文已经讨论)实现。然而,这里可能出现问题。如果EJB模块在一个事务上下文之内执行 ...
- 2008-09-11 14:18
- 浏览 3233
- 评论(0)
三、JMS P2P编程 在JMS P2P通信方式中,发送程序将消息放入一个队列,根据通信要求,发送程序可以要求一个应答信息(请求-应答模式),也可以不要求立即获得应答(发送-遗忘模式)。如果需要应答信息,发送程序通过消息头的JMSReplayTo域向消息的接收程序声明应答信息应当放入哪一个本地队列。 在请求-应答模式中,发送程序可以按照两种方式操作。一种称为伪同步方式,发送程序在等待应答消息时会被阻塞;另一种是异步方式,发送程序发送消息后不被阻塞,可以照常执行其他处理任务,它可以在以后适当的时机检查队列,查看有没有它希望得到的应答信息。下面的代码片断显示了JMS程序发送消息的过程。
...
- 2008-09-11 13:58
- 浏览 3779
- 评论(0)
一、JMS基本概念 1.1 P2P通信 1.2 Pub/Sub通信 二、JMS消息 三、JMS P2P编程 3.1 使用JMS QueueConnection对象 3.2 处理回退事件 3.3 关闭JMS对象 3.4 接收消息 3.5 消息驱动的Bean 3.6 消息持久化 3.7 消息选择器 四、JMS Pub/Sub编程 五、二阶段提交的事务 ━━━━━━━━━━━━━━━━━━━━━━━━━━ EJB 2.0和J2EE 1.3规范开始提供对Java消息服务(JMS)的支持。在J2EE 1.3加入JMS之前,J2EE环境中的组件通过RMI-IIOP协议 ...
- 2008-09-11 13:57
- 浏览 4723
- 评论(0)
目的地类型JNDI名字连接工厂类型Topic/Queuejava:/ConnectionFactoryJVMTopic/Queuejava:/XAConnectionFactoryJVM支持XA事务Topic/QueueRMIConnectionFactoryRMITopic/QueueRMIXAConnectionFactoryRMI支持XA事务Topic/QueueConnectionFactoryOILTopic/QueueXAConnectionFactoryOIL支持XA事务Topic/QueueUILConnectionFactoryUILTopic/QueueUILXAConnec ...
- 2008-09-10 18:55
- 浏览 2927
- 评论(0)
lib: jms1.1.jar activemq-all-5.0.jar 首先启动 activemq.bat或者执行以下代码启动一个broker
import org.apache.activemq.broker.BrokerService;
/**
* This example demonstrates how to run an embedded broker inside your Java code
*
* @version $Revision: 565003 $
*/
public final class EmbeddedBroker {
private Emb ...
- 2008-09-10 18:12
- 浏览 2489
- 评论(0)
import javax.jms.Connection;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageProducer;
import javax.jms.ObjectMessage;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnectionFactory;
imp ...
- 2008-09-10 13:55
- 浏览 18391
- 评论(4)
ActiveMQ in Action(7)
关键字: activemq
2.6.7 Wildcards Wildcards用来支持联合的名字分层体系(federated name hierarchies)。它不是JMS规范的一部分,而是ActiveMQ的扩展。ActiveMQ支持以下三种wildcards:
"." 用于作为路径上名字间的分 ...
- 2008-09-10 13:44
- 浏览 3953
- 评论(1)
ActiveMQ in Action(6)
关键字: activemq
2.6 Features ActiveMQ包含了很多功能强大的特性,下面简要介绍其中的几个。2.6.1 Exclusive Consumer Queue中的消息是按照顺序被分发到consumers的。然而,当你有多个consumers同时从相同的queue中提取消息时,你将失去这个保证。因为这些消息是被多个线程并发的处理。有的时候,保证消息按照顺序处理是很重要的。例如,你可能不希望在插入订单操作结束之前执行更新这个订单的操作。 ActiveMQ从4.x版本起开始支持Exclusive Consumer ( ...
- 2008-09-10 13:43
- 浏览 3740
- 评论(0)