update

zheng-cms/zheng-cms-job/src/main/resources/log4j.properties

@@ -18,6 +18,6 @@ log4j.logger.druid.sql.Statement=warn,stdout
 log4j.logger.druid.sql.ResultSet=warn,stdout
 
 # MyBatis logging configuration
-log4j.logger.com.zheng.cms.dao.mapper=error
+log4j.logger.com.zheng.cms.dao.mapper=debug
 #log4j.logger.com.zheng.cms.dao.mapper.UserMapper=debug
 #log4j.logger.com.zheng.cms.dao.mapper.UserMapper.selectUser=debug

zheng-cms/zheng-cms-web/src/main/java/com/zheng/cms/web/jms/MessageListener.java

@@ -1,57 +0,0 @@
-package com.zheng.cms.web.jms;
-
-import com.zheng.cms.dao.model.User;
-import com.zheng.cms.service.UserService;
-import net.sf.json.JSONObject;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.jms.annotation.JmsListener;
-import org.springframework.jms.listener.adapter.MessageListenerAdapter;
-import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
-import org.springframework.stereotype.Component;
-
-import javax.jms.Message;
-import javax.jms.Session;
-import javax.jms.TextMessage;
-import java.text.SimpleDateFormat;
-import java.util.Date;
-
-/**
- * Created by ZhangShuzheng on 2016/12/8.
- */
-@Component
-public class MessageListener extends MessageListenerAdapter {
-
-	private static Logger _log = LoggerFactory.getLogger(defaultQueueMessageListener.class);
-
-	@Autowired
-	ThreadPoolTaskExecutor threadPoolTaskExecutor;
-
-	@Autowired
-	UserService userService;
-
-	@JmsListener(destination="defaultQueueDestination",concurrency="5-10")
-	public void processOrder(final Message message, Session session) {
-		// 使用线程池多线程处理
-		threadPoolTaskExecutor.execute(new Runnable() {
-			public void run() {
-				TextMessage textMessage = (TextMessage) message;
-				try {
-					String text = textMessage.getText();
-					JSONObject json = JSONObject.fromObject(text);
-					User user = (User) JSONObject.toBean(json, User.class);
-					if (user.getUsername().equals("1")) {
-						_log.info("消费开始时间：" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date(System.currentTimeMillis())));
-					}
-					if (user.getUsername().equals("1000")) {
-						_log.info("消费结束时间：" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date(System.currentTimeMillis())));
-					}
-					userService.getMapper().insertSelective(user);
-				} catch (Exception e) {
-					e.printStackTrace();
-				}
-			}
-		});
-	}
-}

zheng-cms/zheng-cms-web/src/main/resources/applicationContext-activemq.xml

@@ -41,17 +41,12 @@
 	</bean>
 
 	<!-- 消费者 -->
-	<!--<bean id="defaultQueueMessageListener" class="com.zheng.cms.web.jms.defaultQueueMessageListener"/>-->
-	<!--<bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">-->
-		<!--<property name="connectionFactory" ref="connectionFactory"/>-->
-		<!--<property name="destination" ref="defaultQueueDestination"/>-->
-		<!--<property name="messageListener" ref="defaultQueueMessageListener"/>-->
-		<!--&lt;!&ndash;<property name="concurrency" value="4-10"/>&ndash;&gt;-->
-	<!--</bean>-->
-
-	<bean id="jmsListenerContainerFactory" class="org.springframework.jms.config.DefaultJmsListenerContainerFactory">
+	<bean id="defaultQueueMessageListener" class="com.zheng.cms.web.jms.defaultQueueMessageListener"/>
+	<bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
 		<property name="connectionFactory" ref="connectionFactory"/>
+		<property name="destination" ref="defaultQueueDestination"/>
+		<property name="messageListener" ref="defaultQueueMessageListener"/>
+		<!--<property name="concurrency" value="4-10"/>-->
 	</bean>
-	<jms:annotation-driven/>
 
 </beans>

zheng-cms/zheng-cms-web/src/main/resources/log4j.properties

@@ -18,6 +18,6 @@ log4j.logger.druid.sql.Statement=warn,stdout
 log4j.logger.druid.sql.ResultSet=warn,stdout
 
 # MyBatis logging configuration
-log4j.logger.com.zheng.cms.dao.mapper=error
+log4j.logger.com.zheng.cms.dao.mapper=debug
 #log4j.logger.com.zheng.cms.dao.mapper.UserMapper=debug
 #log4j.logger.com.zheng.cms.dao.mapper.UserMapper.selectUser=debug