记得上下班打卡 | 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
d24c5178
Commit
d24c5178
authored
Jun 15, 2022
by
zhanggb
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
~queue:adam/kylin.SMS_NOTICE合并;
parent
38883b17
Changes
6
Hide whitespace changes
Inline
Side-by-side
Showing
6 changed files
with
177 additions
and
177 deletions
+177
-177
ConsumerAdamSmsSenderRedisStreamConfig.java
...r/adam/config/ConsumerAdamSmsSenderRedisStreamConfig.java
+121
-121
ConsumerAdamSmsNoticeRdsReceiver.java
...sumer/adam/receiver/ConsumerAdamSmsNoticeRdsReceiver.java
+17
-17
ConsumerCommonBizRedisStreamConfig.java
...sumer/base/config/ConsumerCommonBizRedisStreamConfig.java
+4
-4
ConsumerCommonSmsNoticeReceiver.java
...nsumer/base/receiver/ConsumerCommonSmsNoticeReceiver.java
+1
-1
ConsumerKylinSmsNoticeRdsReceiver.java
...mer/kylin/receiver/ConsumerKylinSmsNoticeRdsReceiver.java
+17
-17
ConsumerKylinSmsNoticeRdsReceiver.java
...er/slowly/receiver/ConsumerKylinSmsNoticeRdsReceiver.java
+17
-17
No files found.
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-adam/src/main/java/com/liquidnet/service/consumer/adam/config/ConsumerAdamSmsSenderRedisStreamConfig.java
View file @
d24c5178
package
com
.
liquidnet
.
service
.
consumer
.
adam
.
config
;
//
package com.liquidnet.service.consumer.adam.config;
//
import
com.liquidnet.common.cache.redis.config.RedisStreamConfig
;
//
import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
import
com.liquidnet.service.consumer.adam.receiver.ConsumerAdamSmsNoticeRdsReceiver
;
//
import com.liquidnet.service.consumer.adam.receiver.ConsumerAdamSmsNoticeRdsReceiver;
import
lombok.var
;
//
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;
import
org.springframework.data.redis.connection.RedisConnectionFactory
;
//
import org.springframework.data.redis.connection.RedisConnectionFactory;
import
org.springframework.data.redis.connection.stream.Consumer
;
//
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.stream.StreamMessageListenerContainer
;
//
import org.springframework.data.redis.stream.StreamMessageListenerContainer;
import
org.springframework.data.redis.stream.Subscription
;
//
import org.springframework.data.redis.stream.Subscription;
//
import
static
com
.
liquidnet
.
service
.
base
.
constant
.
MQConst
.
AdamQueue
;
//
import static com.liquidnet.service.base.constant.MQConst.AdamQueue;
//
@Configuration
//
@Configuration
public
class
ConsumerAdamSmsSenderRedisStreamConfig
extends
RedisStreamConfig
{
//
public class ConsumerAdamSmsSenderRedisStreamConfig extends RedisStreamConfig {
@Autowired
//
@Autowired
ConsumerAdamSmsNoticeRdsReceiver
consumerAdamSmsNoticeRdsReceiver
;
//
ConsumerAdamSmsNoticeRdsReceiver consumerAdamSmsNoticeRdsReceiver;
//
/**
//
/**
* 短信通知
//
* 短信通知
*
//
*
* @param listenerContainer
//
* @param listenerContainer
* @param t
//
* @param t
* @return
//
* @return
*/
//
*/
private
Subscription
receiveSqlURegister
(
StreamMessageListenerContainer
<
String
,
MapRecord
<
String
,
String
,
String
>>
listenerContainer
,
int
t
)
{
//
private Subscription receiveSqlURegister(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
return
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
AdamQueue
.
SMS_NOTICE
.
getGroup
(),
getConsumerName
(
AdamQueue
.
SMS_NOTICE
.
name
()
+
t
)),
//
return listenerContainer.receiveAutoAck(Consumer.from(AdamQueue.SMS_NOTICE.getGroup(), getConsumerName(AdamQueue.SMS_NOTICE.name() + t)),
StreamOffset
.
create
(
AdamQueue
.
SMS_NOTICE
.
getKey
(),
ReadOffset
.
lastConsumed
()),
consumerAdamSmsNoticeRdsReceiver
);
//
StreamOffset.create(AdamQueue.SMS_NOTICE.getKey(), ReadOffset.lastConsumed()), consumerAdamSmsNoticeRdsReceiver);
}
//
}
//
/* —————————————————————————— | —————————————————————————— | —————————————————————————— */
//
/* —————————————————————————— | —————————————————————————— | —————————————————————————— */
//
/* -------------------------------------------------------- | 短信通知 */
//
/* -------------------------------------------------------- | 短信通知 */
//
@Bean
//
@Bean
public
Subscription
subscriptionSmsNotice0
(
RedisConnectionFactory
factory
)
{
//
public Subscription subscriptionSmsNotice0(RedisConnectionFactory factory) {
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
//
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var
subscription
=
receiveSqlURegister
(
listenerContainer
,
0
);
//
var subscription = receiveSqlURegister(listenerContainer, 0);
listenerContainer
.
start
();
//
listenerContainer.start();
return
subscription
;
//
return subscription;
}
//
}
//
@Bean
//
@Bean
public
Subscription
subscriptionSmsNotice1
(
RedisConnectionFactory
factory
)
{
//
public Subscription subscriptionSmsNotice1(RedisConnectionFactory factory) {
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
//
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var
subscription
=
receiveSqlURegister
(
listenerContainer
,
1
);
//
var subscription = receiveSqlURegister(listenerContainer, 1);
listenerContainer
.
start
();
//
listenerContainer.start();
return
subscription
;
//
return subscription;
}
//
}
//
@Bean
//
@Bean
public
Subscription
subscriptionSmsNotice2
(
RedisConnectionFactory
factory
)
{
//
public Subscription subscriptionSmsNotice2(RedisConnectionFactory factory) {
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
//
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var
subscription
=
receiveSqlURegister
(
listenerContainer
,
2
);
//
var subscription = receiveSqlURegister(listenerContainer, 2);
listenerContainer
.
start
();
//
listenerContainer.start();
return
subscription
;
//
return subscription;
}
//
}
//
@Bean
//
@Bean
public
Subscription
subscriptionSmsNotice3
(
RedisConnectionFactory
factory
)
{
//
public Subscription subscriptionSmsNotice3(RedisConnectionFactory factory) {
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
//
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var
subscription
=
receiveSqlURegister
(
listenerContainer
,
3
);
//
var subscription = receiveSqlURegister(listenerContainer, 3);
listenerContainer
.
start
();
//
listenerContainer.start();
return
subscription
;
//
return subscription;
}
//
}
//
@Bean
//
@Bean
public
Subscription
subscriptionSmsNotice4
(
RedisConnectionFactory
factory
)
{
//
public Subscription subscriptionSmsNotice4(RedisConnectionFactory factory) {
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
//
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var
subscription
=
receiveSqlURegister
(
listenerContainer
,
4
);
//
var subscription = receiveSqlURegister(listenerContainer, 4);
listenerContainer
.
start
();
//
listenerContainer.start();
return
subscription
;
//
return subscription;
}
//
}
//
@Bean
//
@Bean
public
Subscription
subscriptionSmsNotice5
(
RedisConnectionFactory
factory
)
{
//
public Subscription subscriptionSmsNotice5(RedisConnectionFactory factory) {
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
//
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var
subscription
=
receiveSqlURegister
(
listenerContainer
,
5
);
//
var subscription = receiveSqlURegister(listenerContainer, 5);
listenerContainer
.
start
();
//
listenerContainer.start();
return
subscription
;
//
return subscription;
}
//
}
//
@Bean
//
@Bean
public
Subscription
subscriptionSmsNotice6
(
RedisConnectionFactory
factory
)
{
//
public Subscription subscriptionSmsNotice6(RedisConnectionFactory factory) {
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
//
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var
subscription
=
receiveSqlURegister
(
listenerContainer
,
6
);
//
var subscription = receiveSqlURegister(listenerContainer, 6);
listenerContainer
.
start
();
//
listenerContainer.start();
return
subscription
;
//
return subscription;
}
//
}
//
@Bean
//
@Bean
public
Subscription
subscriptionSmsNotice7
(
RedisConnectionFactory
factory
)
{
//
public Subscription subscriptionSmsNotice7(RedisConnectionFactory factory) {
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
//
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var
subscription
=
receiveSqlURegister
(
listenerContainer
,
7
);
//
var subscription = receiveSqlURegister(listenerContainer, 7);
listenerContainer
.
start
();
//
listenerContainer.start();
return
subscription
;
//
return subscription;
}
//
}
//
@Bean
//
@Bean
public
Subscription
subscriptionSmsNotice8
(
RedisConnectionFactory
factory
)
{
//
public Subscription subscriptionSmsNotice8(RedisConnectionFactory factory) {
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
//
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var
subscription
=
receiveSqlURegister
(
listenerContainer
,
8
);
//
var subscription = receiveSqlURegister(listenerContainer, 8);
listenerContainer
.
start
();
//
listenerContainer.start();
return
subscription
;
//
return subscription;
}
//
}
//
@Bean
//
@Bean
public
Subscription
subscriptionSmsNotice9
(
RedisConnectionFactory
factory
)
{
//
public Subscription subscriptionSmsNotice9(RedisConnectionFactory factory) {
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
//
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var
subscription
=
receiveSqlURegister
(
listenerContainer
,
9
);
//
var subscription = receiveSqlURegister(listenerContainer, 9);
listenerContainer
.
start
();
//
listenerContainer.start();
return
subscription
;
//
return subscription;
}
//
}
//
/* -------------------------------------------------------- | */
//
/* -------------------------------------------------------- | */
}
//
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-adam/src/main/java/com/liquidnet/service/consumer/adam/receiver/ConsumerAdamSmsNoticeRdsReceiver.java
View file @
d24c5178
package
com
.
liquidnet
.
service
.
consumer
.
adam
.
receiver
;
//
package com.liquidnet.service.consumer.adam.receiver;
//
import
com.liquidnet.service.base.constant.MQConst
;
//
import com.liquidnet.service.base.constant.MQConst;
import
org.springframework.stereotype.Component
;
//
import org.springframework.stereotype.Component;
//
@Component
//
@Component
public
class
ConsumerAdamSmsNoticeRdsReceiver
extends
AbstractSmsRedisReceiver
{
//
public class ConsumerAdamSmsNoticeRdsReceiver extends AbstractSmsRedisReceiver {
@Override
//
@Override
protected
String
getRedisStreamKey
()
{
//
protected String getRedisStreamKey() {
return
MQConst
.
AdamQueue
.
SMS_NOTICE
.
getKey
();
//
return MQConst.AdamQueue.SMS_NOTICE.getKey();
}
//
}
//
@Override
//
@Override
protected
String
getRedisStreamGroup
()
{
//
protected String getRedisStreamGroup() {
return
MQConst
.
AdamQueue
.
SMS_NOTICE
.
getGroup
();
//
return MQConst.AdamQueue.SMS_NOTICE.getGroup();
}
//
}
}
//
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/config/ConsumerCommonBizRedisStreamConfig.java
View file @
d24c5178
...
@@ -29,7 +29,7 @@ public class ConsumerCommonBizRedisStreamConfig extends RedisStreamConfig {
...
@@ -29,7 +29,7 @@ public class ConsumerCommonBizRedisStreamConfig extends RedisStreamConfig {
@Autowired
@Autowired
StringRedisTemplate
stringRedisTemplate
;
StringRedisTemplate
stringRedisTemplate
;
@Autowired
@Autowired
Consumer
KylinSmsNoticeReceiver
consumerKyli
nSmsNoticeReceiver
;
Consumer
CommonSmsNoticeReceiver
consumerCommo
nSmsNoticeReceiver
;
@Autowired
@Autowired
ConsumerGoblinBizArtworkUplReceiver
consumerGoblinBizArtworkUplReceiver
;
ConsumerGoblinBizArtworkUplReceiver
consumerGoblinBizArtworkUplReceiver
;
@Autowired
@Autowired
...
@@ -42,15 +42,15 @@ public class ConsumerCommonBizRedisStreamConfig extends RedisStreamConfig {
...
@@ -42,15 +42,15 @@ public class ConsumerCommonBizRedisStreamConfig extends RedisStreamConfig {
ConsumerGoblinBizIntegralReceiver
consumerGoblinBizIntegralReceiver
;
ConsumerGoblinBizIntegralReceiver
consumerGoblinBizIntegralReceiver
;
@Bean
// 短信通知
@Bean
// 短信通知
public
List
<
Subscription
>
subscription
Kyli
nSmsNotice
(
RedisConnectionFactory
factory
)
{
public
List
<
Subscription
>
subscription
Commo
nSmsNotice
(
RedisConnectionFactory
factory
)
{
List
<
Subscription
>
subscriptionList
=
new
ArrayList
<>();
List
<
Subscription
>
subscriptionList
=
new
ArrayList
<>();
MQConst
.
KylinQueue
stream
=
MQConst
.
KylinQueue
.
SMS_NOTICE
;
MQConst
.
KylinQueue
stream
=
MQConst
.
KylinQueue
.
SMS_NOTICE
;
this
.
initStream
(
stringRedisTemplate
,
stream
.
getKey
(),
stream
.
getGroup
());
this
.
initStream
(
stringRedisTemplate
,
stream
.
getKey
(),
stream
.
getGroup
());
for
(
int
i
=
0
;
i
<
3
;
i
++)
{
for
(
int
i
=
0
;
i
<
5
;
i
++)
{
StreamMessageListenerContainer
<
String
,
MapRecord
<
String
,
String
,
String
>>
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
StreamMessageListenerContainer
<
String
,
MapRecord
<
String
,
String
,
String
>>
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
subscriptionList
.
add
(
listenerContainer
.
receiveAutoAck
(
subscriptionList
.
add
(
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
stream
.
getGroup
(),
getConsumerName
(
stream
.
name
()
+
i
)),
Consumer
.
from
(
stream
.
getGroup
(),
getConsumerName
(
stream
.
name
()
+
i
)),
StreamOffset
.
create
(
stream
.
getKey
(),
ReadOffset
.
lastConsumed
()),
consumer
Kyli
nSmsNoticeReceiver
StreamOffset
.
create
(
stream
.
getKey
(),
ReadOffset
.
lastConsumed
()),
consumer
Commo
nSmsNoticeReceiver
));
));
listenerContainer
.
start
();
listenerContainer
.
start
();
}
}
...
...
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/Consumer
Kyli
nSmsNoticeReceiver.java
→
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/Consumer
Commo
nSmsNoticeReceiver.java
View file @
d24c5178
...
@@ -15,7 +15,7 @@ import java.util.HashMap;
...
@@ -15,7 +15,7 @@ import java.util.HashMap;
@Slf4j
@Slf4j
@Component
@Component
public
class
Consumer
Kyli
nSmsNoticeReceiver
extends
AbstractBizRedisReceiver
{
public
class
Consumer
Commo
nSmsNoticeReceiver
extends
AbstractBizRedisReceiver
{
@Resource
@Resource
private
SmsProcessor
smsProcessor
;
private
SmsProcessor
smsProcessor
;
...
...
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerKylinSmsNoticeRdsReceiver.java
View file @
d24c5178
package
com
.
liquidnet
.
service
.
consumer
.
kylin
.
receiver
;
//
package com.liquidnet.service.consumer.kylin.receiver;
//
import
com.liquidnet.service.base.constant.MQConst
;
//
import com.liquidnet.service.base.constant.MQConst;
import
org.springframework.stereotype.Component
;
//
import org.springframework.stereotype.Component;
//
@Component
//
@Component
public
class
ConsumerKylinSmsNoticeRdsReceiver
extends
AbstractSmsRedisReceiver
{
//
public class ConsumerKylinSmsNoticeRdsReceiver extends AbstractSmsRedisReceiver {
@Override
//
@Override
protected
String
getRedisStreamKey
()
{
//
protected String getRedisStreamKey() {
return
MQConst
.
KylinQueue
.
SMS_NOTICE
.
getKey
();
//
return MQConst.KylinQueue.SMS_NOTICE.getKey();
}
//
}
//
@Override
//
@Override
protected
String
getRedisStreamGroup
()
{
//
protected String getRedisStreamGroup() {
return
MQConst
.
KylinQueue
.
SMS_NOTICE
.
getGroup
();
//
return MQConst.KylinQueue.SMS_NOTICE.getGroup();
}
//
}
}
//
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/receiver/ConsumerKylinSmsNoticeRdsReceiver.java
View file @
d24c5178
package
com
.
liquidnet
.
service
.
consumer
.
slowly
.
receiver
;
//
package com.liquidnet.service.consumer.slowly.receiver;
//
import
com.liquidnet.service.base.constant.MQConst
;
//
import com.liquidnet.service.base.constant.MQConst;
import
org.springframework.stereotype.Component
;
//
import org.springframework.stereotype.Component;
//
@Component
//
@Component
public
class
ConsumerKylinSmsNoticeRdsReceiver
extends
AbstractSmsRedisReceiver
{
//
public class ConsumerKylinSmsNoticeRdsReceiver extends AbstractSmsRedisReceiver {
@Override
//
@Override
protected
String
getRedisStreamKey
()
{
//
protected String getRedisStreamKey() {
return
MQConst
.
KylinQueue
.
SMS_NOTICE
.
getKey
();
//
return MQConst.KylinQueue.SMS_NOTICE.getKey();
}
//
}
//
@Override
//
@Override
protected
String
getRedisStreamGroup
()
{
//
protected String getRedisStreamGroup() {
return
MQConst
.
KylinQueue
.
SMS_NOTICE
.
getGroup
();
//
return MQConst.KylinQueue.SMS_NOTICE.getGroup();
}
//
}
}
//
}
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