记得上下班打卡 | 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
da6cf45a
Commit
da6cf45a
authored
Oct 27, 2021
by
张国柄
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
consumer.kylin删除candy相关消费逻辑;
parent
cfbef2dc
Changes
9
Expand all
Hide whitespace changes
Inline
Side-by-side
Showing
9 changed files
with
504 additions
and
504 deletions
+504
-504
ConsumerCandyCouponBackRedisStreamConfig.java
...ylin/config/ConsumerCandyCouponBackRedisStreamConfig.java
+78
-78
ConsumerCandyCouponOrderBackRedisStreamConfig.java
...config/ConsumerCandyCouponOrderBackRedisStreamConfig.java
+80
-80
ConsumerCandyCouponReceiveRedisStreamConfig.java
...n/config/ConsumerCandyCouponReceiveRedisStreamConfig.java
+79
-79
ConsumerCandyCouponUseRedisStreamConfig.java
...kylin/config/ConsumerCandyCouponUseRedisStreamConfig.java
+77
-77
AbstractCouponOrderBackRedisReceiver.java
.../kylin/receiver/AbstractCouponOrderBackRedisReceiver.java
+122
-122
ConsumerCandyCouponBackRdsReceiver.java
...er/kylin/receiver/ConsumerCandyCouponBackRdsReceiver.java
+17
-17
ConsumerCandyCouponOrderBackRdsReceiver.java
...lin/receiver/ConsumerCandyCouponOrderBackRdsReceiver.java
+17
-17
ConsumerCandyCouponReceiveRdsReceiver.java
...kylin/receiver/ConsumerCandyCouponReceiveRdsReceiver.java
+17
-17
ConsumerCandyCouponUseRdsReceiver.java
...mer/kylin/receiver/ConsumerCandyCouponUseRdsReceiver.java
+17
-17
No files found.
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerCandyCouponBackRedisStreamConfig.java
View file @
da6cf45a
package
com
.
liquidnet
.
service
.
consumer
.
kylin
.
config
;
//
package com.liquidnet.service.consumer.kylin.config;
//
import
com.liquidnet.service.consumer.kylin.receiver.ConsumerCandyCouponBackRdsReceiver
;
//
import com.liquidnet.service.consumer.kylin.receiver.ConsumerCandyCouponBackRdsReceiver;
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
java.time.Duration
;
//
import java.time.Duration;
//
import
static
com
.
liquidnet
.
service
.
base
.
constant
.
MQConst
.
CandyQueue
.
COUPON_BACK
;
//
import static com.liquidnet.service.base.constant.MQConst.CandyQueue.COUPON_BACK;
//
//
@Configuration
//
@Configuration
public
class
ConsumerCandyCouponBackRedisStreamConfig
{
//
public class ConsumerCandyCouponBackRedisStreamConfig {
@Autowired
//
@Autowired
ConsumerCandyCouponBackRdsReceiver
consumerCandyCouponBackRdsReceiver
;
//
ConsumerCandyCouponBackRdsReceiver consumerCandyCouponBackRdsReceiver;
//
private
StreamMessageListenerContainer
<
String
,
MapRecord
<
String
,
String
,
String
>>
buildStreamMessageListenerContainer
(
RedisConnectionFactory
factory
)
{
//
private StreamMessageListenerContainer<String, MapRecord<String, String, String>> buildStreamMessageListenerContainer(RedisConnectionFactory factory) {
var
options
=
StreamMessageListenerContainer
//
var options = StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
//
.StreamMessageListenerContainerOptions
.
builder
()
//
.builder()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
//
.pollTimeout(Duration.ofMillis(1))
.
build
();
//
.build();
return
StreamMessageListenerContainer
.
create
(
factory
,
options
);
//
return StreamMessageListenerContainer.create(factory, options);
}
//
}
//
/**
//
/**
* 缺票登记
//
* 缺票登记
*
//
*
* @param listenerContainer
//
* @param listenerContainer
* @param t
//
* @param t
* @return
//
* @return
*/
//
*/
private
Subscription
receiveSqlCandyCouponBack
(
StreamMessageListenerContainer
<
String
,
MapRecord
<
String
,
String
,
String
>>
listenerContainer
,
int
t
)
{
//
private Subscription receiveSqlCandyCouponBack(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
return
listenerContainer
.
receiveAutoAck
(
//
return listenerContainer.receiveAutoAck(
Consumer
.
from
(
COUPON_BACK
.
getGroup
(),
COUPON_BACK
.
name
()
+
t
),
//
Consumer.from(COUPON_BACK.getGroup(), COUPON_BACK.name() + t),
StreamOffset
.
create
(
COUPON_BACK
.
getKey
(),
ReadOffset
.
lastConsumed
()),
consumerCandyCouponBackRdsReceiver
//
StreamOffset.create(COUPON_BACK.getKey(), ReadOffset.lastConsumed()), consumerCandyCouponBackRdsReceiver
);
//
);
}
//
}
//
/* —————————————————————————— | —————————————————————————— | —————————————————————————— */
//
/* —————————————————————————— | —————————————————————————— | —————————————————————————— */
//
/* -------------------------------------------------------- | 缺票登记 */
//
/* -------------------------------------------------------- | 缺票登记 */
//
@Bean
//
@Bean
public
Subscription
subscriptionSqlCandyCouponBack
(
RedisConnectionFactory
factory
)
{
//
public Subscription subscriptionSqlCandyCouponBack(RedisConnectionFactory factory) {
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
//
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var
subscription
=
receiveSqlCandyCouponBack
(
listenerContainer
,
1
);
//
var subscription = receiveSqlCandyCouponBack(listenerContainer, 1);
listenerContainer
.
start
();
//
listenerContainer.start();
return
subscription
;
//
return subscription;
}
//
}
//
@Bean
//
@Bean
public
Subscription
subscriptionSqlCandyCouponBack2
(
RedisConnectionFactory
factory
)
{
//
public Subscription subscriptionSqlCandyCouponBack2(RedisConnectionFactory factory) {
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
//
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var
subscription
=
receiveSqlCandyCouponBack
(
listenerContainer
,
1
);
//
var subscription = receiveSqlCandyCouponBack(listenerContainer, 1);
listenerContainer
.
start
();
//
listenerContainer.start();
return
subscription
;
//
return subscription;
}
//
}
//
@Bean
//
@Bean
public
Subscription
subscriptionSqlCandyCouponBack3
(
RedisConnectionFactory
factory
)
{
//
public Subscription subscriptionSqlCandyCouponBack3(RedisConnectionFactory factory) {
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
//
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var
subscription
=
receiveSqlCandyCouponBack
(
listenerContainer
,
1
);
//
var subscription = receiveSqlCandyCouponBack(listenerContainer, 1);
listenerContainer
.
start
();
//
listenerContainer.start();
return
subscription
;
//
return subscription;
}
//
}
//
/* -------------------------------------------------------- | */
//
/* -------------------------------------------------------- | */
}
//
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerCandyCouponOrderBackRedisStreamConfig.java
View file @
da6cf45a
package
com
.
liquidnet
.
service
.
consumer
.
kylin
.
config
;
//
package com.liquidnet.service.consumer.kylin.config;
//
import
com.liquidnet.service.consumer.kylin.receiver.ConsumerCandyCouponBackRdsReceiver
;
//
import com.liquidnet.service.consumer.kylin.receiver.ConsumerCandyCouponBackRdsReceiver;
import
com.liquidnet.service.consumer.kylin.receiver.ConsumerCandyCouponOrderBackRdsReceiver
;
//
import com.liquidnet.service.consumer.kylin.receiver.ConsumerCandyCouponOrderBackRdsReceiver;
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
java.time.Duration
;
//
import java.time.Duration;
//
import
static
com
.
liquidnet
.
service
.
base
.
constant
.
MQConst
.
CandyQueue
.
COUPON_BACK
;
//
import static com.liquidnet.service.base.constant.MQConst.CandyQueue.COUPON_BACK;
import
static
com
.
liquidnet
.
service
.
base
.
constant
.
MQConst
.
CandyQueue
.
COUPON_ORDER_BACK
;
//
import static com.liquidnet.service.base.constant.MQConst.CandyQueue.COUPON_ORDER_BACK;
//
//
@Configuration
//
@Configuration
public
class
ConsumerCandyCouponOrderBackRedisStreamConfig
{
//
public class ConsumerCandyCouponOrderBackRedisStreamConfig {
@Autowired
//
@Autowired
ConsumerCandyCouponOrderBackRdsReceiver
consumerCandyCouponOrderBackRdsReceiver
;
//
ConsumerCandyCouponOrderBackRdsReceiver consumerCandyCouponOrderBackRdsReceiver;
//
private
StreamMessageListenerContainer
<
String
,
MapRecord
<
String
,
String
,
String
>>
buildStreamMessageListenerContainer
(
RedisConnectionFactory
factory
)
{
//
private StreamMessageListenerContainer<String, MapRecord<String, String, String>> buildStreamMessageListenerContainer(RedisConnectionFactory factory) {
var
options
=
StreamMessageListenerContainer
//
var options = StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
//
.StreamMessageListenerContainerOptions
.
builder
()
//
.builder()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
//
.pollTimeout(Duration.ofMillis(1))
.
build
();
//
.build();
return
StreamMessageListenerContainer
.
create
(
factory
,
options
);
//
return StreamMessageListenerContainer.create(factory, options);
}
//
}
//
/**
//
/**
* 缺票登记
//
* 缺票登记
*
//
*
* @param listenerContainer
//
* @param listenerContainer
* @param t
//
* @param t
* @return
//
* @return
*/
//
*/
private
Subscription
receiveSqlCandyCouponBack
(
StreamMessageListenerContainer
<
String
,
MapRecord
<
String
,
String
,
String
>>
listenerContainer
,
int
t
)
{
//
private Subscription receiveSqlCandyCouponBack(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
return
listenerContainer
.
receiveAutoAck
(
//
return listenerContainer.receiveAutoAck(
Consumer
.
from
(
COUPON_ORDER_BACK
.
getGroup
(),
COUPON_ORDER_BACK
.
name
()
+
t
),
//
Consumer.from(COUPON_ORDER_BACK.getGroup(), COUPON_ORDER_BACK.name() + t),
StreamOffset
.
create
(
COUPON_ORDER_BACK
.
getKey
(),
ReadOffset
.
lastConsumed
()),
consumerCandyCouponOrderBackRdsReceiver
//
StreamOffset.create(COUPON_ORDER_BACK.getKey(), ReadOffset.lastConsumed()), consumerCandyCouponOrderBackRdsReceiver
);
//
);
}
//
}
//
/* —————————————————————————— | —————————————————————————— | —————————————————————————— */
//
/* —————————————————————————— | —————————————————————————— | —————————————————————————— */
//
/* -------------------------------------------------------- | 缺票登记 */
//
/* -------------------------------------------------------- | 缺票登记 */
//
@Bean
//
@Bean
public
Subscription
subscriptionSqlCandyCouponOrderBack
(
RedisConnectionFactory
factory
)
{
//
public Subscription subscriptionSqlCandyCouponOrderBack(RedisConnectionFactory factory) {
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
//
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var
subscription
=
receiveSqlCandyCouponBack
(
listenerContainer
,
1
);
//
var subscription = receiveSqlCandyCouponBack(listenerContainer, 1);
listenerContainer
.
start
();
//
listenerContainer.start();
return
subscription
;
//
return subscription;
}
//
}
//
@Bean
//
@Bean
public
Subscription
subscriptionSqlCandyCouponOrderBack2
(
RedisConnectionFactory
factory
)
{
//
public Subscription subscriptionSqlCandyCouponOrderBack2(RedisConnectionFactory factory) {
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
//
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var
subscription
=
receiveSqlCandyCouponBack
(
listenerContainer
,
1
);
//
var subscription = receiveSqlCandyCouponBack(listenerContainer, 1);
listenerContainer
.
start
();
//
listenerContainer.start();
return
subscription
;
//
return subscription;
}
//
}
//
@Bean
//
@Bean
public
Subscription
subscriptionSqlCandyCouponOrderBack3
(
RedisConnectionFactory
factory
)
{
//
public Subscription subscriptionSqlCandyCouponOrderBack3(RedisConnectionFactory factory) {
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
//
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var
subscription
=
receiveSqlCandyCouponBack
(
listenerContainer
,
1
);
//
var subscription = receiveSqlCandyCouponBack(listenerContainer, 1);
listenerContainer
.
start
();
//
listenerContainer.start();
return
subscription
;
//
return subscription;
}
//
}
//
/* -------------------------------------------------------- | */
//
/* -------------------------------------------------------- | */
}
//
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerCandyCouponReceiveRedisStreamConfig.java
View file @
da6cf45a
package
com
.
liquidnet
.
service
.
consumer
.
kylin
.
config
;
//
package com.liquidnet.service.consumer.kylin.config;
//
import
com.liquidnet.service.consumer.kylin.receiver.ConsumerCandyCouponReceiveRdsReceiver
;
//
import com.liquidnet.service.consumer.kylin.receiver.ConsumerCandyCouponReceiveRdsReceiver;
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
java.time.Duration
;
//
import java.time.Duration;
//
import
static
com
.
liquidnet
.
service
.
base
.
constant
.
MQConst
.
CandyQueue
.
COUPON_RECEIVE
;
//
import static com.liquidnet.service.base.constant.MQConst.CandyQueue.COUPON_RECEIVE;
import
static
com
.
liquidnet
.
service
.
base
.
constant
.
MQConst
.
CandyQueue
.
COUPON_USE
;
//
import static com.liquidnet.service.base.constant.MQConst.CandyQueue.COUPON_USE;
import
static
com
.
liquidnet
.
service
.
base
.
constant
.
MQConst
.
SweetQueue
.
SWEET_USER_INSERT_DRAW
;
//
import static com.liquidnet.service.base.constant.MQConst.SweetQueue.SWEET_USER_INSERT_DRAW;
//
@Configuration
//
@Configuration
public
class
ConsumerCandyCouponReceiveRedisStreamConfig
{
//
public class ConsumerCandyCouponReceiveRedisStreamConfig {
@Autowired
//
@Autowired
ConsumerCandyCouponReceiveRdsReceiver
consumerCandyCouponReceiveRdsReceiver
;
//
ConsumerCandyCouponReceiveRdsReceiver consumerCandyCouponReceiveRdsReceiver;
//
private
StreamMessageListenerContainer
<
String
,
MapRecord
<
String
,
String
,
String
>>
buildStreamMessageListenerContainer
(
RedisConnectionFactory
factory
)
{
//
private StreamMessageListenerContainer<String, MapRecord<String, String, String>> buildStreamMessageListenerContainer(RedisConnectionFactory factory) {
var
options
=
StreamMessageListenerContainer
//
var options = StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
//
.StreamMessageListenerContainerOptions
.
builder
()
//
.builder()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
//
.pollTimeout(Duration.ofMillis(1))
.
build
();
//
.build();
return
StreamMessageListenerContainer
.
create
(
factory
,
options
);
//
return StreamMessageListenerContainer.create(factory, options);
}
//
}
//
/**
//
/**
* 缺票登记
//
* 缺票登记
*
//
*
* @param listenerContainer
//
* @param listenerContainer
* @param t
//
* @param t
* @return
//
* @return
*/
//
*/
private
Subscription
receiveSqlCandyCouponReceive
(
StreamMessageListenerContainer
<
String
,
MapRecord
<
String
,
String
,
String
>>
listenerContainer
,
int
t
)
{
//
private Subscription receiveSqlCandyCouponReceive(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
return
listenerContainer
.
receiveAutoAck
(
//
return listenerContainer.receiveAutoAck(
Consumer
.
from
(
COUPON_RECEIVE
.
getGroup
(),
COUPON_RECEIVE
.
name
()
+
t
),
//
Consumer.from(COUPON_RECEIVE.getGroup(), COUPON_RECEIVE.name() + t),
StreamOffset
.
create
(
COUPON_RECEIVE
.
getKey
(),
ReadOffset
.
lastConsumed
()),
consumerCandyCouponReceiveRdsReceiver
//
StreamOffset.create(COUPON_RECEIVE.getKey(), ReadOffset.lastConsumed()), consumerCandyCouponReceiveRdsReceiver
);
//
);
}
//
}
//
/* —————————————————————————— | —————————————————————————— | —————————————————————————— */
//
/* —————————————————————————— | —————————————————————————— | —————————————————————————— */
//
/* -------------------------------------------------------- | 缺票登记 */
//
/* -------------------------------------------------------- | 缺票登记 */
//
@Bean
//
@Bean
public
Subscription
subscriptionSqlCandyCouponReceive
(
RedisConnectionFactory
factory
)
{
//
public Subscription subscriptionSqlCandyCouponReceive(RedisConnectionFactory factory) {
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
//
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var
subscription
=
receiveSqlCandyCouponReceive
(
listenerContainer
,
1
);
//
var subscription = receiveSqlCandyCouponReceive(listenerContainer, 1);
listenerContainer
.
start
();
//
listenerContainer.start();
return
subscription
;
//
return subscription;
}
//
}
//
@Bean
//
@Bean
public
Subscription
subscriptionSqlCandyCouponReceive2
(
RedisConnectionFactory
factory
)
{
//
public Subscription subscriptionSqlCandyCouponReceive2(RedisConnectionFactory factory) {
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
//
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var
subscription
=
receiveSqlCandyCouponReceive
(
listenerContainer
,
1
);
//
var subscription = receiveSqlCandyCouponReceive(listenerContainer, 1);
listenerContainer
.
start
();
//
listenerContainer.start();
return
subscription
;
//
return subscription;
}
//
}
//
@Bean
//
@Bean
public
Subscription
subscriptionSqlCandyCouponReceive3
(
RedisConnectionFactory
factory
)
{
//
public Subscription subscriptionSqlCandyCouponReceive3(RedisConnectionFactory factory) {
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
//
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var
subscription
=
receiveSqlCandyCouponReceive
(
listenerContainer
,
1
);
//
var subscription = receiveSqlCandyCouponReceive(listenerContainer, 1);
listenerContainer
.
start
();
//
listenerContainer.start();
return
subscription
;
//
return subscription;
}
//
}
//
/* -------------------------------------------------------- | */
//
/* -------------------------------------------------------- | */
}
//
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerCandyCouponUseRedisStreamConfig.java
View file @
da6cf45a
package
com
.
liquidnet
.
service
.
consumer
.
kylin
.
config
;
//
package com.liquidnet.service.consumer.kylin.config;
//
import
com.liquidnet.service.consumer.kylin.receiver.ConsumerCandyCouponUseRdsReceiver
;
//
import com.liquidnet.service.consumer.kylin.receiver.ConsumerCandyCouponUseRdsReceiver;
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
java.time.Duration
;
//
import java.time.Duration;
//
import
static
com
.
liquidnet
.
service
.
base
.
constant
.
MQConst
.
CandyQueue
.
COUPON_USE
;
//
import static com.liquidnet.service.base.constant.MQConst.CandyQueue.COUPON_USE;
//
@Configuration
//
@Configuration
public
class
ConsumerCandyCouponUseRedisStreamConfig
{
//
public class ConsumerCandyCouponUseRedisStreamConfig {
@Autowired
//
@Autowired
ConsumerCandyCouponUseRdsReceiver
consumerCandyCouponUseRdsReceiver
;
//
ConsumerCandyCouponUseRdsReceiver consumerCandyCouponUseRdsReceiver;
//
private
StreamMessageListenerContainer
<
String
,
MapRecord
<
String
,
String
,
String
>>
buildStreamMessageListenerContainer
(
RedisConnectionFactory
factory
)
{
//
private StreamMessageListenerContainer<String, MapRecord<String, String, String>> buildStreamMessageListenerContainer(RedisConnectionFactory factory) {
var
options
=
StreamMessageListenerContainer
//
var options = StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
//
.StreamMessageListenerContainerOptions
.
builder
()
//
.builder()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
//
.pollTimeout(Duration.ofMillis(1))
.
build
();
//
.build();
return
StreamMessageListenerContainer
.
create
(
factory
,
options
);
//
return StreamMessageListenerContainer.create(factory, options);
}
//
}
//
/**
//
/**
* 缺票登记
//
* 缺票登记
*
//
*
* @param listenerContainer
//
* @param listenerContainer
* @param t
//
* @param t
* @return
//
* @return
*/
//
*/
private
Subscription
receiveSqlCandyCouponUse
(
StreamMessageListenerContainer
<
String
,
MapRecord
<
String
,
String
,
String
>>
listenerContainer
,
int
t
)
{
//
private Subscription receiveSqlCandyCouponUse(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
return
listenerContainer
.
receiveAutoAck
(
//
return listenerContainer.receiveAutoAck(
Consumer
.
from
(
COUPON_USE
.
getGroup
(),
COUPON_USE
.
name
()
+
t
),
//
Consumer.from(COUPON_USE.getGroup(), COUPON_USE.name() + t),
StreamOffset
.
create
(
COUPON_USE
.
getKey
(),
ReadOffset
.
lastConsumed
()),
consumerCandyCouponUseRdsReceiver
//
StreamOffset.create(COUPON_USE.getKey(), ReadOffset.lastConsumed()), consumerCandyCouponUseRdsReceiver
);
//
);
}
//
}
//
/* —————————————————————————— | —————————————————————————— | —————————————————————————— */
//
/* —————————————————————————— | —————————————————————————— | —————————————————————————— */
//
/* -------------------------------------------------------- | 缺票登记 */
//
/* -------------------------------------------------------- | 缺票登记 */
//
@Bean
//
@Bean
public
Subscription
subscriptionSqlCandyCouponUse
(
RedisConnectionFactory
factory
)
{
//
public Subscription subscriptionSqlCandyCouponUse(RedisConnectionFactory factory) {
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
//
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var
subscription
=
receiveSqlCandyCouponUse
(
listenerContainer
,
1
);
//
var subscription = receiveSqlCandyCouponUse(listenerContainer, 1);
listenerContainer
.
start
();
//
listenerContainer.start();
return
subscription
;
//
return subscription;
}
//
}
//
@Bean
//
@Bean
public
Subscription
subscriptionSqlCandyCouponUse2
(
RedisConnectionFactory
factory
)
{
//
public Subscription subscriptionSqlCandyCouponUse2(RedisConnectionFactory factory) {
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
//
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var
subscription
=
receiveSqlCandyCouponUse
(
listenerContainer
,
1
);
//
var subscription = receiveSqlCandyCouponUse(listenerContainer, 1);
listenerContainer
.
start
();
//
listenerContainer.start();
return
subscription
;
//
return subscription;
}
//
}
//
@Bean
//
@Bean
public
Subscription
subscriptionSqlCandyCouponUse3
(
RedisConnectionFactory
factory
)
{
//
public Subscription subscriptionSqlCandyCouponUse3(RedisConnectionFactory factory) {
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
//
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var
subscription
=
receiveSqlCandyCouponUse
(
listenerContainer
,
1
);
//
var subscription = receiveSqlCandyCouponUse(listenerContainer, 1);
listenerContainer
.
start
();
//
listenerContainer.start();
return
subscription
;
//
return subscription;
}
//
}
//
/* -------------------------------------------------------- | */
//
/* -------------------------------------------------------- | */
}
//
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/AbstractCouponOrderBackRedisReceiver.java
View file @
da6cf45a
This diff is collapsed.
Click to expand it.
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerCandyCouponBackRdsReceiver.java
View file @
da6cf45a
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
ConsumerCandyCouponBackRdsReceiver
extends
AbstractSqlRedisReceiver
{
//
public class ConsumerCandyCouponBackRdsReceiver extends AbstractSqlRedisReceiver {
@Override
//
@Override
protected
String
getRedisStreamKey
()
{
//
protected String getRedisStreamKey() {
return
MQConst
.
CandyQueue
.
COUPON_BACK
.
getKey
();
//
return MQConst.CandyQueue.COUPON_BACK.getKey();
}
//
}
//
@Override
//
@Override
protected
String
getRedisStreamGroup
()
{
//
protected String getRedisStreamGroup() {
return
MQConst
.
CandyQueue
.
COUPON_BACK
.
getGroup
();
//
return MQConst.CandyQueue.COUPON_BACK.getGroup();
}
//
}
}
//
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerCandyCouponOrderBackRdsReceiver.java
View file @
da6cf45a
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
ConsumerCandyCouponOrderBackRdsReceiver
extends
AbstractCouponOrderBackRedisReceiver
{
//
public class ConsumerCandyCouponOrderBackRdsReceiver extends AbstractCouponOrderBackRedisReceiver {
@Override
//
@Override
protected
String
getRedisStreamKey
()
{
//
protected String getRedisStreamKey() {
return
MQConst
.
CandyQueue
.
COUPON_ORDER_BACK
.
getKey
();
//
return MQConst.CandyQueue.COUPON_ORDER_BACK.getKey();
}
//
}
//
@Override
//
@Override
protected
String
getRedisStreamGroup
()
{
//
protected String getRedisStreamGroup() {
return
MQConst
.
CandyQueue
.
COUPON_ORDER_BACK
.
getGroup
();
//
return MQConst.CandyQueue.COUPON_ORDER_BACK.getGroup();
}
//
}
}
//
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerCandyCouponReceiveRdsReceiver.java
View file @
da6cf45a
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
ConsumerCandyCouponReceiveRdsReceiver
extends
AbstractSqlRedisReceiver
{
//
public class ConsumerCandyCouponReceiveRdsReceiver extends AbstractSqlRedisReceiver {
@Override
//
@Override
protected
String
getRedisStreamKey
()
{
//
protected String getRedisStreamKey() {
return
MQConst
.
CandyQueue
.
COUPON_RECEIVE
.
getKey
();
//
return MQConst.CandyQueue.COUPON_RECEIVE.getKey();
}
//
}
//
@Override
//
@Override
protected
String
getRedisStreamGroup
()
{
//
protected String getRedisStreamGroup() {
return
MQConst
.
CandyQueue
.
COUPON_RECEIVE
.
getGroup
();
//
return MQConst.CandyQueue.COUPON_RECEIVE.getGroup();
}
//
}
}
//
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerCandyCouponUseRdsReceiver.java
View file @
da6cf45a
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
ConsumerCandyCouponUseRdsReceiver
extends
AbstractSqlRedisReceiver
{
//
public class ConsumerCandyCouponUseRdsReceiver extends AbstractSqlRedisReceiver {
@Override
//
@Override
protected
String
getRedisStreamKey
()
{
//
protected String getRedisStreamKey() {
return
MQConst
.
CandyQueue
.
COUPON_USE
.
getKey
();
//
return MQConst.CandyQueue.COUPON_USE.getKey();
}
//
}
//
@Override
//
@Override
protected
String
getRedisStreamGroup
()
{
//
protected String getRedisStreamGroup() {
return
MQConst
.
CandyQueue
.
COUPON_USE
.
getGroup
();
//
return MQConst.CandyQueue.COUPON_USE.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