- 浏览: 62930 次
- 来自: ...
最新评论
-
humiao8:
could you give a small temple f ...
深入掌握JMS(三)MessageListener -
pengtyao:
学习了 谢谢
mysql linux命令
文章列表
在下面的例子中,首先创建两个Queue,发送者给一个Queue发送,接收者接收到消息之后给另一个Queue回复一个Message,然后再创建一个消费者来接受所回复的消息。
import javax.jms.Connection;
import javax.jms.JMSException;
import javax.jms.Message;
...
在下面的例子中,分别发送一个Persistent和nonpersistent的消息,然后关闭退出JMS。
import javax.jms.Connection;
import javax.jms.DeliveryMode;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.command.ActiveMQ ...
一个消息对象分为三部分:消息头(Headers),属性
(Properties)和消息体(Payload)。对于StreamMessage和
MapMessage,消息本身就有特定的结构,而对于TextMessage,ObjectMessage和BytesMessage是无结构的。一个
消息可以包含一些重要的数据 ...
与Queue不同的是,Topic实现的是发布/订阅模型,在下面的例子中,启动2个消费者共同监听一个Topic,然后循环给这个Topic中发送多个消息。
import javax.jms.Connection;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.MessageProducer;
import javax.jms.Session;
imp ...
Queue实现的是点到点模型,在下面的例子中,启动2个消费者共同监听一个Queue,然后循环给这个Queue中发送多个消息,我们依然采用ActiveMQ。
import javax.jms.Connection;
import javax.jms.DeliveryMode;
import javax.jms.JMSException;
import javax.jms.Mes ...
消息的消费者接收消息可以采用两种方式:
1、consumer.receive() 或 consumer.receive(int timeout);
2、注册一个MessageListener。
采用第一种方式,消息的接收者会一直等待下去,直到有消息到达,或者超时。后一种方式会注册一个监听器,当有消息到达的时候,会回调它的onMessage()方法。下面举例说明:
MessageConsumer comsumer = session.createConsumer(queue);
comsumer.setMessageListener(new MessageLi ...
前一讲简单的介绍了一下JMS的基本概念,
这一讲结合一个例子让大家深入理解前一讲的基本概念. 首先需要做的是选择一个JMS提供者, 如果在JavaEE环境中可以不用考虑这些.
我们选择ActiveMQ, 官方地址: http://activemq.apache.org/. 网上有很多介绍ActiveMQ的文档,
所以在这里就不介绍了.
按照上一讲的这个简图,
ConnectionFactory---->Connection--->Session--->Message
Destination + Session------------------ ...
1. JMS基本概念
JMS(Java Message Service) 即Java消息服务。它提供标准的产生、发送、接收消息的接口简化
企业
应用的开发。它支持两种消息通信模型:点到点(point-to-point)(P2P)模型和发布/订阅(Pub/Sub)模型。P2P 模 ...
安装oracle客户端
在oracle的客户端安装文件中,找到tnsnames.ora这个文件,添加一条信息,大体如下:
ora_db = --此名字,可以自由命名
(DESCRIPTION =
(ADDRESS = (PROTOCOL = TCP)(HOST = xp-PC)(PORT = 1521))
(CONNECT_DATA =
(SERVER = DEDICATED)
(SERVICE_NAME = orcl)
)
)
上面的这段信息中,HOST和SERVICE_NAME一定要改,HOST就是远 ...
信息处理的多层次要求导致了一种新的数据环境
——DB-DW
的中间层
ODS
(操作型数据存储)的出现。
ODS
是
“
面向主题的、集成的、当前或接近当前的、不断变化的
”
数据。通过统一规划,规范框架和数据,
ODS
可以实现操作型数据整合
和各个系统之间的数据交换
,能够提供实时的操作型报表
,减轻数据仓库的负担。建设
ODS
还可以为后期数据仓库建设
做好准备。
什么是
ODS?
ODS
全称为
Operational Data Store
,即操作型数据存储
,是“ ...
内容如下
关于Adobe Flex
关于Spring
为什么使用Flex和Spring
Flex和Spring的整合
关于Flex
Adobe Flex是一套创建富客户端应用(RIAs)的框架.Flex生成的swf文件可以直接运行在Flash
Player之中。相比较基于时间轴的Flash开发,Flex框架更适合那些用传统方式开发应用程序的开发人员。Flex应用可以使用Flex
builder来开发。这套IDE是基于Eclipse平台开发的。Action
Script3语言是用来访问数据和创建用户接口组件的。Flex框架也用到了一种XML语言叫做MXML,它 ...
非常好的jsf教程:
http://www.docin.com/p-53619816.html
第一步: 取消自动validationvalidation有一堆,什么xml、jsp、jsf、js等等,我们没有必要全部都去自动校验一下,只是需要的时候才会手工校验一下!
取消方法:windows–>perferences–>myeclipse–>validation除开Manual下面的复选框全 ...
启动mysql:
/usr/local/mysql/bin/mysqld_safe --user=root&
创建数据库用户,可以对该库进行所有操作
连接mysql:mysql -uroot -p123
创建用户:grant all on testdb.* to test@"%" identified by "123";
all是表示给予所有的权限,testdb是数据库名,test是一个用户名,"%"是可以访问的域名,"%"表示所有都可以访问,"123"是密码
第一章 安装
1. 采用源文件编译安装。源文件共两个,为:
subversion-1.6.1.tar.gz (subversion 源文件)
subversion-deps-1.6.1.tar.gz (subversion依赖文件)
注意文件版本必须一致,否则很容易产生各种奇怪的问题.
2. 上传以上两个文件到 ...