记得上下班打卡 | git大法好,push需谨慎

Commit e0c76d3d authored by 胡佳晨's avatar 胡佳晨

Merge remote-tracking branch 'origin/dev_yy_dh' into dev_yy_dh

parents 81f1886f 92912625
...@@ -3,7 +3,6 @@ package com.liquidnet.service.consumer.kylin.config; ...@@ -3,7 +3,6 @@ package com.liquidnet.service.consumer.kylin.config;
import com.liquidnet.common.cache.redis.config.RedisStreamConfig; import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
import com.liquidnet.service.base.constant.MQConst; import com.liquidnet.service.base.constant.MQConst;
import com.liquidnet.service.consumer.kylin.receiver.ConsumerGoblinCodeReceiver; import com.liquidnet.service.consumer.kylin.receiver.ConsumerGoblinCodeReceiver;
import lombok.var;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Configuration;
...@@ -12,28 +11,46 @@ import org.springframework.data.redis.connection.stream.Consumer; ...@@ -12,28 +11,46 @@ import org.springframework.data.redis.connection.stream.Consumer;
import org.springframework.data.redis.connection.stream.MapRecord; import org.springframework.data.redis.connection.stream.MapRecord;
import org.springframework.data.redis.connection.stream.ReadOffset; import org.springframework.data.redis.connection.stream.ReadOffset;
import org.springframework.data.redis.connection.stream.StreamOffset; import org.springframework.data.redis.connection.stream.StreamOffset;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.stream.StreamMessageListenerContainer; import org.springframework.data.redis.stream.StreamMessageListenerContainer;
import org.springframework.data.redis.stream.Subscription; import org.springframework.data.redis.stream.Subscription;
import java.util.ArrayList;
import java.util.List;
@Configuration @Configuration
public class ConsumerGoblinCodeStreamConfig extends RedisStreamConfig { public class ConsumerGoblinCodeStreamConfig extends RedisStreamConfig {
@Autowired
StringRedisTemplate stringRedisTemplate;
@Autowired @Autowired
ConsumerGoblinCodeReceiver consumerGoblinCodeReceiver; ConsumerGoblinCodeReceiver consumerGoblinCodeReceiver;
public Subscription receiveCodeExamine(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) { // public Subscription receiveCodeExamine(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_CODE_OPERA.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_CODE_OPERA.name() + t)), // return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_CODE_OPERA.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_CODE_OPERA.name() + t)),
StreamOffset.create(MQConst.GoblinQueue.GOBLIN_CODE_OPERA.getKey(), ReadOffset.lastConsumed()), consumerGoblinCodeReceiver); // StreamOffset.create(MQConst.GoblinQueue.GOBLIN_CODE_OPERA.getKey(), ReadOffset.lastConsumed()), consumerGoblinCodeReceiver);
} // }
//
// @Bean
@Bean // public Subscription codeExamine0(RedisConnectionFactory factory) {
public Subscription codeExamine0(RedisConnectionFactory factory) { // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var subscription = receiveCodeExamine(listenerContainer, 0);
var subscription = receiveCodeExamine(listenerContainer, 0); // listenerContainer.start();
listenerContainer.start(); // return subscription;
return subscription; // }
@Bean//
public List<Subscription> subscriptionCodeExamine(RedisConnectionFactory factory) {
List<Subscription> subscriptionList = new ArrayList<>();
MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_CODE_OPERA;
this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
for (int i = 0; i < 1; i++) {
StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
subscriptionList.add(listenerContainer.receiveAutoAck(
Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),
StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerGoblinCodeReceiver
));
listenerContainer.start();
}
return subscriptionList;
} }
} }
...@@ -11,44 +11,49 @@ import org.springframework.data.redis.connection.stream.Consumer; ...@@ -11,44 +11,49 @@ import org.springframework.data.redis.connection.stream.Consumer;
import org.springframework.data.redis.connection.stream.MapRecord; import org.springframework.data.redis.connection.stream.MapRecord;
import org.springframework.data.redis.connection.stream.ReadOffset; import org.springframework.data.redis.connection.stream.ReadOffset;
import org.springframework.data.redis.connection.stream.StreamOffset; import org.springframework.data.redis.connection.stream.StreamOffset;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.stream.StreamMessageListenerContainer; import org.springframework.data.redis.stream.StreamMessageListenerContainer;
import org.springframework.data.redis.stream.Subscription; import org.springframework.data.redis.stream.Subscription;
import com.liquidnet.service.consumer.kylin.receiver.ConsumerGoblinPhoneCodeReceiver; import com.liquidnet.service.consumer.kylin.receiver.ConsumerGoblinPhoneCodeReceiver;
import java.util.ArrayList;
import java.util.List;
@Configuration @Configuration
public class ConsumerGoblinPhoneCodeStreamConfig extends RedisStreamConfig { public class ConsumerGoblinPhoneCodeStreamConfig extends RedisStreamConfig {
@Autowired
StringRedisTemplate stringRedisTemplate;
@Autowired @Autowired
ConsumerGoblinPhoneCodeReceiver consumerGoblinPhoneCodeReceiver; ConsumerGoblinPhoneCodeReceiver consumerGoblinPhoneCodeReceiver;
public Subscription receivePhoneCodeExamine(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) { // public Subscription receivePhoneCodeExamine(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_PHONE_CODE_OPERA.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_PHONE_CODE_OPERA.name() + t)), // return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_PHONE_CODE_OPERA.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_PHONE_CODE_OPERA.name() + t)),
StreamOffset.create(MQConst.GoblinQueue.GOBLIN_PHONE_CODE_OPERA.getKey(), ReadOffset.lastConsumed()), consumerGoblinPhoneCodeReceiver); // StreamOffset.create(MQConst.GoblinQueue.GOBLIN_PHONE_CODE_OPERA.getKey(), ReadOffset.lastConsumed()), consumerGoblinPhoneCodeReceiver);
} // }
//
// @Bean
@Bean // public Subscription phoneCodeExamine0(RedisConnectionFactory factory) {
public Subscription phoneCodeExamine0(RedisConnectionFactory factory) { // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var subscription = receivePhoneCodeExamine(listenerContainer, 0);
var subscription = receivePhoneCodeExamine(listenerContainer, 0); // listenerContainer.start();
listenerContainer.start(); // return subscription;
return subscription; // }
@Bean//
public List<Subscription> subscriptionPhoneCodeExamine(RedisConnectionFactory factory) {
List<Subscription> subscriptionList = new ArrayList<>();
MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_PHONE_CODE_OPERA;
this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
for (int i = 0; i < 1; i++) {
StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
subscriptionList.add(listenerContainer.receiveAutoAck(
Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),
StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerGoblinPhoneCodeReceiver
));
listenerContainer.start();
}
return subscriptionList;
} }
/* @Bean
public Subscription phoneCodeExamine1(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receivePhoneCodeExamine(listenerContainer, 1);
listenerContainer.start();
return subscription;
}*/
} }
package com.liquidnet.service.consumer.kylin.receiver; package com.liquidnet.service.consumer.kylin.receiver;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.fasterxml.jackson.core.type.TypeReference; import com.fasterxml.jackson.core.type.TypeReference;
import com.liquidnet.commons.lang.util.CollectionUtil; import com.liquidnet.commons.lang.util.CollectionUtil;
import com.liquidnet.commons.lang.util.HttpUtil; import com.liquidnet.commons.lang.util.HttpUtil;
...@@ -9,7 +7,6 @@ import com.liquidnet.commons.lang.util.JsonUtils; ...@@ -9,7 +7,6 @@ import com.liquidnet.commons.lang.util.JsonUtils;
import com.liquidnet.service.base.ResponseDto; import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.base.SqlMapping; import com.liquidnet.service.base.SqlMapping;
import com.liquidnet.service.base.constant.MQConst; import com.liquidnet.service.base.constant.MQConst;
import com.liquidnet.service.goblin.mapper.GoblinNftExCodeMapper;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
......
...@@ -6,7 +6,8 @@ import org.springframework.stereotype.Component; ...@@ -6,7 +6,8 @@ import org.springframework.stereotype.Component;
@Slf4j @Slf4j
@Component @Component
public class ConsumerGoblinCodeReceiver extends AbstractSqlRedisReceiver{ public class ConsumerGoblinCodeReceiver extends AbstractSqlRedisReceiver {
@Override @Override
protected String getRedisStreamKey() { protected String getRedisStreamKey() {
return MQConst.GoblinQueue.GOBLIN_CODE_OPERA.getKey(); return MQConst.GoblinQueue.GOBLIN_CODE_OPERA.getKey();
......
package com.liquidnet.service.consumer.kylin.receiver; package com.liquidnet.service.consumer.kylin.receiver;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.fasterxml.jackson.core.type.TypeReference;
import com.liquidnet.commons.lang.util.*;
import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.base.constant.MQConst; import com.liquidnet.service.base.constant.MQConst;
import com.liquidnet.service.goblin.mapper.GoblinNftExCodeMapper;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.data.redis.connection.stream.MapRecord;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
@Slf4j @Slf4j
@Component @Component
public class ConsumerGoblinPhoneCodeReceiver extends AbstractHttpRedisReceiver{ public class ConsumerGoblinPhoneCodeReceiver extends AbstractHttpRedisReceiver {
@Override @Override
protected String getRedisStreamKey() { protected String getRedisStreamKey() {
......
...@@ -12,7 +12,6 @@ ...@@ -12,7 +12,6 @@
<properties> <properties>
<bitwalker.version>1.19</bitwalker.version> <bitwalker.version>1.19</bitwalker.version>
<easyexcel.version>3.0.5</easyexcel.version>
</properties> </properties>
<dependencies> <dependencies>
...@@ -114,16 +113,17 @@ ...@@ -114,16 +113,17 @@
<artifactId>aliyun-java-sdk-facebody</artifactId> <artifactId>aliyun-java-sdk-facebody</artifactId>
<version>1.2.27</version> <version>1.2.27</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.alibaba</groupId> <groupId>com.alibaba</groupId>
<artifactId>easyexcel</artifactId> <artifactId>easyexcel</artifactId>
</dependency> </dependency>
<!-- <dependency>-->
<dependency> <!-- <groupId>redis.clients</groupId>-->
<groupId>redis.clients</groupId> <!-- <artifactId>jedis</artifactId>-->
<artifactId>jedis</artifactId> <!-- <version>3.6.0</version>-->
<version>3.6.0</version> <!-- </dependency>-->
</dependency>
<dependency> <dependency>
<groupId>com.liquidnet</groupId> <groupId>com.liquidnet</groupId>
<artifactId>liquidnet-api-feign-stone</artifactId> <artifactId>liquidnet-api-feign-stone</artifactId>
......
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