rabbitmq相关需求

未分类

1.数据库消费者

负责从rabbitmq的某个queue中拿取消息，并写入mysql数据库。rabbitmq地址，queue名，数据库可配置。

2.转发消费者

负责从rabbitmq的某个queue中拿取JSON格式的消息，并转发给另外一个rabbitmq。rabbitmq地址，queue名可配置。

关于消费者的需求，每个消费者至少和rabbitmq保持一个长连接，且能够处理mq连接的断线，自动重连；能够在出现消费错误的情况时让消息重新进入消息队列；消费者支持水平拓展。

消息有两种:

策略目标持仓信号

public class StrategyPositionSignal extends BaseData {
    private int supplierID; // 供应商ID
    private long strategyID; // 策略ID
    private String exchange = ""; // 交易所
    private String symbol = ""; // 市场标的
    private int position; // 目标持仓，正为多头，负为空头
    private double price; // 建议建仓价格，对市价单为0.0
    private String CreateTime = ""; // 建仓时间，格式"YYYYMMDDTHHMMSS"
    private String ExpireTime = ""; // 信号过期时间，格式为"YYYYMMDDTHHMMSS"
}

策略订单信号

public class StrategyOrderSignal extends BaseData{
    private int supplierID; // 供应商ID
    private long strategyID; // 策略ID
    private String exchange = ""; // 交易所
    private String symbol = ""; // 市场标的
    private int action; // 买卖方向
    private int orderCtg; // 订单类型
    private int offsetFlag; // 开平标记
    private int volume; // 交易手数
    private double price; // 报单价格，对市价单为0.0
    private String orderTime = ""; // 报单时间,格式"YYYYMMDDTHHMMSS"
}