记得上下班打卡 | 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
5f77d57d
Commit
5f77d57d
authored
Jun 15, 2022
by
胡佳晨
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
迁移 consumer-kylin
parent
c1be86d2
Changes
22
Expand all
Hide whitespace changes
Inline
Side-by-side
Showing
22 changed files
with
984 additions
and
670 deletions
+984
-670
ConsumerKylinSqlOrderAgainRedisStreamConfig.java
...ig/kylin/ConsumerKylinSqlOrderAgainRedisStreamConfig.java
+44
-0
ConsumerKylinSqlOrderCreateRedisStreamConfig.java
...g/kylin/ConsumerKylinSqlOrderCreateRedisStreamConfig.java
+43
-0
ConsumerKylinSqlOrderOvertimeRefundRedisStreamConfig.java
...ConsumerKylinSqlOrderOvertimeRefundRedisStreamConfig.java
+43
-0
ConsumerKylinSqlOrderPayRedisStreamConfig.java
...nfig/kylin/ConsumerKylinSqlOrderPayRedisStreamConfig.java
+47
-0
ConsumerKylinSqlOrderRefundRedisStreamConfig.java
...g/kylin/ConsumerKylinSqlOrderRefundRedisStreamConfig.java
+47
-0
ConsumerKylinSqlOrderAgainRdsReceiver.java
...receiver/kylin/ConsumerKylinSqlOrderAgainRdsReceiver.java
+18
-0
ConsumerKylinSqlOrderCreateRdsReceiver.java
...eceiver/kylin/ConsumerKylinSqlOrderCreateRdsReceiver.java
+18
-0
ConsumerKylinSqlOrderOvertimeRefundRdsReceiver.java
...kylin/ConsumerKylinSqlOrderOvertimeRefundRdsReceiver.java
+18
-0
ConsumerKylinSqlOrderPayRdsReceiver.java
...e/receiver/kylin/ConsumerKylinSqlOrderPayRdsReceiver.java
+18
-0
ConsumerKylinSqlOrderRefundRdsReceiver.java
...eceiver/kylin/ConsumerKylinSqlOrderRefundRdsReceiver.java
+18
-0
ConsumerCommonBizRedisStreamConfig.java
...umer/kylin/config/ConsumerCommonBizRedisStreamConfig.java
+12
-12
ConsumerCommonSqlRedisStreamConfig.java
...umer/kylin/config/ConsumerCommonSqlRedisStreamConfig.java
+12
-12
ConsumerKylinSqlOptOrderCloseRedisStreamConfig.java
...onfig/ConsumerKylinSqlOptOrderCloseRedisStreamConfig.java
+123
-123
ConsumerKylinSqlOrderAgainRedisStreamConfig.java
...n/config/ConsumerKylinSqlOrderAgainRedisStreamConfig.java
+68
-68
ConsumerKylinSqlOrderCreateRedisStreamConfig.java
.../config/ConsumerKylinSqlOrderCreateRedisStreamConfig.java
+136
-136
ConsumerKylinSqlOrderOvertimeRefundRedisStreamConfig.java
...ConsumerKylinSqlOrderOvertimeRefundRedisStreamConfig.java
+68
-68
ConsumerKylinSqlOrderPayRedisStreamConfig.java
...lin/config/ConsumerKylinSqlOrderPayRedisStreamConfig.java
+102
-102
ConsumerKylinSqlOrderRefundRedisStreamConfig.java
.../config/ConsumerKylinSqlOrderRefundRedisStreamConfig.java
+81
-81
ConsumerKylinSqlOrderCreateRdsReceiver.java
...ylin/receiver/ConsumerKylinSqlOrderCreateRdsReceiver.java
+17
-17
ConsumerKylinSqlOrderOvertimeRefundRdsReceiver.java
...eiver/ConsumerKylinSqlOrderOvertimeRefundRdsReceiver.java
+17
-17
ConsumerKylinSqlOrderPayRdsReceiver.java
...r/kylin/receiver/ConsumerKylinSqlOrderPayRdsReceiver.java
+17
-17
ConsumerKylinSqlOrderRefundRdsReceiver.java
...ylin/receiver/ConsumerKylinSqlOrderRefundRdsReceiver.java
+17
-17
No files found.
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/config/kylin/ConsumerKylinSqlOrderAgainRedisStreamConfig.java
0 → 100644
View file @
5f77d57d
package
com
.
liquidnet
.
service
.
consumer
.
base
.
config
.
kylin
;
import
com.liquidnet.common.cache.redis.config.RedisStreamConfig
;
import
com.liquidnet.service.base.constant.MQConst
;
import
com.liquidnet.service.consumer.base.receiver.kylin.ConsumerKylinSqlOrderAgainRdsReceiver
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.context.annotation.Bean
;
import
org.springframework.context.annotation.Configuration
;
import
org.springframework.data.redis.connection.RedisConnectionFactory
;
import
org.springframework.data.redis.connection.stream.Consumer
;
import
org.springframework.data.redis.connection.stream.MapRecord
;
import
org.springframework.data.redis.connection.stream.ReadOffset
;
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.Subscription
;
import
java.util.ArrayList
;
import
java.util.List
;
@Configuration
public
class
ConsumerKylinSqlOrderAgainRedisStreamConfig
extends
RedisStreamConfig
{
@Autowired
StringRedisTemplate
stringRedisTemplate
;
@Autowired
ConsumerKylinSqlOrderAgainRdsReceiver
consumerKylinSqlOrderAgainRdsReceiver
;
@Bean
// 订单再次支付
public
List
<
Subscription
>
subscriptionSqlOrderAgain
(
RedisConnectionFactory
factory
)
{
List
<
Subscription
>
subscriptionList
=
new
ArrayList
<>();
MQConst
.
KylinQueue
stream
=
MQConst
.
KylinQueue
.
SQL_ORDER_AGAIN
;
this
.
initStream
(
stringRedisTemplate
,
stream
.
getKey
(),
stream
.
getGroup
());
for
(
int
i
=
0
;
i
<
3
;
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
()),
consumerKylinSqlOrderAgainRdsReceiver
));
listenerContainer
.
start
();
}
return
subscriptionList
;
}
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/config/kylin/ConsumerKylinSqlOrderCreateRedisStreamConfig.java
0 → 100644
View file @
5f77d57d
package
com
.
liquidnet
.
service
.
consumer
.
base
.
config
.
kylin
;
import
com.liquidnet.common.cache.redis.config.RedisStreamConfig
;
import
com.liquidnet.service.base.constant.MQConst
;
import
com.liquidnet.service.consumer.base.receiver.kylin.ConsumerKylinSqlOrderCreateRdsReceiver
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.context.annotation.Bean
;
import
org.springframework.context.annotation.Configuration
;
import
org.springframework.data.redis.connection.RedisConnectionFactory
;
import
org.springframework.data.redis.connection.stream.Consumer
;
import
org.springframework.data.redis.connection.stream.MapRecord
;
import
org.springframework.data.redis.connection.stream.ReadOffset
;
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.Subscription
;
import
java.util.ArrayList
;
import
java.util.List
;
@Configuration
public
class
ConsumerKylinSqlOrderCreateRedisStreamConfig
extends
RedisStreamConfig
{
@Autowired
StringRedisTemplate
stringRedisTemplate
;
@Autowired
ConsumerKylinSqlOrderCreateRdsReceiver
consumerKylinSqlOrderCreateRdsReceiver
;
@Bean
// 创建订单
public
List
<
Subscription
>
subscriptionSqlOrderCreate
(
RedisConnectionFactory
factory
)
{
List
<
Subscription
>
subscriptionList
=
new
ArrayList
<>();
MQConst
.
KylinQueue
stream
=
MQConst
.
KylinQueue
.
SQL_ORDER_CREATE
;
this
.
initStream
(
stringRedisTemplate
,
stream
.
getKey
(),
stream
.
getGroup
());
for
(
int
i
=
0
;
i
<
20
;
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
()),
consumerKylinSqlOrderCreateRdsReceiver
));
listenerContainer
.
start
();
}
return
subscriptionList
;
}
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/config/kylin/ConsumerKylinSqlOrderOvertimeRefundRedisStreamConfig.java
0 → 100644
View file @
5f77d57d
package
com
.
liquidnet
.
service
.
consumer
.
base
.
config
.
kylin
;
import
com.liquidnet.common.cache.redis.config.RedisStreamConfig
;
import
com.liquidnet.service.base.constant.MQConst
;
import
com.liquidnet.service.consumer.base.receiver.kylin.ConsumerKylinSqlOrderOvertimeRefundRdsReceiver
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.context.annotation.Bean
;
import
org.springframework.context.annotation.Configuration
;
import
org.springframework.data.redis.connection.RedisConnectionFactory
;
import
org.springframework.data.redis.connection.stream.Consumer
;
import
org.springframework.data.redis.connection.stream.MapRecord
;
import
org.springframework.data.redis.connection.stream.ReadOffset
;
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.Subscription
;
import
java.util.ArrayList
;
import
java.util.List
;
@Configuration
public
class
ConsumerKylinSqlOrderOvertimeRefundRedisStreamConfig
extends
RedisStreamConfig
{
@Autowired
StringRedisTemplate
stringRedisTemplate
;
@Autowired
ConsumerKylinSqlOrderOvertimeRefundRdsReceiver
consumerKylinSqlOrderOvertimeRefundRdsReceiver
;
@Bean
// 超时支付申请退款
public
List
<
Subscription
>
subscriptionSqlOrderOvertimeRefund
(
RedisConnectionFactory
factory
)
{
List
<
Subscription
>
subscriptionList
=
new
ArrayList
<>();
MQConst
.
KylinQueue
stream
=
MQConst
.
KylinQueue
.
SQL_ORDER_OVERTIME_REFUND
;
this
.
initStream
(
stringRedisTemplate
,
stream
.
getKey
(),
stream
.
getGroup
());
for
(
int
i
=
0
;
i
<
3
;
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
()),
consumerKylinSqlOrderOvertimeRefundRdsReceiver
));
listenerContainer
.
start
();
}
return
subscriptionList
;
}
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/config/kylin/ConsumerKylinSqlOrderPayRedisStreamConfig.java
0 → 100644
View file @
5f77d57d
package
com
.
liquidnet
.
service
.
consumer
.
base
.
config
.
kylin
;
import
com.liquidnet.common.cache.redis.config.RedisStreamConfig
;
import
com.liquidnet.service.base.constant.MQConst
;
import
com.liquidnet.service.consumer.base.receiver.kylin.ConsumerKylinSqlOrderPayRdsReceiver
;
import
lombok.var
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.context.annotation.Bean
;
import
org.springframework.context.annotation.Configuration
;
import
org.springframework.data.redis.connection.RedisConnectionFactory
;
import
org.springframework.data.redis.connection.stream.Consumer
;
import
org.springframework.data.redis.connection.stream.MapRecord
;
import
org.springframework.data.redis.connection.stream.ReadOffset
;
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.Subscription
;
import
java.util.ArrayList
;
import
java.util.List
;
import
static
com
.
liquidnet
.
service
.
base
.
constant
.
MQConst
.
KylinQueue
.
SQL_ORDER_PAY
;
@Configuration
public
class
ConsumerKylinSqlOrderPayRedisStreamConfig
extends
RedisStreamConfig
{
@Autowired
ConsumerKylinSqlOrderPayRdsReceiver
consumerKylinSqlOrderPayRdsReceiver
;
@Autowired
StringRedisTemplate
stringRedisTemplate
;
@Bean
// 超时支付申请退款
public
List
<
Subscription
>
orderPay
(
RedisConnectionFactory
factory
)
{
List
<
Subscription
>
subscriptionList
=
new
ArrayList
<>();
MQConst
.
KylinQueue
stream
=
MQConst
.
KylinQueue
.
SQL_ORDER_PAY
;
this
.
initStream
(
stringRedisTemplate
,
stream
.
getKey
(),
stream
.
getGroup
());
for
(
int
i
=
0
;
i
<
3
;
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
()),
consumerKylinSqlOrderPayRdsReceiver
));
listenerContainer
.
start
();
}
return
subscriptionList
;
}
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/config/kylin/ConsumerKylinSqlOrderRefundRedisStreamConfig.java
0 → 100644
View file @
5f77d57d
package
com
.
liquidnet
.
service
.
consumer
.
base
.
config
.
kylin
;
import
com.liquidnet.common.cache.redis.config.RedisStreamConfig
;
import
com.liquidnet.service.base.constant.MQConst
;
import
com.liquidnet.service.consumer.base.receiver.kylin.ConsumerKylinSqlOrderRefundRdsReceiver
;
import
lombok.var
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.context.annotation.Bean
;
import
org.springframework.context.annotation.Configuration
;
import
org.springframework.data.redis.connection.RedisConnectionFactory
;
import
org.springframework.data.redis.connection.stream.Consumer
;
import
org.springframework.data.redis.connection.stream.MapRecord
;
import
org.springframework.data.redis.connection.stream.ReadOffset
;
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.Subscription
;
import
java.util.ArrayList
;
import
java.util.List
;
import
static
com
.
liquidnet
.
service
.
base
.
constant
.
MQConst
.
KylinQueue
.
SQL_ORDER_REFUND
;
@Configuration
public
class
ConsumerKylinSqlOrderRefundRedisStreamConfig
extends
RedisStreamConfig
{
@Autowired
ConsumerKylinSqlOrderRefundRdsReceiver
consumerKylinSqlOrderRefundRdsReceiver
;
@Autowired
StringRedisTemplate
stringRedisTemplate
;
@Bean
// 超时支付申请退款
public
List
<
Subscription
>
orderRefund
(
RedisConnectionFactory
factory
)
{
List
<
Subscription
>
subscriptionList
=
new
ArrayList
<>();
MQConst
.
KylinQueue
stream
=
MQConst
.
KylinQueue
.
SQL_ORDER_REFUND
;
this
.
initStream
(
stringRedisTemplate
,
stream
.
getKey
(),
stream
.
getGroup
());
for
(
int
i
=
0
;
i
<
3
;
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
()),
consumerKylinSqlOrderRefundRdsReceiver
));
listenerContainer
.
start
();
}
return
subscriptionList
;
}
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/kylin/ConsumerKylinSqlOrderAgainRdsReceiver.java
0 → 100644
View file @
5f77d57d
package
com
.
liquidnet
.
service
.
consumer
.
base
.
receiver
.
kylin
;
import
com.liquidnet.service.base.constant.MQConst
;
import
com.liquidnet.service.consumer.base.receiver.AbstractSqlRedisReceiver
;
import
org.springframework.stereotype.Component
;
@Component
public
class
ConsumerKylinSqlOrderAgainRdsReceiver
extends
AbstractSqlRedisReceiver
{
@Override
protected
String
getRedisStreamKey
()
{
return
MQConst
.
KylinQueue
.
SQL_ORDER_AGAIN
.
getKey
();
}
@Override
protected
String
getRedisStreamGroup
()
{
return
MQConst
.
KylinQueue
.
SQL_ORDER_AGAIN
.
getGroup
();
}
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/kylin/ConsumerKylinSqlOrderCreateRdsReceiver.java
0 → 100644
View file @
5f77d57d
package
com
.
liquidnet
.
service
.
consumer
.
base
.
receiver
.
kylin
;
import
com.liquidnet.service.base.constant.MQConst
;
import
com.liquidnet.service.consumer.base.receiver.AbstractSqlRedisReceiver
;
import
org.springframework.stereotype.Component
;
@Component
public
class
ConsumerKylinSqlOrderCreateRdsReceiver
extends
AbstractSqlRedisReceiver
{
@Override
protected
String
getRedisStreamKey
()
{
return
MQConst
.
KylinQueue
.
SQL_ORDER_CREATE
.
getKey
();
}
@Override
protected
String
getRedisStreamGroup
()
{
return
MQConst
.
KylinQueue
.
SQL_ORDER_CREATE
.
getGroup
();
}
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/kylin/ConsumerKylinSqlOrderOvertimeRefundRdsReceiver.java
0 → 100644
View file @
5f77d57d
package
com
.
liquidnet
.
service
.
consumer
.
base
.
receiver
.
kylin
;
import
com.liquidnet.service.base.constant.MQConst
;
import
com.liquidnet.service.consumer.base.receiver.AbstractSqlRedisReceiver
;
import
org.springframework.stereotype.Component
;
@Component
public
class
ConsumerKylinSqlOrderOvertimeRefundRdsReceiver
extends
AbstractSqlRedisReceiver
{
@Override
protected
String
getRedisStreamKey
()
{
return
MQConst
.
KylinQueue
.
SQL_ORDER_OVERTIME_REFUND
.
getKey
();
}
@Override
protected
String
getRedisStreamGroup
()
{
return
MQConst
.
KylinQueue
.
SQL_ORDER_OVERTIME_REFUND
.
getGroup
();
}
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/kylin/ConsumerKylinSqlOrderPayRdsReceiver.java
0 → 100644
View file @
5f77d57d
package
com
.
liquidnet
.
service
.
consumer
.
base
.
receiver
.
kylin
;
import
com.liquidnet.service.base.constant.MQConst
;
import
com.liquidnet.service.consumer.base.receiver.AbstractSqlRedisReceiver
;
import
org.springframework.stereotype.Component
;
@Component
public
class
ConsumerKylinSqlOrderPayRdsReceiver
extends
AbstractSqlRedisReceiver
{
@Override
protected
String
getRedisStreamKey
()
{
return
MQConst
.
KylinQueue
.
SQL_ORDER_PAY
.
getKey
();
}
@Override
protected
String
getRedisStreamGroup
()
{
return
MQConst
.
KylinQueue
.
SQL_ORDER_PAY
.
getGroup
();
}
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/kylin/ConsumerKylinSqlOrderRefundRdsReceiver.java
0 → 100644
View file @
5f77d57d
package
com
.
liquidnet
.
service
.
consumer
.
base
.
receiver
.
kylin
;
import
com.liquidnet.service.base.constant.MQConst
;
import
com.liquidnet.service.consumer.base.receiver.AbstractSqlRedisReceiver
;
import
org.springframework.stereotype.Component
;
@Component
public
class
ConsumerKylinSqlOrderRefundRdsReceiver
extends
AbstractSqlRedisReceiver
{
@Override
protected
String
getRedisStreamKey
()
{
return
MQConst
.
KylinQueue
.
SQL_ORDER_REFUND
.
getKey
();
}
@Override
protected
String
getRedisStreamGroup
()
{
return
MQConst
.
KylinQueue
.
SQL_ORDER_REFUND
.
getGroup
();
}
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerCommonBizRedisStreamConfig.java
View file @
5f77d57d
package
com
.
liquidnet
.
service
.
consumer
.
kylin
.
config
;
import
com.liquidnet.common.cache.redis.config.RedisStreamConfig
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.context.annotation.Configuration
;
import
org.springframework.data.redis.core.StringRedisTemplate
;
@Configuration
public
class
ConsumerCommonBizRedisStreamConfig
extends
RedisStreamConfig
{
@Autowired
StringRedisTemplate
stringRedisTemplate
;
}
//
package com.liquidnet.service.consumer.kylin.config;
//
//
import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
//
import org.springframework.beans.factory.annotation.Autowired;
//
import org.springframework.context.annotation.Configuration;
//
import org.springframework.data.redis.core.StringRedisTemplate;
//
//
@Configuration
//
public class ConsumerCommonBizRedisStreamConfig extends RedisStreamConfig {
//
@Autowired
//
StringRedisTemplate stringRedisTemplate;
//
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerCommonSqlRedisStreamConfig.java
View file @
5f77d57d
package
com
.
liquidnet
.
service
.
consumer
.
kylin
.
config
;
import
com.liquidnet.common.cache.redis.config.RedisStreamConfig
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.context.annotation.Configuration
;
import
org.springframework.data.redis.core.StringRedisTemplate
;
@Configuration
public
class
ConsumerCommonSqlRedisStreamConfig
extends
RedisStreamConfig
{
@Autowired
StringRedisTemplate
stringRedisTemplate
;
}
//
package com.liquidnet.service.consumer.kylin.config;
//
//
import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
//
import org.springframework.beans.factory.annotation.Autowired;
//
import org.springframework.context.annotation.Configuration;
//
import org.springframework.data.redis.core.StringRedisTemplate;
//
//
@Configuration
//
public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
//
@Autowired
//
StringRedisTemplate stringRedisTemplate;
//
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerKylinSqlOptOrderCloseRedisStreamConfig.java
View file @
5f77d57d
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/config/ConsumerKylinSqlOrderAgainRedisStreamConfig.java
View file @
5f77d57d
package
com
.
liquidnet
.
service
.
consumer
.
kylin
.
config
;
import
com.liquidnet.common.cache.redis.config.RedisStreamConfig
;
import
com.liquidnet.service.base.constant.MQConst
;
import
com.liquidnet.service.consumer.kylin.receiver.ConsumerKylinSqlOrderAgainRdsReceiver
;
import
lombok.var
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.context.annotation.Bean
;
import
org.springframework.context.annotation.Configuration
;
import
org.springframework.data.redis.connection.RedisConnectionFactory
;
import
org.springframework.data.redis.connection.stream.Consumer
;
import
org.springframework.data.redis.connection.stream.MapRecord
;
import
org.springframework.data.redis.connection.stream.ReadOffset
;
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.Subscription
;
import
java.util.ArrayList
;
import
java.util.List
;
import
static
com
.
liquidnet
.
service
.
base
.
constant
.
MQConst
.
KylinQueue
.
SQL_ORDER_AGAIN
;
@Configuration
public
class
ConsumerKylinSqlOrderAgainRedisStreamConfig
extends
RedisStreamConfig
{
@Autowired
StringRedisTemplate
stringRedisTemplate
;
@Autowired
ConsumerKylinSqlOrderAgainRdsReceiver
consumerKylinSqlOrderAgainRdsReceiver
;
// /**
// * 订单再次支付
// *
// * @param listenerContainer
// * @param t
// * @return
// */
// private Subscription receiveSqlOrderAgain(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
// return listenerContainer.receiveAutoAck(Consumer.from(SQL_ORDER_AGAIN.getGroup(), getConsumerName(SQL_ORDER_AGAIN.name() + t)),
// StreamOffset.create(SQL_ORDER_AGAIN.getKey(), ReadOffset.lastConsumed()), consumerKylinSqlOrderAgainRdsReceiver);
// }
//package com.liquidnet.service.consumer.kylin.config;
//
//import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
//import com.liquidnet.service.base.constant.MQConst;
//import com.liquidnet.service.consumer.kylin.receiver.ConsumerKylinSqlOrderAgainRdsReceiver;
//import lombok.var;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.context.annotation.Bean;
//import org.springframework.context.annotation.Configuration;
//import org.springframework.data.redis.connection.RedisConnectionFactory;
//import org.springframework.data.redis.connection.stream.Consumer;
//import org.springframework.data.redis.connection.stream.MapRecord;
//import org.springframework.data.redis.connection.stream.ReadOffset;
//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.Subscription;
//
//import java.util.ArrayList;
//import java.util.List;
//
//import static com.liquidnet.service.base.constant.MQConst.KylinQueue.SQL_ORDER_AGAIN;
//
//@Configuration
//public class ConsumerKylinSqlOrderAgainRedisStreamConfig extends RedisStreamConfig {
// @Autowired
// StringRedisTemplate stringRedisTemplate;
// @Autowired
// ConsumerKylinSqlOrderAgainRdsReceiver consumerKylinSqlOrderAgainRdsReceiver;
//
// /* —————————————————————————— | —————————————————————————— | —————————————————————————— */
//// /**
//// * 订单再次支付
//// *
//// * @param listenerContainer
//// * @param t
//// * @return
//// */
//// private Subscription receiveSqlOrderAgain(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
//// return listenerContainer.receiveAutoAck(Consumer.from(SQL_ORDER_AGAIN.getGroup(), getConsumerName(SQL_ORDER_AGAIN.name() + t)),
//// StreamOffset.create(SQL_ORDER_AGAIN.getKey(), ReadOffset.lastConsumed()), consumerKylinSqlOrderAgainRdsReceiver);
//// }
////
//// /* —————————————————————————— | —————————————————————————— | —————————————————————————— */
////
//// /* -------------------------------------------------------- | 订单再次支付 */
////
//// @Bean
//// public Subscription subscriptionSqlOrderAgain0(RedisConnectionFactory factory) {
//// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
//// var subscription = receiveSqlOrderAgain(listenerContainer, 0);
//// listenerContainer.start();
//// return subscription;
//// }
//
// /* -------------------------------------------------------- |
订单再次支付
*/
// /* -------------------------------------------------------- | */
//
// @Bean
// public Subscription subscriptionSqlOrderAgain0(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
// var subscription = receiveSqlOrderAgain(listenerContainer, 0);
// listenerContainer.start();
// return subscription;
// @Bean// 订单再次支付
// public List<Subscription> subscriptionSqlOrderAgain(RedisConnectionFactory factory) {
// List<Subscription> subscriptionList = new ArrayList<>();
// MQConst.KylinQueue stream = MQConst.KylinQueue.SQL_ORDER_AGAIN;
// this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
// for (int i = 0; i < 3; 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()), consumerKylinSqlOrderAgainRdsReceiver
// ));
// listenerContainer.start();
// }
// return subscriptionList;
// }
/* -------------------------------------------------------- | */
@Bean
// 订单再次支付
public
List
<
Subscription
>
subscriptionSqlOrderAgain
(
RedisConnectionFactory
factory
)
{
List
<
Subscription
>
subscriptionList
=
new
ArrayList
<>();
MQConst
.
KylinQueue
stream
=
MQConst
.
KylinQueue
.
SQL_ORDER_AGAIN
;
this
.
initStream
(
stringRedisTemplate
,
stream
.
getKey
(),
stream
.
getGroup
());
for
(
int
i
=
0
;
i
<
3
;
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
()),
consumerKylinSqlOrderAgainRdsReceiver
));
listenerContainer
.
start
();
}
return
subscriptionList
;
}
}
//}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerKylinSqlOrderCreateRedisStreamConfig.java
View file @
5f77d57d
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/config/ConsumerKylinSqlOrderOvertimeRefundRedisStreamConfig.java
View file @
5f77d57d
package
com
.
liquidnet
.
service
.
consumer
.
kylin
.
config
;
import
com.liquidnet.common.cache.redis.config.RedisStreamConfig
;
import
com.liquidnet.service.base.constant.MQConst
;
import
com.liquidnet.service.consumer.kylin.receiver.ConsumerKylinSqlOrderOvertimeRefundRdsReceiver
;
import
lombok.var
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.context.annotation.Bean
;
import
org.springframework.context.annotation.Configuration
;
import
org.springframework.data.redis.connection.RedisConnectionFactory
;
import
org.springframework.data.redis.connection.stream.Consumer
;
import
org.springframework.data.redis.connection.stream.MapRecord
;
import
org.springframework.data.redis.connection.stream.ReadOffset
;
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.Subscription
;
import
java.util.ArrayList
;
import
java.util.List
;
import
static
com
.
liquidnet
.
service
.
base
.
constant
.
MQConst
.
KylinQueue
.
SQL_ORDER_OVERTIME_REFUND
;
@Configuration
public
class
ConsumerKylinSqlOrderOvertimeRefundRedisStreamConfig
extends
RedisStreamConfig
{
@Autowired
StringRedisTemplate
stringRedisTemplate
;
@Autowired
ConsumerKylinSqlOrderOvertimeRefundRdsReceiver
consumerKylinSqlOrderOvertimeRefundRdsReceiver
;
// /**
// * 超时支付申请退款
// *
// * @param listenerContainer
// * @param t
// * @return
// */
// private Subscription receiveSqlOrderOvertimeRefund(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
// return listenerContainer.receiveAutoAck(Consumer.from(SQL_ORDER_OVERTIME_REFUND.getGroup(), getConsumerName(SQL_ORDER_OVERTIME_REFUND.name() + t)),
// StreamOffset.create(SQL_ORDER_OVERTIME_REFUND.getKey(), ReadOffset.lastConsumed()), consumerKylinSqlOrderOvertimeRefundRdsReceiver);
// }
//package com.liquidnet.service.consumer.kylin.config;
//
//import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
//import com.liquidnet.service.base.constant.MQConst;
//import com.liquidnet.service.consumer.kylin.receiver.ConsumerKylinSqlOrderOvertimeRefundRdsReceiver;
//import lombok.var;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.context.annotation.Bean;
//import org.springframework.context.annotation.Configuration;
//import org.springframework.data.redis.connection.RedisConnectionFactory;
//import org.springframework.data.redis.connection.stream.Consumer;
//import org.springframework.data.redis.connection.stream.MapRecord;
//import org.springframework.data.redis.connection.stream.ReadOffset;
//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.Subscription;
//
//import java.util.ArrayList;
//import java.util.List;
//
//import static com.liquidnet.service.base.constant.MQConst.KylinQueue.SQL_ORDER_OVERTIME_REFUND;
//
//@Configuration
//public class ConsumerKylinSqlOrderOvertimeRefundRedisStreamConfig extends RedisStreamConfig {
// @Autowired
// StringRedisTemplate stringRedisTemplate;
// @Autowired
// ConsumerKylinSqlOrderOvertimeRefundRdsReceiver consumerKylinSqlOrderOvertimeRefundRdsReceiver;
//
// /* —————————————————————————— | —————————————————————————— | —————————————————————————— */
//// /**
//// * 超时支付申请退款
//// *
//// * @param listenerContainer
//// * @param t
//// * @return
//// */
//// private Subscription receiveSqlOrderOvertimeRefund(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
//// return listenerContainer.receiveAutoAck(Consumer.from(SQL_ORDER_OVERTIME_REFUND.getGroup(), getConsumerName(SQL_ORDER_OVERTIME_REFUND.name() + t)),
//// StreamOffset.create(SQL_ORDER_OVERTIME_REFUND.getKey(), ReadOffset.lastConsumed()), consumerKylinSqlOrderOvertimeRefundRdsReceiver);
//// }
////
//// /* —————————————————————————— | —————————————————————————— | —————————————————————————— */
////
//// /* -------------------------------------------------------- | 超时支付申请退款 */
////
//// @Bean
//// public Subscription subscriptionSqlOrderOvertimeRefund0(RedisConnectionFactory factory) {
//// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
//// var subscription = receiveSqlOrderOvertimeRefund(listenerContainer, 0);
//// listenerContainer.start();
//// return subscription;
//// }
//
// /* -------------------------------------------------------- |
超时支付申请退款
*/
// /* -------------------------------------------------------- | */
//
// @Bean
// public Subscription subscriptionSqlOrderOvertimeRefund0(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
// var subscription = receiveSqlOrderOvertimeRefund(listenerContainer, 0);
// listenerContainer.start();
// return subscription;
// @Bean// 超时支付申请退款
// public List<Subscription> subscriptionSqlOrderOvertimeRefund(RedisConnectionFactory factory) {
// List<Subscription> subscriptionList = new ArrayList<>();
// MQConst.KylinQueue stream = MQConst.KylinQueue.SQL_ORDER_OVERTIME_REFUND;
// this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
// for (int i = 0; i < 3; 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()), consumerKylinSqlOrderOvertimeRefundRdsReceiver
// ));
// listenerContainer.start();
// }
// return subscriptionList;
// }
/* -------------------------------------------------------- | */
@Bean
// 超时支付申请退款
public
List
<
Subscription
>
subscriptionSqlOrderOvertimeRefund
(
RedisConnectionFactory
factory
)
{
List
<
Subscription
>
subscriptionList
=
new
ArrayList
<>();
MQConst
.
KylinQueue
stream
=
MQConst
.
KylinQueue
.
SQL_ORDER_OVERTIME_REFUND
;
this
.
initStream
(
stringRedisTemplate
,
stream
.
getKey
(),
stream
.
getGroup
());
for
(
int
i
=
0
;
i
<
3
;
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
()),
consumerKylinSqlOrderOvertimeRefundRdsReceiver
));
listenerContainer
.
start
();
}
return
subscriptionList
;
}
}
//}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerKylinSqlOrderPayRedisStreamConfig.java
View file @
5f77d57d
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/config/ConsumerKylinSqlOrderRefundRedisStreamConfig.java
View file @
5f77d57d
package
com
.
liquidnet
.
service
.
consumer
.
kylin
.
config
;
import
com.liquidnet.common.cache.redis.config.RedisStreamConfig
;
import
com.liquidnet.service.consumer.kylin.receiver.ConsumerKylinSqlOrderRefundRdsReceiver
;
import
lombok.var
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.context.annotation.Bean
;
import
org.springframework.context.annotation.Configuration
;
import
org.springframework.data.redis.connection.RedisConnectionFactory
;
import
org.springframework.data.redis.connection.stream.Consumer
;
import
org.springframework.data.redis.connection.stream.MapRecord
;
import
org.springframework.data.redis.connection.stream.ReadOffset
;
import
org.springframework.data.redis.connection.stream.StreamOffset
;
import
org.springframework.data.redis.stream.StreamMessageListenerContainer
;
import
org.springframework.data.redis.stream.Subscription
;
import
static
com
.
liquidnet
.
service
.
base
.
constant
.
MQConst
.
KylinQueue
.
SQL_ORDER_REFUND
;
@Configuration
public
class
ConsumerKylinSqlOrderRefundRedisStreamConfig
extends
RedisStreamConfig
{
@Autowired
ConsumerKylinSqlOrderRefundRdsReceiver
consumerKylinSqlOrderRefundRdsReceiver
;
/**
* 订单申请退款
*
* @param listenerContainer
* @param t
* @return
*/
private
Subscription
receiveSqlOrderRefund
(
StreamMessageListenerContainer
<
String
,
MapRecord
<
String
,
String
,
String
>>
listenerContainer
,
int
t
)
{
return
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
SQL_ORDER_REFUND
.
getGroup
(),
getConsumerName
(
SQL_ORDER_REFUND
.
name
()
+
t
)),
StreamOffset
.
create
(
SQL_ORDER_REFUND
.
getKey
(),
ReadOffset
.
lastConsumed
()),
consumerKylinSqlOrderRefundRdsReceiver
);
}
/* —————————————————————————— | —————————————————————————— | —————————————————————————— */
/* -------------------------------------------------------- | 订单申请退款 */
@Bean
public
Subscription
subscriptionSqlOrderRefund0
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
receiveSqlOrderRefund
(
listenerContainer
,
0
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionSqlOrderRefund1
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
receiveSqlOrderRefund
(
listenerContainer
,
1
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionSqlOrderRefund2
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
receiveSqlOrderRefund
(
listenerContainer
,
2
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionSqlOrderRefund3
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
receiveSqlOrderRefund
(
listenerContainer
,
3
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionSqlOrderRefund4
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
receiveSqlOrderRefund
(
listenerContainer
,
4
);
listenerContainer
.
start
();
return
subscription
;
}
/* -------------------------------------------------------- | */
}
//
package com.liquidnet.service.consumer.kylin.config;
//
//
import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
//
import com.liquidnet.service.consumer.kylin.receiver.ConsumerKylinSqlOrderRefundRdsReceiver;
//
import lombok.var;
//
import org.springframework.beans.factory.annotation.Autowired;
//
import org.springframework.context.annotation.Bean;
//
import org.springframework.context.annotation.Configuration;
//
import org.springframework.data.redis.connection.RedisConnectionFactory;
//
import org.springframework.data.redis.connection.stream.Consumer;
//
import org.springframework.data.redis.connection.stream.MapRecord;
//
import org.springframework.data.redis.connection.stream.ReadOffset;
//
import org.springframework.data.redis.connection.stream.StreamOffset;
//
import org.springframework.data.redis.stream.StreamMessageListenerContainer;
//
import org.springframework.data.redis.stream.Subscription;
//
//
import static com.liquidnet.service.base.constant.MQConst.KylinQueue.SQL_ORDER_REFUND;
//
//
@Configuration
//
public class ConsumerKylinSqlOrderRefundRedisStreamConfig extends RedisStreamConfig {
//
@Autowired
//
ConsumerKylinSqlOrderRefundRdsReceiver consumerKylinSqlOrderRefundRdsReceiver;
//
//
/**
//
* 订单申请退款
//
*
//
* @param listenerContainer
//
* @param t
//
* @return
//
*/
//
private Subscription receiveSqlOrderRefund(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
//
return listenerContainer.receiveAutoAck(Consumer.from(SQL_ORDER_REFUND.getGroup(), getConsumerName(SQL_ORDER_REFUND.name() + t)),
//
StreamOffset.create(SQL_ORDER_REFUND.getKey(), ReadOffset.lastConsumed()), consumerKylinSqlOrderRefundRdsReceiver);
//
}
//
//
/* —————————————————————————— | —————————————————————————— | —————————————————————————— */
//
//
/* -------------------------------------------------------- | 订单申请退款 */
//
//
@Bean
//
public Subscription subscriptionSqlOrderRefund0(RedisConnectionFactory factory) {
//
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
//
var subscription = receiveSqlOrderRefund(listenerContainer, 0);
//
listenerContainer.start();
//
return subscription;
//
}
//
//
@Bean
//
public Subscription subscriptionSqlOrderRefund1(RedisConnectionFactory factory) {
//
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
//
var subscription = receiveSqlOrderRefund(listenerContainer, 1);
//
listenerContainer.start();
//
return subscription;
//
}
//
//
@Bean
//
public Subscription subscriptionSqlOrderRefund2(RedisConnectionFactory factory) {
//
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
//
var subscription = receiveSqlOrderRefund(listenerContainer, 2);
//
listenerContainer.start();
//
return subscription;
//
}
//
//
@Bean
//
public Subscription subscriptionSqlOrderRefund3(RedisConnectionFactory factory) {
//
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
//
var subscription = receiveSqlOrderRefund(listenerContainer, 3);
//
listenerContainer.start();
//
return subscription;
//
}
//
//
@Bean
//
public Subscription subscriptionSqlOrderRefund4(RedisConnectionFactory factory) {
//
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
//
var subscription = receiveSqlOrderRefund(listenerContainer, 4);
//
listenerContainer.start();
//
return subscription;
//
}
//
//
/* -------------------------------------------------------- | */
//
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerKylinSqlOrderCreateRdsReceiver.java
View file @
5f77d57d
package
com
.
liquidnet
.
service
.
consumer
.
kylin
.
receiver
;
import
com.liquidnet.service.base.constant.MQConst
;
import
org.springframework.stereotype.Component
;
@Component
public
class
ConsumerKylinSqlOrderCreateRdsReceiver
extends
AbstractSqlRedisReceiver
{
@Override
protected
String
getRedisStreamKey
()
{
return
MQConst
.
KylinQueue
.
SQL_ORDER_CREATE
.
getKey
();
}
@Override
protected
String
getRedisStreamGroup
()
{
return
MQConst
.
KylinQueue
.
SQL_ORDER_CREATE
.
getGroup
();
}
}
//
package com.liquidnet.service.consumer.kylin.receiver;
//
//
import com.liquidnet.service.base.constant.MQConst;
//
import org.springframework.stereotype.Component;
//
//
@Component
//
public class ConsumerKylinSqlOrderCreateRdsReceiver extends AbstractSqlRedisReceiver {
//
@Override
//
protected String getRedisStreamKey() {
//
return MQConst.KylinQueue.SQL_ORDER_CREATE.getKey();
//
}
//
//
@Override
//
protected String getRedisStreamGroup() {
//
return MQConst.KylinQueue.SQL_ORDER_CREATE.getGroup();
//
}
//
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerKylinSqlOrderOvertimeRefundRdsReceiver.java
View file @
5f77d57d
package
com
.
liquidnet
.
service
.
consumer
.
kylin
.
receiver
;
import
com.liquidnet.service.base.constant.MQConst
;
import
org.springframework.stereotype.Component
;
@Component
public
class
ConsumerKylinSqlOrderOvertimeRefundRdsReceiver
extends
AbstractSqlRedisReceiver
{
@Override
protected
String
getRedisStreamKey
()
{
return
MQConst
.
KylinQueue
.
SQL_ORDER_OVERTIME_REFUND
.
getKey
();
}
@Override
protected
String
getRedisStreamGroup
()
{
return
MQConst
.
KylinQueue
.
SQL_ORDER_OVERTIME_REFUND
.
getGroup
();
}
}
//
package com.liquidnet.service.consumer.kylin.receiver;
//
//
import com.liquidnet.service.base.constant.MQConst;
//
import org.springframework.stereotype.Component;
//
//
@Component
//
public class ConsumerKylinSqlOrderOvertimeRefundRdsReceiver extends AbstractSqlRedisReceiver {
//
@Override
//
protected String getRedisStreamKey() {
//
return MQConst.KylinQueue.SQL_ORDER_OVERTIME_REFUND.getKey();
//
}
//
//
@Override
//
protected String getRedisStreamGroup() {
//
return MQConst.KylinQueue.SQL_ORDER_OVERTIME_REFUND.getGroup();
//
}
//
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerKylinSqlOrderPayRdsReceiver.java
View file @
5f77d57d
package
com
.
liquidnet
.
service
.
consumer
.
kylin
.
receiver
;
import
com.liquidnet.service.base.constant.MQConst
;
import
org.springframework.stereotype.Component
;
@Component
public
class
ConsumerKylinSqlOrderPayRdsReceiver
extends
AbstractSqlRedisReceiver
{
@Override
protected
String
getRedisStreamKey
()
{
return
MQConst
.
KylinQueue
.
SQL_ORDER_PAY
.
getKey
();
}
@Override
protected
String
getRedisStreamGroup
()
{
return
MQConst
.
KylinQueue
.
SQL_ORDER_PAY
.
getGroup
();
}
}
//
package com.liquidnet.service.consumer.kylin.receiver;
//
//
import com.liquidnet.service.base.constant.MQConst;
//
import org.springframework.stereotype.Component;
//
//
@Component
//
public class ConsumerKylinSqlOrderPayRdsReceiver extends AbstractSqlRedisReceiver {
//
@Override
//
protected String getRedisStreamKey() {
//
return MQConst.KylinQueue.SQL_ORDER_PAY.getKey();
//
}
//
//
@Override
//
protected String getRedisStreamGroup() {
//
return MQConst.KylinQueue.SQL_ORDER_PAY.getGroup();
//
}
//
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerKylinSqlOrderRefundRdsReceiver.java
View file @
5f77d57d
package
com
.
liquidnet
.
service
.
consumer
.
kylin
.
receiver
;
import
com.liquidnet.service.base.constant.MQConst
;
import
org.springframework.stereotype.Component
;
@Component
public
class
ConsumerKylinSqlOrderRefundRdsReceiver
extends
AbstractSqlRedisReceiver
{
@Override
protected
String
getRedisStreamKey
()
{
return
MQConst
.
KylinQueue
.
SQL_ORDER_REFUND
.
getKey
();
}
@Override
protected
String
getRedisStreamGroup
()
{
return
MQConst
.
KylinQueue
.
SQL_ORDER_REFUND
.
getGroup
();
}
}
//
package com.liquidnet.service.consumer.kylin.receiver;
//
//
import com.liquidnet.service.base.constant.MQConst;
//
import org.springframework.stereotype.Component;
//
//
@Component
//
public class ConsumerKylinSqlOrderRefundRdsReceiver extends AbstractSqlRedisReceiver {
//
@Override
//
protected String getRedisStreamKey() {
//
return MQConst.KylinQueue.SQL_ORDER_REFUND.getKey();
//
}
//
//
@Override
//
protected String getRedisStreamGroup() {
//
return MQConst.KylinQueue.SQL_ORDER_REFUND.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