记得上下班打卡 | 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
07ec3da0
Commit
07ec3da0
authored
May 11, 2022
by
zhanggb
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
~consumer-order:queue.listener;
parent
69b979a8
Changes
4
Expand all
Hide whitespace changes
Inline
Side-by-side
Showing
4 changed files
with
274 additions
and
274 deletions
+274
-274
ConsumerKylinSqlOptOrderCloseRedisStreamConfig.java
...onfig/ConsumerKylinSqlOptOrderCloseRedisStreamConfig.java
+122
-122
ConsumerKylinSqlOrderAgainRedisStreamConfig.java
...r/config/ConsumerKylinSqlOrderAgainRedisStreamConfig.java
+49
-49
ConsumerKylinSqlOrderPayRedisStreamConfig.java
...der/config/ConsumerKylinSqlOrderPayRedisStreamConfig.java
+102
-102
ConsumerKylinSqlPerformanceLackRedisStreamConfig.java
...fig/ConsumerKylinSqlPerformanceLackRedisStreamConfig.java
+1
-1
No files found.
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-order/src/main/java/com/liquidnet/service/consumer/order/config/ConsumerKylinSqlOptOrderCloseRedisStreamConfig.java
View file @
07ec3da0
This diff is collapsed.
Click to expand it.
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-order/src/main/java/com/liquidnet/service/consumer/order/config/ConsumerKylinSqlOrderAgainRedisStreamConfig.java
View file @
07ec3da0
package
com
.
liquidnet
.
service
.
consumer
.
order
.
config
;
import
com.liquidnet.common.cache.redis.config.RedisStreamConfig
;
import
com.liquidnet.service.consumer.order.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.stream.StreamMessageListenerContainer
;
import
org.springframework.data.redis.stream.Subscription
;
import
static
com
.
liquidnet
.
service
.
base
.
constant
.
MQConst
.
KylinQueue
.
SQL_ORDER_AGAIN
;
@Configuration
public
class
ConsumerKylinSqlOrderAgainRedisStreamConfig
extends
RedisStreamConfig
{
@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
;
}
/* -------------------------------------------------------- | */
}
//
package com.liquidnet.service.consumer.order.config;
//
//
import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
//
import com.liquidnet.service.consumer.order.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.stream.StreamMessageListenerContainer;
//
import org.springframework.data.redis.stream.Subscription;
//
//
import static com.liquidnet.service.base.constant.MQConst.KylinQueue.SQL_ORDER_AGAIN;
//
//
@Configuration
//
public class ConsumerKylinSqlOrderAgainRedisStreamConfig extends RedisStreamConfig {
//
@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;
//
}
//
//
/* -------------------------------------------------------- | */
//
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-order/src/main/java/com/liquidnet/service/consumer/order/config/ConsumerKylinSqlOrderPayRedisStreamConfig.java
View file @
07ec3da0
This diff is collapsed.
Click to expand it.
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-order/src/main/java/com/liquidnet/service/consumer/order/config/ConsumerKylinSqlPerformanceLackRedisStreamConfig.java
View file @
07ec3da0
...
...
@@ -60,7 +60,7 @@ public class ConsumerKylinSqlPerformanceLackRedisStreamConfig extends RedisStrea
List
<
Subscription
>
subscriptionList
=
new
ArrayList
<>();
MQConst
.
KylinQueue
stream
=
MQConst
.
KylinQueue
.
SQL_PERFORMANCE_LACK
;
this
.
initStream
(
stringRedisTemplate
,
stream
.
getKey
(),
stream
.
getGroup
());
for
(
int
i
=
0
;
i
<
50
;
i
++)
{
for
(
int
i
=
0
;
i
<
1
;
i
++)
{
StreamMessageListenerContainer
<
String
,
MapRecord
<
String
,
String
,
String
>>
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
subscriptionList
.
add
(
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
stream
.
getGroup
(),
getConsumerName
(
stream
.
name
()
+
i
)),
...
...
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