Rails 做了好久的 Rails 代码迁移至 Go,顺便开源一个 Go 版的 SneakerWorker

oldfritter · January 17, 2020 · 2793 hits

SneakerWorker for Golang

Dependencies 依赖

  • RabbitMQ

Usage 使用方法

1.在你的项目中的 config 目录下创建以下两个文件

amqp.yml
workers.yml

This is a example.

2.workers

example 示例

3.main

example 示例

workers.yml 配置说明

---
- name: TreatWorker  # worker的名称
  exchange: sneaker.example.default  # 消息经过的Exchange
  routing_key: sneaker.example.treat  # 消息经过的routing_key
  queue: sneaker.example.treat  # 消息进入的queue
  durable: true
  ack: true  # 是否ack
  threads: 1  # 并发处理数量
  steps:  # 重试队列的延时配置
    - 5000       # 5 Second
    - 30000      # 30 Second
    - 60000      # 1 Minute
No Reply at the moment.
You need to Sign in before reply, if you don't have an account, please Sign up first.