website·Indexed 30 days ago
https://guoshiqiufeng.github.io/loki-doc/A simplified enhancement tool for Message Queues (MQ) designed to improve development efficiency. LOKI provides a non-intrusive way to consume and send messages via annotations, supports multiple MQ types, and integrates with Spring Boot 2.x and 3.x based on JDK8. Key features include auto and non-auto decoding, LokiClient for sending messages, BaseMapper support, and interceptors for outgoing and listening messages using the PipelineProcess interface.
LOKI is a tool designed to simplify the use of Message Queues (MQ) and improve development efficiency. Its core value propositions include:
PipelineProcess interface and specify the generic type as ProducerRecordModel. The process method is where the interception logic is implemented, receiving a PipelineContext containing the message model.@Slf4j
@Component
public class SendInterceptor implements PipelineProcess<ProducerRecordModel> {
@Override
public void process(PipelineContext<ProducerRecordModel> context) {
log.debug("SendInterceptor context:{}", context);
}
}PipelineProcess interface.support method in your PipelineProcess implementation. Return true if the interceptor should process the message, and false otherwise.@Slf4j
@Component
public class SendInterceptor implements PipelineProcess<ProducerRecordModel> {
@Override
public boolean support(PipelineContext<ProducerRecordModel> context) {
// Only intercept messages for the 'loki' topic
return "loki".equals(context.getModel().getTopic());
}
@Override
public void process(PipelineContext<ProducerRecordModel> context) {
log.debug("SendInterceptor context:{}", context);
}
}PipelineProcess interface and specify ConsumerRecordModel as the generic type. The process method is where the interception logic is implemented, receiving a PipelineContext containing the record model.@Slf4j
@Component
public class ListenerInterceptor implements PipelineProcess<ConsumerRecordModel> {
@Override
public void process(PipelineContext<ConsumerRecordModel> context) {
log.debug("ListenerInterceptor context:{}", context);
}
}loki-spring-boot-starter-rocketmq-remoting artifact for projects requiring support for RocketMQ 4.X and 5.X using the Remoting protocol.<dependency>
<groupId>com.github.guoshiqiufeng</groupId>
<artifactId>loki-spring-boot-starter-rocketmq-remoting</artifactId>
<version>1.2.1</version>
</dependency>implementation 'com.github.guoshiqiufeng:loki-spring-boot-starter-rocketmq-remoting:1.2.1'Listener<T> interface. The generic type T used in the Listener implementation must be annotated with @MessageName, which contains the subscription information required to route messages to the listener.@Slf4j
@Component
public class TestListener implements Listener<TestEntity> {
@Override
public void onMessage(MessageContent<TestEntity> entity) {
log.info("entity:{}", entity);
}
}loki-spring-boot-starter dependency to your Spring Boot project (supports versions 2.x and 3.x).<!-- Maven -->
<dependency>
<groupId>com.github.guoshiqiufeng</groupId>
<artifactId>loki-spring-boot-starter</artifactId>
<version>1.2.1</version>
</dependency>// Gradle
implementation 'com.github.guoshiqiufeng:loki-spring-boot-starter:1.2.1'loki-spring-boot-starter-rocketmq artifact for projects requiring support for RocketMQ 5.X via gRPC.<dependency>
<groupId>com.github.guoshiqiufeng</groupId>
<artifactId>loki-spring-boot-starter-rocketmq</artifactId>
<version>1.2.1</version>
</dependency>implementation 'com.github.guoshiqiufeng:loki-spring-boot-starter-rocketmq:1.2.1'PipelineProcess interface.