- 浏览: 1745667 次
- 性别:
- 来自: 北京
文章分类
- 全部博客 (723)
- IE 国际化 (1)
- java (310)
- python (52)
- Spring (101)
- eclipse (43)
- birt (10)
- exe4j (1)
- ActiveMQ (3)
- HornetQ (7)
- Ext (16)
- Linux (50)
- james (1)
- mail (3)
- 经验 (288)
- tomcat (5)
- Netty (3)
- ant (6)
- rsync (2)
- MD5 (3)
- 正则表达式 (3)
- 非技术 (59)
- mysql (28)
- sftp (1)
- Commons (2)
- oracle (3)
- vsftp (1)
- jdoc (1)
- socket (3)
- SEDA (2)
- UUID (1)
- quartz (7)
- javascript (50)
- sql (5)
- array (3)
- POI (3)
- redis (2)
- junit (4)
- 二维码 (1)
- jdk (8)
- h2 (6)
- maven (37)
- JVM (5)
- html (4)
- css (1)
- excel (4)
- myeclipse (2)
- scala (0)
- jQuery (5)
- log (10)
- slf4j (2)
- log4j (9)
- REST (15)
- guava (18)
- Joda-Time (7)
- ini4j (1)
- 配置文件 (2)
- lucene (1)
- database (3)
- curator (2)
- zookeeper (3)
- 并发 (2)
- jetty (6)
- ehcache (5)
- windows (1)
- protobuf (1)
- select2 (2)
- easyui (10)
- Freemarker (1)
- Filter (1)
- twisted (1)
- DateTime (11)
- mockrunner (1)
- DataSource (4)
- ajax (1)
- shell (18)
- powermockito (5)
- json (5)
- lombok (1)
- jointjs (1)
- cookie (1)
- mybatis (11)
- 加密解密 (2)
- 安全 (2)
- web (1)
- notepad++ (3)
- mac (48)
- sublime (14)
- git (7)
- docker (10)
- jar (1)
- gson (5)
- ubuntu (3)
- 模式 (1)
- neo4j (2)
- elasticsearch (1)
- OmniGranffle (1)
- ASCII (1)
- jdbc (3)
- kafka (1)
- MQ (1)
- chrome (3)
- 华为 (1)
- 路由器 (1)
- api (2)
- 架构 (1)
- 设计模式 (1)
- pip (4)
- springboot (48)
- 数据库 (4)
- thread (1)
- java.thread (1)
- sqlite (1)
- postman (1)
- springboot-actuator (2)
- jwt (1)
- token (1)
- brew (9)
- vim (1)
- virtualbox (1)
- Swagger (1)
- spring-retry (3)
- 调度 (1)
- item2 (5)
- graph (12)
- jgrapht (12)
- tuple (1)
- hadoop (5)
- curl (1)
- 算法 (3)
- Jekyll (1)
- github (1)
- ssh-keygen (1)
- zip (2)
- http (2)
- RestTemplate (8)
- 文件处理 (2)
- XStream (1)
- XML (3)
- JAXB (1)
- 笛卡尔积 (2)
- hive (1)
- 搜狗输入法 (1)
- 常用java类 (2)
- nginx (1)
- log4j2 (1)
- drawio (2)
- 安卓 (1)
- 小米 (1)
- okhttp (1)
- requests (1)
- 格式化 (2)
- MySQL Workbench (1)
- 分布式 (1)
- zip4j (1)
- hbase (5)
- hikari (1)
- javers (1)
- pydatetime (4)
- pyassert (1)
- pylog (2)
- tree (2)
- download (1)
- zeppelin (1)
- utils (2)
- wget (1)
- 鼠标 (1)
- 位运算 (2)
- open api (1)
- 域名 (1)
最新评论
-
youngcoder:
haohaohao~
Spring cache 注解功能不起作用的解决方案 -
kanpiaoxue:
lixz 写道有具体实例demo吗好多年前写的了。你还是去官网 ...
spring batch(一):基础部分 -
lixz:
有具体实例demo吗
spring batch(一):基础部分 -
BuDongOrz:
...
Spring MVC controller 读取配置文件 -
hvang1988:
理解错了,原来还是计数,不是时间
spring batch(二):核心部分(1):配置Spring batch
用HornetQ和Spring3做了一个简单的小例子,client发送指定的json串,经由HornetQ,由Server接收。
--------------------- client code -----------------------------------
spring 配置文件:
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:util="http://www.springframework.org/schema/util" xmlns:jee="http://www.springframework.org/schema/jee" xmlns:lang="http://www.springframework.org/schema/lang" xmlns:jms="http://www.springframework.org/schema/jms" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:context="http://www.springframework.org/schema/context" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.0.xsd http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-3.0.xsd http://www.springframework.org/schema/lang http://www.springframework.org/schema/lang/spring-lang-3.0.xsd http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms-3.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd"> <bean id="messageTopic" class="org.hornetq.api.jms.HornetQJMSClient" factory-method="createTopic"> <constructor-arg value="com.wanmei.bitask.input.initialize.topic" /> </bean> <bean id="transportConfiguration" class="org.hornetq.api.core.TransportConfiguration"> <constructor-arg value="org.hornetq.core.remoting.impl.netty.NettyConnectorFactory" /> <constructor-arg> <map key-type="java.lang.String" value-type="java.lang.Object"> <entry key="host" value="192.168.123.74"></entry> <entry key="port" value="5445"></entry> </map> </constructor-arg> </bean> <bean id="connectionFactory" class="org.hornetq.api.jms.HornetQJMSClient" factory-method="createConnectionFactoryWithoutHA"> <constructor-arg type="org.hornetq.api.jms.JMSFactoryType" value="CF" /> <constructor-arg ref="transportConfiguration" /> </bean> <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"> <property name="connectionFactory" ref="connectionFactory" /> <property name="pubSubDomain" value="true" /> </bean> <bean id="service" class="com.wanmei.service.impl.ServiceImpl"> <property name="jmsTemplate" ref="jmsTemplate" /> <property name="topic" ref="messageTopic" /> </bean> </beans>
java类的实现:
public class ServiceImpl implements Service { private static final Logger logger = Logger.getLogger(ServiceImpl.class); private JmsTemplate jmsTemplate; private Topic topic; /* * (non-Javadoc) * * @see com.wanmei.service.Service#sendMessage(java.util.List) */ @Override public boolean sendMessage(List<TaskMessage> messageList) { return sendTopic(messageList); } // ------------------ private method private boolean sendTopic(List<TaskMessage> messageList) { try { for (TaskMessage msg : messageList) { Gson gson = new Gson(); final String msgJson = gson.toJson(msg); logger.info("start to send topic to " + topic.getTopicName() + ", message : " + msgJson); jmsTemplate.send(topic, new MessageCreator() { @Override public Message createMessage(Session session) throws JMSException { TextMessage message = session .createTextMessage(msgJson); return message; } }); } return true; } catch (Exception e) { logger.error("Error: send topic failure:" + e.getMessage(), e); return false; } } // ------------------ setter / getter /** * @return the jmsTemplate */ public JmsTemplate getJmsTemplate() { return jmsTemplate; } /** * @param jmsTemplate * the jmsTemplate to set */ public void setJmsTemplate(JmsTemplate jmsTemplate) { this.jmsTemplate = jmsTemplate; } /** * @return the logger */ public static Logger getLogger() { return logger; } /** * @return the topic */ public Topic getTopic() { return topic; } /** * @param topic * the topic to set */ public void setTopic(Topic topic) { this.topic = topic; } }
--------------------- server code -----------------------------------
spring 配置文件:
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:util="http://www.springframework.org/schema/util" xmlns:jee="http://www.springframework.org/schema/jee" xmlns:lang="http://www.springframework.org/schema/lang" xmlns:jms="http://www.springframework.org/schema/jms" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:context="http://www.springframework.org/schema/context" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.0.xsd http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-3.0.xsd http://www.springframework.org/schema/lang http://www.springframework.org/schema/lang/spring-lang-3.0.xsd http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms-3.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd"> <bean id="messageTopic" class="org.hornetq.api.jms.HornetQJMSClient" factory-method="createTopic"> <constructor-arg value="com.wanmei.bitask.input.initialize.topic" /> </bean> <bean id="transportConfiguration" class="org.hornetq.api.core.TransportConfiguration"> <constructor-arg value="org.hornetq.core.remoting.impl.netty.NettyConnectorFactory" /> <constructor-arg> <map key-type="java.lang.String" value-type="java.lang.Object"> <entry key="host" value="192.168.123.74"></entry> <entry key="port" value="5445"></entry> </map> </constructor-arg> </bean> <bean id="connectionFactory" class="org.hornetq.api.jms.HornetQJMSClient" factory-method="createConnectionFactoryWithoutHA"> <constructor-arg type="org.hornetq.api.jms.JMSFactoryType" value="CF" /> <constructor-arg ref="transportConfiguration" /> </bean> <!-- this is the Message Driven POJO (MDP) --> <bean id="messageListener" class="com.wanmei.service.MessageListenerImpl"> <property name="jdbcTemplate" ref="bitaskJdbcTemplate" /> </bean> <!-- and this is the message listener container --> <bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer"> <property name="connectionFactory" ref="connectionFactory" /> <property name="destination" ref="messageTopic" /> <property name="messageListener" ref="messageListener" /> </bean> <!-- jdbc start --> <bean id="bitaskDataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"> <property name="driverClassName" value="oracle.jdbc.driver.OracleDriver" /> <property name="url" value="jdbc:oracle:thin:@192.168.182.129:1521:wmdw" /> <property name="username" value="bitask" /> <property name="password" value="bitask" /> <property name="validationQuery" value="select * from dual" /> </bean> <bean id="bitaskJdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"> <property name="dataSource" ref="bitaskDataSource" /> </bean> <bean id="transactionManager_jdbcTemplate" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="bitaskDataSource" /> </bean> <aop:config> <aop:advisor pointcut="execution(* com.wanmei.service.*Impl*.*(..))" advice-ref="txAdvice_jdbcTemplate" /> </aop:config> <tx:advice id="txAdvice_jdbcTemplate" transaction-manager="transactionManager_jdbcTemplate"> <tx:attributes> <tx:method name="change*" propagation="REQUIRED" /> <tx:method name="update*" propagation="REQUIRED" /> <tx:method name="merge*" propagation="REQUIRED" /> <tx:method name="get*" read-only="true" /> <tx:method name="save*" propagation="REQUIRED" /> <tx:method name="add*" propagation="REQUIRED" /> <tx:method name="delete*" propagation="REQUIRED" /> <tx:method name="remove*" propagation="REQUIRED" /> <tx:method name="hidden*" propagation="REQUIRED" /> </tx:attributes> </tx:advice> <!-- <bean id="lobHandler" class="org.springframework.jdbc.support.lob.DefaultLobHandler" lazy-init="true"/> --> <!-- jdbc end --> </beans>
java类的实现:
public class MessageListenerImpl implements MessageListener { private static Logger logger = Logger.getLogger(MessageListenerImpl.class); private JdbcTemplate jdbcTemplate; /* * (non-Javadoc) * * @see javax.jms.MessageListener#onMessage(javax.jms.Message) */ @Override public void onMessage(Message objMsg) { TextMessage msg = (TextMessage) objMsg; try { String json = msg.getText(); logger.info("receive message : " + json); doJson(json); } catch (JMSException e) { logger.error( "Error: receive message from topic failure: " + e.getMessage(), e); } } // ------------------ private method private void doJson(String json) { Gson gson = new Gson(); TaskMessage message = gson.fromJson(json, TaskMessage.class); if (checkValid(message)) { updateProcRun(message); } else { logger.error("Error: found null value in message."); } } private void updateProcRun(final TaskMessage msg) { StringBuilder builder = new StringBuilder(); builder.append(" update task_proc_run ") .append(" set task_status = ?, ").append(" reload = ?, ") .append(" ignore_type = ?, ").append(" initial_type = ?, ") .append(" last_modified = sysdate, ") .append(" exec_message = ? ") .append(" where proc_time = to_date(?,'yyyy-mm-dd') ") .append(" and proc_name = ? ") .append(" and data_source_name = ? "); int count = jdbcTemplate.update(builder.toString(), new PreparedStatementSetter() { @Override public void setValues(PreparedStatement ps) throws SQLException { ps.setInt(1, msg.getTaskStatus()); ps.setString(2, msg.getReload()); ps.setInt(3, msg.getIgnoreType()); ps.setInt(4, msg.getInitialType()); ps.setString(5, msg.getExecMessage()); ps.setString(6, msg.getProcTime()); ps.setString(7, msg.getProcName()); ps.setString(8, msg.getDataSourceName()); } }); if (1 == count) { logger.info("update task_proc_run successfully. " + msg); } else { logger.error("update task_proc_run failure: " + msg); } } private static boolean checkValid(TaskMessage msg) { if (isNull(msg.getProcName()) || isNull(msg.getProcTime()) || isNull(msg.getDataSourceName()) || isNull(msg.getIgnoreType()) || isNull(msg.getInitialType()) || isNull(msg.getTaskStatus()) || isNull(msg.getExecMessage()) || isNull(msg.getReload())) { logger.error("Error: some field is null. Please check args."); return false; } return true; } private static boolean isNull(Object obj) { return obj == null ? true : false; } // ------------------ setter / getter /** * @return the logger */ public static Logger getLogger() { return logger; } /** * @param logger * the logger to set */ public static void setLogger(Logger logger) { MessageListenerImpl.logger = logger; } /** * @return the jdbcTemplate */ public JdbcTemplate getJdbcTemplate() { return jdbcTemplate; } /** * @param jdbcTemplate * the jdbcTemplate to set */ public void setJdbcTemplate(JdbcTemplate jdbcTemplate) { this.jdbcTemplate = jdbcTemplate; } }
发表评论
-
swagger生成javaAPI的server&client代码
2021-03-25 11:05 859文章原文: 《Spring Boot: API ... -
springboot 返回JSON日期格式问题
2021-03-24 16:36 1068springboot返回的时间格式,根据版本的不同,可能返回 ... -
在其他项目中如何依赖一个springboot的jar?
2021-03-17 16:08 586资料:How to add a dependency ... -
Can we disable the default web server in the Spring Boot application?
2021-02-22 11:07 250The major strong point in S ... -
springboot的json的时间格式:时间戳
2020-07-07 17:52 1088springboot项目中javabean的字段 ... -
Spring RestTemplate处理请求的泛型的情况:ParameterizedTypeReference
2020-04-26 16:50 1961参考文章: https://stackoverflo ... -
spring-data-hbase的使用
2020-04-17 14:17 634maven的配置 <!-- hbase st ... -
本地搭建hbase的环境
2020-04-14 18:37 375最近要用到hbase,需要开发一个程序。总不能跑到线上环境 ... -
springboot的Hikari的数据源报错Failed to validate connection
2020-01-19 14:30 7015使用springboot的默认数据源 Hikari ... -
spring读取classpath下文件
2020-01-09 20:20 268开发过程中,必不可少的需要读取文件,对于打包方式的不 ... -
springboot的多module打包问题(repackage)
2019-12-25 17:28 1529我有个java的项目是maven管理的。mav ... -
Spring JdbcTemplate Querying Examples
2019-12-06 11:43 293Spring JdbcTemplate Queryin ... -
spring-jdbctemplate-streams
2019-11-06 16:19 0使用spring的jdbctemplate查询数据的时 ... -
springboot RestTemplate整合
2019-10-08 09:52 442import org.slf4j.Logger; ... -
Quartz计算下次运行时间
2019-08-09 10:50 1375处理Quartz自身可以计算下次执行时间,还可以通过s ... -
springboot上传文件报错:The field file exceeds its maximum permitted size
2019-07-30 15:37 856参考地址:https://blog.csdn.net/ ... -
java.lang.ClassCastException: java.util.LinkedHashMap cannot be cast to xxx.xxx
2019-05-24 14:49 4594使用Spring的RestTemplate访问RES ... -
springboot的logback和spring-data-hbase的log4j冲突解决方法
2019-04-15 19:51 1231springboot默认的日志框架是logback,它的性 ... -
获得spring上下文ApplicationContext
2019-04-12 14:15 1247在项目中实现 ApplicationContextAw ... -
Spring Boot Environment
2019-04-12 12:12 1414如何在springboot里面直接读取配置文件里面的内容呢? ...
相关推荐
教你一步一步掌握HornetQ,HornetQ是一个支持集群和多种协议,可嵌入、高性能的异步消息系统。HornetQ完全支持JMS,HornetQ不但支持JMS1.1 API同时也定义属于自己的消息API,这可以最大限度的提升HornetQ的性能和...
HornetQ 2.3.0 Alpha 发布,这不是一个简单的 Alpha 版本,同时也是一个大的发行版本。该版本对 2.2.0 进行了重构,引入一些原子故障迁移特性和大量企业特性改进。详细的新特性介绍请看发行说明。 HornetQ是一个...
HornetQ是JBoss社区所研发的开放源代码消息中间件;HornetQ是以Java 5 编写,因此只需要操作系统支持Java虚拟机,HornetQ便可运行。 支持Java消息服务 (JMS) 1.1 版本 集群 (Clustering) 支持庞大的消息(Message)...
Hornetq 实例
HornetQ2.1中文手册 HornetQ2.1中文手册
hermes 监听hornetq JMS配置
该文档是对Hornetq英文文档的翻译,对于英文不好的同学,有很大的帮助。
hornetq 2.4.0 一个轻量但高效的MQ
ActiveMQ和HornetQ性能对比
hornetq-2.2.5.Final.ziphornetq-2.2.5.Final.ziphornetq-2.2.5.Final.ziphornetq-2.2.5.Final.ziphornetq-2.2.5.Final.ziphornetq-2.2.5.Final.ziphornetq-2.2.5.Final.zip
能用该dll连HornetQ并上传或获取队列数据,引用dll,创建Factory ,创建连接,创建消费者,创建发布者,等等
HornetQ是java开源实现的消息系统框架,性能上比ActiveQ要好一些,被集成到JBoss的消息服务中。 Table of Contents Preface 1 Chapter 1: Getting Started with HornetQ 9 Chapter 2: Setting Up HornetQ 31 ...
hornetq-2.3.0.Final-bin.zip
hornetq安装包, hornetq-2.4.0.Final-bin.tar 消息中间件 供项目中数据交互使用
qMon 是一个简单的应用程序,用于通过 JMX 控制您的 HornetQ 队列和主题。安装和使用安装 、 和 安装和使用的凉亭包:$ npm install -g bower$ cd $ bower install 构建和运行$ mvn clean package$ java -Dqmon....
HornetQ2.1中文手册.7z
hornetq-transports-2.0.0.GA.jar
HornetQ集群配置,主主集群,通过udp广播形式通信。。
根据不同的需要, HornetQ可以单独运行,也可以运行于JEE应用服务器中。它还可以嵌入到你自己的应用程序中。 * 完美的可获得性。HornetQ提供自动客户端失效备援(automatic client failover)功能,能保证在...
hornetQ 2.4.0