8000 GitHub - yilu-tech/YiMQ: YiMQ is an easy-to-use open source distributed transaction solution.
[go: up one dir, main page]
More Web Proxy on the site http://driver.im/
Skip to content

yilu-tech/YiMQ

Repository files navigation

#YiMQ

###事务类型

  1. EC (eventually consistent)
  2. TCC (try confirm cancel)
  3. XA

###环境变量

  1. CONFIG_DIR_PATH (配置文件路径)
  2. TRANSACATION_MESSAGE_JOB_DELAY (message job 默认等待时间 )
  3. SUBTASK_JOB_DELAY (subtask job 延迟时间 )
  4. SUBTASK_JOB_BACKOFF_DELAY (subtask job重试延迟时间 )

##命令

  1. yimq reload [actor_name]/--all
  2. yimq pause
  3. yimq resume

##管理接口

  1. /admin 获取各种基础信息

     response
     {
         "version": "0.1.9",
         "master_redis": {},
         "servers": [],
         "actors": []
     }
    
  2. /admin/reload (重新加载配置文件)

  3. /actor/clearfailed (获取清理失败的message和process)

    query:

     {
         actor_id: 1 //为空的情况下,返回所有actor的错误message和process_ids
     }
    
  4. /admin/actor/clearfailed/retry (重试清理错误)

    body:

     {
    
         "actor_id":20,
         "message_ids": "*",
         "process_ids": "*"
     }
    
     {
    
         "actor_id":20,
         "message_ids": [1,2],
         "process_ids": [2,3]
     }
    
  5. /admin/actor/jobs

    query:

    actor_id:1 status: 'completed,waiting,active,delayed,failed,paused', start:0 size:2 sort: asc|desc

  6. /admin/actor/status

    query:

     {
         actor_id: 1
     }
    
  7. /admin/actor/job

    query { actor_id: 1, job_id: 38 }

  8. /admin/message

    query { actor_id: 1, message_id: 38 }

  9. /admin/actor/job/retry

    body

    { "actor_id":1, "job_ids": "*" }

  10. /admin/messages

    query

    actor_id:1 start:0 size:1 sort:asc topic:user.create status: CANCELED,CANCELLING,DOING,DONE,PENDING clear_status: WAITING|FAILED message_id:23 subtask_id:25 job_id:2180

boostrap流程

reload流程

shutdown流程

License

Apache License, Version 2.0 Copyright (C) Apache Software Foundation

About

YiMQ is an easy-to-use open source distributed transaction solution.

Resources

Stars

Watchers

Forks

Packages

No packages published

Languages

0