Skip to content

X
xyqb-user2
Commit d272bb74 authored by killer's avatar killer
Browse files
Options

销户

parent 58dbc884
Hide whitespace changes
Inline Side-by-side
Showing with 102 additions and 25 deletions
src/main/java/cn/quantgroup/xyqb/repository/IWeChatUserRepository.java
View file @ d272bb74
...@@ -12,7 +12,6 @@ import static org.springframework.transaction.annotation.Propagation.MANDATORY; ...@@ -12,7 +12,6 @@ import static org.springframework.transaction.annotation.Propagation.MANDATORY;
/** /**
* Created by 11 on 2017/1/18. * Created by 11 on 2017/1/18.
* modify by djh 20200527 http://confluence.quantgroup.cn/pages/viewpage.action?pageId=30657427 * modify by djh 20200527 http://confluence.quantgroup.cn/pages/viewpage.action?pageId=30657427
*
*/ */
public interface IWeChatUserRepository extends JpaRepository<WechatUserInfo, Long> { public interface IWeChatUserRepository extends JpaRepository<WechatUserInfo, Long> {
WechatUserInfo findByOpenIdAndAppName(String openId, String appName); WechatUserInfo findByOpenIdAndAppName(String openId, String appName);
...@@ -37,6 +36,17 @@ public interface IWeChatUserRepository extends JpaRepository<WechatUserInfo, Lon ...@@ -37,6 +36,17 @@ public interface IWeChatUserRepository extends JpaRepository<WechatUserInfo, Lon
@Query(value = "update wechat_userinfo set user_id=null,phone_no='*' where user_id=?1 and app_name=?2", nativeQuery = true) @Query(value = "update wechat_userinfo set user_id=null,phone_no='*' where user_id=?1 and app_name=?2", nativeQuery = true)
int dissociateByUserIdAndAppName(Long userId, String appName); int dissociateByUserIdAndAppName(Long userId, String appName);
/**
* 解除商城用户与小程序和公众号关联关系
*
* @param userId 用户id
* @return 结果
*/
@Transactional(rollbackFor = Exception.class)
@Modifying
@Query(value = "update wechat_userinfo set user_id=null,phone_no='*' where user_id=?1 and app_name in ('xyqb', 'wuxi')", nativeQuery = true)
int forbiddenXyqbAndWuxiUserByUserId(Long userId);
/** /**
* 关联用户 * 关联用户
* *
......
src/main/java/cn/quantgroup/xyqb/service/user/impl/UserServiceImpl.java
View file @ d272bb74
...@@ -549,6 +549,6 @@ public class UserServiceImpl implements IUserService, IBaseController { ...@@ -549,6 +549,6 @@ public class UserServiceImpl implements IUserService, IBaseController {
/* 清空缓存 */ /* 清空缓存 */
sessionService.deleteUserCatch(user); sessionService.deleteUserCatch(user);
/* 禁用微信 */ /* 禁用微信 */
wechatService.forbiddenUserWeChat(user.getId()); wechatService.forbiddenXyqbAndWuxiUserByUserId(user.getId());
} }
} }
src/main/java/cn/quantgroup/xyqb/service/wechat/IWechatService.java
View file @ d272bb74
...@@ -35,7 +35,16 @@ public interface IWechatService { ...@@ -35,7 +35,16 @@ public interface IWechatService {
* @return * @return
*/ */
WechatUserInfo queryByUserId(Long userId); WechatUserInfo queryByUserId(Long userId);
WechatUserInfo queryByUserId(Long userId,String appName);
WechatUserInfo queryByUserId(Long userId, String appName);
int forbiddenUserWeChat(Long userId); int forbiddenUserWeChat(Long userId);
/**
* 通过userId解除商城用户与小程序和公众号关联关系
*
* @param userId 用户id
* @return 禁用结果
*/
int forbiddenXyqbAndWuxiUserByUserId(Long userId);
} }
src/main/java/cn/quantgroup/xyqb/service/wechat/impl/WechatServiceImpl.java
View file @ d272bb74
...@@ -117,20 +117,20 @@ public class WechatServiceImpl implements IWechatService { ...@@ -117,20 +117,20 @@ public class WechatServiceImpl implements IWechatService {
@Override @Override
public WechatUserInfo findWechatUserInfoFromDb(String openId) { public WechatUserInfo findWechatUserInfoFromDb(String openId) {
return weChatUserRepository.findByOpenIdAndAppName(openId,"xyqb"); return weChatUserRepository.findByOpenIdAndAppName(openId, "xyqb");
} }
@Override @Override
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public WechatUserInfo saveWechatUserInfo(WechatUserInfo userInfo) { public WechatUserInfo saveWechatUserInfo(WechatUserInfo userInfo) {
log.info("微信信息保存开始：{}",JSON.toJSONString(userInfo)); log.info("微信信息保存开始：{}", JSON.toJSONString(userInfo));
if (Objects.isNull(userInfo) || Objects.isNull(userInfo.getOpenId())) { if (Objects.isNull(userInfo) || Objects.isNull(userInfo.getOpenId())) {
return null; return null;
} }
long count = weChatUserRepository.countByOpenIdAndAppName(userInfo.getOpenId(),"xyqb"); long count = weChatUserRepository.countByOpenIdAndAppName(userInfo.getOpenId(), "xyqb");
if (count > 0) { if (count > 0) {
//注意，这里会抛异常（5000/total）,WeChatController中已捕获处理 //注意，这里会抛异常（5000/total）,WeChatController中已捕获处理
return weChatUserRepository.findByOpenIdAndAppName(userInfo.getOpenId(),"xyqb"); return weChatUserRepository.findByOpenIdAndAppName(userInfo.getOpenId(), "xyqb");
} }
if (null == userInfo.getPhoneNo()) { if (null == userInfo.getPhoneNo()) {
userInfo.setPhoneNo(""); userInfo.setPhoneNo("");
...@@ -151,9 +151,9 @@ public class WechatServiceImpl implements IWechatService { ...@@ -151,9 +151,9 @@ public class WechatServiceImpl implements IWechatService {
userInfo = userInfo.convertEmoji(); userInfo = userInfo.convertEmoji();
WechatUserInfo wechatUserInfo = weChatUserRepository.save(userInfo); WechatUserInfo wechatUserInfo = weChatUserRepository.save(userInfo);
WechatEventMsg wechatEventMsg = WechatEventMsg.builder() WechatEventMsg wechatEventMsg = WechatEventMsg.builder()
.userId(wechatUserInfo.getUserId()) .userId(wechatUserInfo.getUserId())
.openId(wechatUserInfo.getOpenId()) .openId(wechatUserInfo.getOpenId())
.build(); .build();
applicationEventPublisher.publishEvent(new WechatBindEvent(this, wechatEventMsg)); applicationEventPublisher.publishEvent(new WechatBindEvent(this, wechatEventMsg));
return wechatUserInfo; return wechatUserInfo;
} }
...@@ -166,27 +166,27 @@ public class WechatServiceImpl implements IWechatService { ...@@ -166,27 +166,27 @@ public class WechatServiceImpl implements IWechatService {
return 0; return 0;
} }
// Old - 当前openId的WechatUserInfo // Old - 当前openId的WechatUserInfo
WechatUserInfo wechatUserInfo = weChatUserRepository.findByOpenIdAndAppName(openId,"xyqb"); WechatUserInfo wechatUserInfo = weChatUserRepository.findByOpenIdAndAppName(openId, "xyqb");
if (Objects.nonNull(wechatUserInfo) && Objects.equals(userId, wechatUserInfo.getUserId()) && Objects.equals(openId, wechatUserInfo.getOpenId())) { if (Objects.nonNull(wechatUserInfo) && Objects.equals(userId, wechatUserInfo.getUserId()) && Objects.equals(openId, wechatUserInfo.getOpenId())) {
log.info("微信关联成功：重复关联：跳过：[service]:userId:{},phoneNo:{},openId:{}", userId, phoneNo, openId); log.info("微信关联成功：重复关联：跳过：[service]:userId:{},phoneNo:{},openId:{}", userId, phoneNo, openId);
return 1; return 1;
} }
// 强制解除关联 // 强制解除关联
int dissociate = weChatUserRepository.dissociateUser(openId, userId,"xyqb"); int dissociate = weChatUserRepository.dissociateUser(openId, userId, "xyqb");
if (dissociate < 1) { if (dissociate < 1) {
log.error("微信关联失败：解绑条数<1：[service]:userId:{},phoneNo:{},openId:{}", userId, phoneNo, openId); log.error("微信关联失败：解绑条数<1：[service]:userId:{},phoneNo:{},openId:{}", userId, phoneNo, openId);
throw new WechatRelateUserException("微信关联失败"); throw new WechatRelateUserException("微信关联失败");
} }
int relate = weChatUserRepository.relateUser(userId, Optional.ofNullable(phoneNo).orElse(""), openId,"xyqb"); int relate = weChatUserRepository.relateUser(userId, Optional.ofNullable(phoneNo).orElse(""), openId, "xyqb");
if (relate < 1) { if (relate < 1) {
log.error("微信关联失败：绑定条数<1：[service]:userId:{},phoneNo:{},openId:{}", userId, phoneNo, openId); log.error("微信关联失败：绑定条数<1：[service]:userId:{},phoneNo:{},openId:{}", userId, phoneNo, openId);
throw new WechatRelateUserException("微信关联失败"); throw new WechatRelateUserException("微信关联失败");
} }
WechatEventMsg wechatEventMsg = WechatEventMsg.builder() WechatEventMsg wechatEventMsg = WechatEventMsg.builder()
.userId(userId) .userId(userId)
.openId(openId) .openId(openId)
.build(); .build();
applicationEventPublisher.publishEvent(new WechatBindEvent(this,wechatEventMsg)); applicationEventPublisher.publishEvent(new WechatBindEvent(this, wechatEventMsg));
// Todo : 如果当前openId已关联其他用户，则解绑成功后要注销其登录session -- 考虑后暂时不执行，影响太大 // Todo : 如果当前openId已关联其他用户，则解绑成功后要注销其登录session -- 考虑后暂时不执行，影响太大
log.info("微信关联成功：[service]:userId:{},phoneNo:{},openId:{},dissociate:{},relate:{},Old-WechatUserInfo:{}", userId, phoneNo, openId, dissociate, relate, wechatUserInfo); log.info("微信关联成功：[service]:userId:{},phoneNo:{},openId:{},dissociate:{},relate:{},Old-WechatUserInfo:{}", userId, phoneNo, openId, dissociate, relate, wechatUserInfo);
return relate; return relate;
...@@ -197,7 +197,7 @@ public class WechatServiceImpl implements IWechatService { ...@@ -197,7 +197,7 @@ public class WechatServiceImpl implements IWechatService {
if (!ValidationUtil.validatePhoneNo(phoneNo)) { if (!ValidationUtil.validatePhoneNo(phoneNo)) {
return null; return null;
} }
return weChatUserRepository.findByPhoneNoAndAppName(phoneNo,"xyqb"); return weChatUserRepository.findByPhoneNoAndAppName(phoneNo, "xyqb");
} }
private String getTokenFromWechatServer(String code) { private String getTokenFromWechatServer(String code) {
...@@ -222,30 +222,33 @@ public class WechatServiceImpl implements IWechatService { ...@@ -222,30 +222,33 @@ public class WechatServiceImpl implements IWechatService {
* @param userId - 用户标识 * @param userId - 用户标识
* @return * @return
* @TODO 2021-10-14 修改 findByUserIdAndAppName 为 findFirstByUserIdAndAppNameOrderByCreatedAtDesc, 原因是存在有多个数据情况 * @TODO 2021-10-14 修改 findByUserIdAndAppName 为 findFirstByUserIdAndAppNameOrderByCreatedAtDesc, 原因是存在有多个数据情况
*
*/ */
@Override @Override
public WechatUserInfo queryByUserId(Long userId) { public WechatUserInfo queryByUserId(Long userId) {
return weChatUserRepository.findFirstByUserIdAndAppNameOrderByCreatedAtDesc(userId,"xyqb"); return weChatUserRepository.findFirstByUserIdAndAppNameOrderByCreatedAtDesc(userId, "xyqb");
} }
/** /**
*
* @param userId * @param userId
* @param appName * @param appName
* @return * @return
* @TODO 2021-10-14 修改 findByUserIdAndAppName 为 findFirstByUserIdAndAppNameOrderByCreatedAtDesc, 原因是存在有多个数据情况 * @TODO 2021-10-14 修改 findByUserIdAndAppName 为 findFirstByUserIdAndAppNameOrderByCreatedAtDesc, 原因是存在有多个数据情况
*/ */
public WechatUserInfo queryByUserId(Long userId,String appName){ public WechatUserInfo queryByUserId(Long userId, String appName) {
if(appName==null||"".equals(appName.trim())){ if (appName == null || "".equals(appName.trim())) {
appName = "xyqb"; appName = "xyqb";
} }
return weChatUserRepository.findFirstByUserIdAndAppNameOrderByCreatedAtDesc(userId,appName); return weChatUserRepository.findFirstByUserIdAndAppNameOrderByCreatedAtDesc(userId, appName);
} }
@Override @Override
public int forbiddenUserWeChat(Long userId) { public int forbiddenUserWeChat(Long userId) {
return weChatUserRepository.dissociateByUserIdAndAppName(userId,"xyqb"); return weChatUserRepository.dissociateByUserIdAndAppName(userId, "xyqb");
}
@Override
public int forbiddenXyqbAndWuxiUserByUserId(Long userId) {
return weChatUserRepository.forbiddenXyqbAndWuxiUserByUserId(userId);
} }
} }
xyqb-user2.log
View file @ d272bb74
...@@ -123005,3 +123005,58 @@ Caused by: java.net.SocketTimeoutException: Read timed out ...@@ -123005,3 +123005,58 @@ Caused by: java.net.SocketTimeoutException: Read timed out
[2021-12-29 17:18:19.269][DEBUG][Apollo-RemoteConfigLongPollService-1|sun.net.www.protocol.http.HttpURLConnection|log] - sun.net.www.MessageHeader@bc8ebb15 pairs: {GET /notifications/v2?cluster=k8s&dataCenter=k8s&appId=xyqb-user2&ip=192.168.28.10&notifications=%5B%7B%22namespaceName%22%3A%22application%22%2C%22notificationId%22%3A14507%7D%2C%7B%22namespaceName%22%3A%22tech.common%22%2C%22notificationId%22%3A9472%7D%2C%7B%22namespaceName%22%3A%22cash.common%22%2C%22notificationId%22%3A2208%7D%2C%7B%22namespaceName%22%3A%22tech.sleuth%22%2C%22notificationId%22%3A7908%7D%2C%7B%22namespaceName%22%3A%22tech.service.urls%22%2C%22notificationId%22%3A12664%7D%2C%7B%22namespaceName%22%3A%22tech.acolyte%22%2C%22notificationId%22%3A3883%7D%2C%7B%22namespaceName%22%3A%22tech.msg.sdk%22%2C%22notificationId%22%3A12835%7D%5D HTTP/1.1: null}{User-Agent: Java/1.8.0_275}{Host: 192.168.4.117:15422}{Accept: text/html, image/gif, image/jpeg, *; q=.2, */*; q=.2}{Connection: keep-alive} [2021-12-29 17:18:19.269][DEBUG][Apollo-RemoteConfigLongPollService-1|sun.net.www.protocol.http.HttpURLConnection|log] - sun.net.www.MessageHeader@bc8ebb15 pairs: {GET /notifications/v2?cluster=k8s&dataCenter=k8s&appId=xyqb-user2&ip=192.168.28.10&notifications=%5B%7B%22namespaceName%22%3A%22application%22%2C%22notificationId%22%3A14507%7D%2C%7B%22namespaceName%22%3A%22tech.common%22%2C%22notificationId%22%3A9472%7D%2C%7B%22namespaceName%22%3A%22cash.common%22%2C%22notificationId%22%3A2208%7D%2C%7B%22namespaceName%22%3A%22tech.sleuth%22%2C%22notificationId%22%3A7908%7D%2C%7B%22namespaceName%22%3A%22tech.service.urls%22%2C%22notificationId%22%3A12664%7D%2C%7B%22namespaceName%22%3A%22tech.acolyte%22%2C%22notificationId%22%3A3883%7D%2C%7B%22namespaceName%22%3A%22tech.msg.sdk%22%2C%22notificationId%22%3A12835%7D%5D HTTP/1.1: null}{User-Agent: Java/1.8.0_275}{Host: 192.168.4.117:15422}{Accept: text/html, image/gif, image/jpeg, *; q=.2, */*; q=.2}{Connection: keep-alive}
[2021-12-29 17:18:29.237][DEBUG][kafka-producer-network-thread | producer-2|org.apache.kafka.clients.NetworkClient|debug] - [Producer clientId=producer-2] Sending metadata request (type=MetadataRequest, topics=) to node 192.168.4.100:15091 (id: 1 rack: null) [2021-12-29 17:18:29.237][DEBUG][kafka-producer-network-thread | producer-2|org.apache.kafka.clients.NetworkClient|debug] - [Producer clientId=producer-2] Sending metadata request (type=MetadataRequest, topics=) to node 192.168.4.100:15091 (id: 1 rack: null)
[2021-12-29 17:18:29.257][DEBUG][kafka-producer-network-thread | producer-2|org.apache.kafka.clients.Metadata|update] - Updated cluster metadata version 8 to Cluster(id = Xir2hMAUR-u-Jqcr8WkIgw, nodes = [192.168.4.100:15091 (id: 1 rack: null), 192.168.4.100:15093 (id: 3 rack: null), 192.168.4.100:15092 (id: 2 rack: null)], partitions = []) [2021-12-29 17:18:29.257][DEBUG][kafka-producer-network-thread | producer-2|org.apache.kafka.clients.Metadata|update] - Updated cluster metadata version 8 to Cluster(id = Xir2hMAUR-u-Jqcr8WkIgw, nodes = [192.168.4.100:15091 (id: 1 rack: null), 192.168.4.100:15093 (id: 3 rack: null), 192.168.4.100:15092 (id: 2 rack: null)], partitions = [])
[2021-12-29 17:18:48.524][INFO][SIGINT handler|cn.quantgroup.tech.shutdown.DefaultSignalHandler|handle] - 开始执行停止服务
[2021-12-29 17:18:48.530][INFO][SIGINT handler|cn.quantgroup.tech.shutdown.DefaultSignalHandler|handle] - undertowShutdown 停止接收请求
[2021-12-29 17:18:48.530][INFO][SIGINT handler|cn.quantgroup.tech.shutdown.DefaultSignalHandler|handle] - 即将执行 @PreDestroy 方法
[2021-12-29 17:18:48.530][INFO][Thread-37|org.springframework.boot.context.embedded.AnnotationConfigEmbeddedWebApplicationContext|doClose] - Closing org.springframework.boot.context.embedded.AnnotationConfigEmbeddedWebApplicationContext@655ef322: startup date [Wed Dec 29 16:52:15 CST 2021]; parent: org.springframework.context.annotation.AnnotationConfigApplicationContext@cad498c
[2021-12-29 17:18:48.534][INFO][Thread-37|org.springframework.context.support.DefaultLifecycleProcessor|stop] - Stopping beans in phase 2147483647
[2021-12-29 17:18:48.534][INFO][Thread-37|org.springframework.context.support.DefaultLifecycleProcessor|stop] - Stopping beans in phase 0
[2021-12-29 17:18:48.534][DEBUG][Thread-37|org.springframework.context.support.DefaultLifecycleProcessor|doStop] - Asking bean 'endpointMBeanExporter' of type [class org.springframework.boot.actuate.endpoint.jmx.EndpointMBeanExporter] to stop
[2021-12-29 17:18:48.535][DEBUG][Thread-37|org.springframework.context.support.DefaultLifecycleProcessor|run] - Bean 'endpointMBeanExporter' completed its stop procedure
[2021-12-29 17:18:48.535][DEBUG][Thread-37|org.springframework.context.support.DefaultLifecycleProcessor|doStop] - Asking bean '_org.springframework.integration.errorLogger' of type [class org.springframework.integration.config.ConsumerEndpointFactoryBean] to stop
[2021-12-29 17:18:48.535][INFO][Thread-37|org.springframework.integration.endpoint.EventDrivenConsumer|logComponentSubscriptionEvent] - Removing {logging-channel-adapter:_org.springframework.integration.errorLogger} as a subscriber to the 'errorChannel' channel
[2021-12-29 17:18:48.535][INFO][Thread-37|org.springframework.integration.channel.PublishSubscribeChannel|adjustCounterIfNecessary] - Channel 'xyqb-user2:8099.errorChannel' has 0 subscriber(s).
[2021-12-29 17:18:48.535][DEBUG][Thread-37|org.springframework.context.support.DefaultLifecycleProcessor|run] - Bean '_org.springframework.integration.errorLogger' completed its stop procedure
[2021-12-29 17:18:48.535][INFO][Thread-37|org.springframework.integration.endpoint.EventDrivenConsumer|stop] - stopped _org.springframework.integration.errorLogger
[2021-12-29 17:18:48.536][INFO][Thread-37|org.springframework.boot.actuate.endpoint.jmx.EndpointMBeanExporter|destroy] - Unregistering JMX-exposed beans on shutdown
[2021-12-29 17:18:48.536][INFO][Thread-37|org.springframework.boot.actuate.endpoint.jmx.EndpointMBeanExporter|unregisterBeans] - Unregistering JMX-exposed beans
[2021-12-29 17:18:48.536][INFO][Thread-37|org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler|shutdown] - Shutting down ExecutorService 'taskScheduler'
[2021-12-29 17:18:48.536][INFO][Thread-37|org.springframework.jmx.export.annotation.AnnotationMBeanExporter|destroy] - Unregistering JMX-exposed beans on shutdown
[2021-12-29 17:18:48.536][INFO][Thread-37|org.springframework.jmx.export.annotation.AnnotationMBeanExporter|unregisterBeans] - Unregistering JMX-exposed beans
[2021-12-29 17:18:48.537][DEBUG][Thread-37|org.apache.http.impl.conn.PoolingHttpClientConnectionManager|shutdown] - Connection manager is shutting down
[2021-12-29 17:18:48.537][DEBUG][Thread-37|org.apache.http.impl.conn.PoolingHttpClientConnectionManager|shutdown] - Connection manager shut down
[2021-12-29 17:18:48.538][INFO][Thread-37|org.apache.kafka.clients.producer.KafkaProducer|info] - [Producer clientId=producer-1] Closing the Kafka producer with timeoutMillis = 30000 ms.
[2021-12-29 17:18:48.538][DEBUG][kafka-producer-network-thread | producer-1|org.apache.kafka.clients.producer.internals.Sender|debug] - [Producer clientId=producer-1] Beginning shutdown of Kafka producer I/O thread, sending remaining records.
[2021-12-29 17:18:48.538][DEBUG][kafka-producer-network-thread | producer-1|org.apache.kafka.common.metrics.Metrics|removeSensor] - Removed sensor with name connections-closed:
[2021-12-29 17:18:48.538][DEBUG][kafka-producer-network-thread | producer-1|org.apache.kafka.common.metrics.Metrics|removeSensor] - Removed sensor with name connections-created:
[2021-12-29 17:18:48.538][DEBUG][kafka-producer-network-thread | producer-1|org.apache.kafka.common.metrics.Metrics|removeSensor] - Removed sensor with name successful-authentication:
[2021-12-29 17:18:48.538][DEBUG][kafka-producer-network-thread | producer-1|org.apache.kafka.common.metrics.Metrics|removeSensor] - Removed sensor with name failed-authentication:
[2021-12-29 17:18:48.538][DEBUG][kafka-producer-network-thread | producer-1|org.apache.kafka.common.metrics.Metrics|removeSensor] - Removed sensor with name bytes-sent-received:
[2021-12-29 17:18:48.538][DEBUG][kafka-producer-network-thread | producer-1|org.apache.kafka.common.metrics.Metrics|removeSensor] - Removed sensor with name bytes-sent:
[2021-12-29 17:18:48.538][DEBUG][kafka-producer-network-thread | producer-1|org.apache.kafka.common.metrics.Metrics|removeSensor] - Removed sensor with name bytes-received:
[2021-12-29 17:18:48.538][DEBUG][kafka-producer-network-thread | producer-1|org.apache.kafka.common.metrics.Metrics|removeSensor] - Removed sensor with name select-time:
[2021-12-29 17:18:48.538][DEBUG][kafka-producer-network-thread | producer-1|org.apache.kafka.common.metrics.Metrics|removeSensor] - Removed sensor with name io-time:
[2021-12-29 17:18:48.538][DEBUG][kafka-producer-network-thread | producer-1|org.apache.kafka.common.metrics.Metrics|removeSensor] - Removed sensor with name node--1.bytes-sent
[2021-12-29 17:18:48.539][DEBUG][kafka-producer-network-thread | producer-1|org.apache.kafka.common.metrics.Metrics|removeSensor] - Removed sensor with name node--1.bytes-received
[2021-12-29 17:18:48.539][DEBUG][kafka-producer-network-thread | producer-1|org.apache.kafka.common.metrics.Metrics|removeSensor] - Removed sensor with name node--1.latency
[2021-12-29 17:18:48.539][DEBUG][kafka-producer-network-thread | producer-1|org.apache.kafka.common.metrics.Metrics|removeSensor] - Removed sensor with name node--2.bytes-sent
[2021-12-29 17:18:48.539][DEBUG][kafka-producer-network-thread | producer-1|org.apache.kafka.common.metrics.Metrics|removeSensor] - Removed sensor with name node--2.bytes-received
[2021-12-29 17:18:48.539][DEBUG][kafka-producer-network-thread | producer-1|org.apache.kafka.common.metrics.Metrics|removeSensor] - Removed sensor with name node--2.latency
[2021-12-29 17:18:48.539][DEBUG][kafka-producer-network-thread | producer-1|org.apache.kafka.common.metrics.Metrics|removeSensor] - Removed sensor with name node--3.bytes-sent
[2021-12-29 17:18:48.539][DEBUG][kafka-producer-network-thread | producer-1|org.apache.kafka.common.metrics.Metrics|removeSensor] - Removed sensor with name node--3.bytes-received
[2021-12-29 17:18:48.539][DEBUG][kafka-producer-network-thread | producer-1|org.apache.kafka.common.metrics.Metrics|removeSensor] - Removed sensor with name node--3.latency
[2021-12-29 17:18:48.539][DEBUG][kafka-producer-network-thread | producer-1|org.apache.kafka.common.metrics.Metrics|removeSensor] - Removed sensor with name node-3.bytes-sent
[2021-12-29 17:18:48.539][DEBUG][kafka-producer-network-thread | producer-1|org.apache.kafka.common.metrics.Metrics|removeSensor] - Removed sensor with name node-3.bytes-received
[2021-12-29 17:18:48.539][DEBUG][kafka-producer-network-thread | producer-1|org.apache.kafka.common.metrics.Metrics|removeSensor] - Removed sensor with name node-3.latency
[2021-12-29 17:18:48.539][DEBUG][kafka-producer-network-thread | producer-1|org.apache.kafka.common.metrics.Metrics|removeSensor] - Removed sensor with name node-2.bytes-sent
[2021-12-29 17:18:48.539][DEBUG][kafka-producer-network-thread | producer-1|org.apache.kafka.common.metrics.Metrics|removeSensor] - Removed sensor with name node-2.bytes-received
[2021-12-29 17:18:48.539][DEBUG][kafka-producer-network-thread | producer-1|org.apache.kafka.common.metrics.Metrics|removeSensor] - Removed sensor with name node-2.latency
[2021-12-29 17:18:48.539][DEBUG][kafka-producer-network-thread | producer-1|org.apache.kafka.common.metrics.Metrics|removeSensor] - Removed sensor with name node-1.bytes-sent
[2021-12-29 17:18:48.539][DEBUG][kafka-producer-network-thread | producer-1|org.apache.kafka.common.metrics.Metrics|removeSensor] - Removed sensor with name node-1.bytes-received
[2021-12-29 17:18:48.539][DEBUG][kafka-producer-network-thread | producer-1|org.apache.kafka.common.metrics.Metrics|removeSensor] - Removed sensor with name node-1.latency
[2021-12-29 17:18:48.539][DEBUG][kafka-producer-network-thread | producer-1|org.apache.kafka.clients.producer.internals.Sender|debug] - [Producer clientId=producer-1] Shutdown of Kafka producer I/O thread has completed.
[2021-12-29 17:18:48.540][DEBUG][Thread-37|org.apache.kafka.clients.producer.KafkaProducer|debug] - [Producer clientId=producer-1] Kafka producer has been closed
[2021-12-29 17:18:48.540][DEBUG][Thread-37|org.springframework.context.annotation.CommonAnnotationBeanPostProcessor|invokeDestroyMethods] - Invoking destroy method on bean 'baseDestroyHandler': private void cn.quantgroup.tech.shutdown.BaseDestroyHandler.stopOther()
[2021-12-29 17:18:48.540][INFO][Thread-37|cn.quantgroup.tech.shutdown.BaseDestroyHandler|stopOther] - 我什么都没做, other stopped
[2021-12-29 17:18:48.540][DEBUG][Thread-37|org.springframework.context.annotation.CommonAnnotationBeanPostProcessor|invokeDestroyMethods] - Invoking destroy method on bean 'baseDestroyHandler.DestroyMessageQueueListener': private void cn.quantgroup.tech.shutdown.BaseDestroyHandler$DestroyMessageQueueListener.stopRabbitMQ()
[2021-12-29 17:18:48.541][INFO][Thread-37|cn.quantgroup.tech.shutdown.BaseDestroyHandler|stopRabbitMQ] - MQ listener stopped
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment