记得上下班打卡 | git大法好,push需谨慎
Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
L
liquidnet-bus-v1
Project
Project
Details
Activity
Releases
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
董敬伟
liquidnet-bus-v1
Commits
92912625
Commit
92912625
authored
May 09, 2022
by
zhanggb
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
~opt;
parent
e1bf558b
Changes
6
Hide whitespace changes
Inline
Side-by-side
Showing
6 changed files
with
75 additions
and
70 deletions
+75
-70
ConsumerGoblinCodeStreamConfig.java
...consumer/kylin/config/ConsumerGoblinCodeStreamConfig.java
+33
-16
ConsumerGoblinPhoneCodeStreamConfig.java
...mer/kylin/config/ConsumerGoblinPhoneCodeStreamConfig.java
+32
-27
AbstractHttpRedisReceiver.java
...ce/consumer/kylin/receiver/AbstractHttpRedisReceiver.java
+0
-3
ConsumerGoblinCodeReceiver.java
...e/consumer/kylin/receiver/ConsumerGoblinCodeReceiver.java
+2
-1
ConsumerGoblinPhoneCodeReceiver.java
...sumer/kylin/receiver/ConsumerGoblinPhoneCodeReceiver.java
+1
-16
pom.xml
...-service-platform/liquidnet-service-platform-impl/pom.xml
+7
-7
No files found.
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerGoblinCodeStreamConfig.java
View file @
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
;
}
}
}
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerGoblinPhoneCodeStreamConfig.java
View file @
92912625
...
@@ -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;
}*/
}
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/AbstractHttpRedisReceiver.java
View file @
92912625
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
;
...
...
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerGoblinCodeReceiver.java
View file @
92912625
...
@@ -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
();
...
...
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerGoblinPhoneCodeReceiver.java
View file @
92912625
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
()
{
...
...
liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/pom.xml
View file @
92912625
...
@@ -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>
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment