今天给各位分享java使用activemq的知识,其中也会对进行解释,如果能碰巧解决你现在面临的问题,别忘了关注本站,现在开始吧!
本文目录一览:
1、用java代码如何设置activemq消息持久化到数据库中?2、JAVA利用ActiveMQ达到实时更新状态3、activemq和rabbitmq谁更适合java学习
用java代码如何设置activemq消息持久化到数据库中?
ActiveMQ持久化消息的二种方式;
1、持久化为文件
这个装ActiveMQ时默认就是这种,只要设置消息为持久化就可以了。涉及到的配置和代码有:
persistenceAdapter
kahaDB directory=”${activemq.base}/data/kahadb”/
/persistenceAdapter
producer.Send(request, MsgDeliveryMode.Persistent, level, TimeSpan.MinValue);
2、持久化为MySql
首先需要把MySql的驱动放到ActiveMQ的Lib目录下,我用的文件名字是:mysql-connector-java-5.0.4-bin.jar
接下来修改配置文件
persistenceAdapter
jdbcPersistenceAdapter dataDirectory=”${activemq.base}/data” dataSource=”#derby-ds”/
/persistenceAdapter
在配置文件中的broker节点外增加
bean id=”derby-ds” class=”org.apache.commons.dbcp.BasicDataSource” destroy-method=”close”
property name=”driverClassName” value=”com.mysql.jdbc.Driver”/
property name=”url” value=”jdbc:mysql://www.easyaq.com/activemq?relaxAutoCommit=true”/
property name=”username” value=”activemq”/
property name=”password” value=”activemq”/
property name=”maxActive” value=”200″/
property name=”poolPreparedStatements” value=”true”/
/bean
从配置中可以看出数据库的名称是activemq,需要手动在MySql中增加这个库。
然后重新启动消息队列,会发现多了3张表
1:activemq_acks
2:activemq_lock
3:activemq_msgs
JAVA利用ActiveMQ达到实时更新状态
我们以前这么做的. Socket 传和收数据. 我们是在struts的action里面 开启socket的 然后发送数据 等待返回的数据 然后在显示数据.
至于修改 那也一样的action处理数据 发送数据 等待接收数据.
在进行通信的时候 进制之间的转换 是很常见的 .
activemq和rabbitmq谁更适合java学习
activemq更贴切java,想学习Java推荐选择【达内教育】,该机构拥有行业内完善的教研团队,强大的师资力量,确保学员利益,全方位保障学员学习。
学习JAVA需要注意的地方:
1、刚学习的时候要注意看相关的入门的书。对于这类书要自己研读,也可以把书当作一个类库来查阅。
2、在看书的同时也要多看看网上相关的视频。主要看一位老师的视频,跟着老师的思路和顺序走。
3、在学习的过程中建立一个目标,让自己能够始终坚持不放弃。
4、学习的过程中会遇到很多的困难,会产生很多疑惑。不要急躁,不要放弃,想尽一切办法去解决。
5、不能只看理论不去动手实践。很多想不通的问题可以通过动手实践去解决。感兴趣的话点击此处,免费学习一下
想了解更多有关Java培训的相关信息,推荐咨询【达内教育】。秉承“名师出高徒、高徒拿高薪”的教学理念,是达内公司确保教学质量的重要环节。作为美国上市职业教育公司,诚信经营,拒绝虚假宣传是该机构集团的经营理念。该机构在学员报名之前完全公开所有授课讲师的授课安排及背景资料,并与学员签订《指定授课讲师承诺书》,确保学员利益。达内IT培训机构,试听名额限时抢购。
java使用activemq的介绍就聊到这里吧,感谢你花时间阅读本站内容,更多关于、java使用activemq的信息别忘了在本站进行查找喔。