rcoketmq集中管理

admin

2020-07-01 c54fb6a88876be994906d57d2d18e844686964d0

 fanli/src/main/java/com/yeshi/fanli/aspect/ActiveUserAspect.java

@@ -23,7 +23,6 @@
import com.aliyun.openservices.ons.api.Producer;

import com.yeshi.fanli.dto.mq.user.UserTopicTagEnum;

import com.yeshi.fanli.dto.mq.user.body.UserActiveMQMsg;

import com.yeshi.fanli.entity.bus.user.UserInfoExtra;

import com.yeshi.fanli.service.inter.user.UserInfoExtraService;

import com.yeshi.fanli.service.inter.user.UserInfoModifyRecordService;

import com.yeshi.fanli.service.inter.user.integral.IntegralGetService;

@@ -58,9 +57,6 @@


   @Resource

   private IntegralGetService integralGetService;

	
   @Resource(name = "producer")

   private Producer producer;

   



   private ExpressionParser parser = new SpelExpressionParser();

@@ -99,15 +95,17 @@
                     String key = "useractive-" + uidStr;

                     Jedis jedis = jedisPool.getResource();

                     try {

                        if (!StringUtil.isNullOrEmpty(jedis.set(key, "1", new SetParams().nx().ex(300)))) {

                        if (!StringUtil.isNullOrEmpty(jedis.set(key, "1", new SetParams().nx().ex(Constant.IS_TEST?10:300)))) {

                           try {

                              Long uid = Long.parseLong(uidStr);

                              if (!Constant.IS_TEST) { // 活跃通知

                                 UserActiveMQMsg msg = new UserActiveMQMsg(uid, new Date());

                                 Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.userActve, msg);

                                 producer.send(message);

                              }

//                              Long uid = Long.parseLong(uidStr);

//                              if (!Constant.IS_TEST) { // 活跃通知

//                                 UserActiveMQMsg msg = new UserActiveMQMsg(uid, new Date());

//                                 Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.userActve, msg);

//                                 message.setStartDeliverTime(System.currentTimeMillis()+1000*10L);//10s后发送活跃消息

//                                 producer.send(message);

//                              }

                           } catch (Exception e) {

										
                           }

                        }

                     } finally {