SkyID
/
zheng
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

update

This commit is contained in:
shuzheng 2016-11-28 18:08:20 +08:00
parent d43f1d7f22
commit 75321645dd
3 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
cms/cms-mq/src/main/resources/applicationContext-activemq.xml
View File

@ -28,7 +28,7 @@
<property name="connectionFactory" ref="connectionFactory"/>
<property name="destination" ref="defaultQueueDestination"/>
<property name="messageListener" ref="defaultQueueMessageListener"/>
<property name="concurrency" value="4-10"/>
<!--<property name="concurrency" value="4-10"/>-->
</bean>
</beans>

3
cms/cms-web/src/main/java/com/zheng/cms/controller/ActiveMQController.java
View File

@ -35,7 +35,7 @@ public class ActiveMQController extends BaseController {
public Object send() {
long start = System.currentTimeMillis();
User user = null;
for (int i = 1; i <= 10000; i ++) {
for (int i = 1; i <= 1000; i ++) {
user = new User();
user.setUsername("用户" + i);
user.setPassword("123456");
@ -43,6 +43,7 @@ public class ActiveMQController extends BaseController {
user.setSex(1);
user.setCtime(System.currentTimeMillis());
user.setContent("用户描述");
// jmsQueueTemplate.convertAndSend(defaultQueueDestination, user);
JmsUtil.sendMessage(jmsQueueTemplate, defaultQueueDestination, JSONObject.fromObject(user).toString());
}
_log.info("发送消息消耗时间" + (System.currentTimeMillis() - start));

2
cms/cms-web/src/main/resources/applicationContext-activemq.xml
View File

@ -40,7 +40,7 @@
<property name="connectionFactory" ref="connectionFactory"/>
<property name="destination" ref="defaultQueueDestination"/>
<property name="messageListener" ref="defaultQueueMessageListener"/>
<property name="concurrency" value="4-10"/>
<!--<property name="concurrency" value="4-10"/>-->
</bean>
</beans>