README-zh_CN.md

Shine-mq

English | 简体中文

🐣 Features

• 无缝集成 spring-boot-starter
• 封装mq的操作，方便使用
• 实现基于可靠消息服务的分布式事务（采用AOP思想与Spring无缝集成，通过注解就可使用)
• 分布式事务支持异常回滚
• 可靠消息默认存储方式：redis (可自行实现)
• 目前消息中间件支持 : rabbitmq

🐳 Maven

<dependency>
    <groupId>top.arkstack</groupId>
    <artifactId>shine-mq</artifactId>
    <version>2.2.1</version>
</dependency>

🎀 Distributed transaction

🎐 博客

分布式事务：基于可靠消息服务

分布式事务：消息可靠发送

🐹 Demo

Demo戳 shine-mq-demo

🌈 Configuration

分布式事务的配置，具体可配置的参数如下：

    /**
     * 是否初始化 开启分布式事务 缺省为false
     */
    private boolean transaction = false;

    /**
     * 提交ack 失败最大重试次数
     */
     
    private Integer commitMaxRetries = 3;

    /**
     * 接收消息 ack 失败最大尝试次数
     */
    private Integer receiveMaxRetries = 3;

    /**
     * 默认提供redis中间件来实现消息提交到mq之前的持久化
     *
     * 也可以自己实现 {@link top.arkstack.shine.mq.coordinator.Coordinator}
     * 或者不想用redis，可以设置为false，就不会有redis的依赖
     */
    private boolean redisPersistence = true;
    
    /**
     * redis缓存前缀
     */
    private String redisPrefix = "";
    
    /**
     * Prepare和Ready状态消息超时时间 默认为3分钟
     * 单位为秒
     */
    private long timeOut = 3 * 60;

    /**
     * returnCallback的状态过期时间 默认为1天
     * 单位为秒
     */
    private long returnCallbackTTL = 24 * 60 * 60;

封装mq的操作，具体可配置的参数如下：

    /**
     * 是否初始化消息监听者， 若服务只是Producer则关闭
     */
    private boolean listenerEnable = false;
    
    /**
     * {@link org.springframework.amqp.core.AcknowledgeMode}
     * <p>
     * 0 AUTO
     * 1 MANUAL
     * 2 NONE
     */
    private int acknowledgeMode = 1;

    /**
     * 每个消费者可能未完成的未确认消息的数量。
     */
    private Integer prefetchCount = null;

    /**
     * 为每个已配置队列创建的消费者数
     */
    private Integer consumersPerQueue = null;

    /**
     * 是否持久化，指是否保存到erlang自带得数据库mnesia中，即重启服务是否消失
     */
    private boolean durable = true;

    /**
     * 是否排外，指当前定义的队列是connection中的channel共享的，其他connection连接访问不到
     */
    private boolean exclusive = false;

    /**
     * 是否自动删除，指当connection.close时队列删除
     */
    private boolean autoDelete = false;

    /**
     * 是否初始化消息监听者， 若服务只是Producer则关闭
     */
    private boolean listenerEnable = false;

    /**
     * 通道缓存
     */
    private Integer channelCacheSize = null;

仓库镜像

• 码云Shine-mq

End

如果对你有帮助，那就帮忙点个星星把 ^.^