一、什么是做市策略 做市策略（market-maker strategy）是一种风险中立（risk-neutral）盘口价差套利策略。其基本原理是：在盘口的卖一和买一价之间，插入委买单和委卖单，如果插入的两个单子都成交的话，做市商就吃到了买卖单之间的价差，而整个过程结束后，做市商所持有的头寸并没有变化。如果买卖单之间的价差扣除各种交易手续费之后还有盈余，那么该做市商就获得了相应的盈利。 做市策略是一种增加交易所流动性的策略，一般来讲，成熟的交易市场为了提升自身的流动性，会用低佣金（甚至为做市商提供流动性奖励金）的办法，吸引做市商来该市场做市。 二、做市策略需要注意的事项 1 做市时机的选择。做市商本质上是整个市场的交易对手方。如果市场呈现急剧的单边行情，做市商下达的买卖委托单会大概率出现单边成交的情况，因此做市商手中就会积累大量的风险头寸，这是做市商不想承担的风险。因此，做市商在选择是否下达做市指令之前，都会预判一下市场的趋势明显程度，如果市场短期内呈现非常明显的趋势信号，做市商就会相应地减少自己的做市单数量（甚至停止做市） 2 净头寸的处理。做市商手中累计的净头寸，可以通过很多种办法来处理，下面列举其中两种： （1）在下一次做市时，处理掉累积的净头寸。比如做市商目前净头寸有2BTC，下次做市时，他就可以下达一个卖3BTC的委卖单，一个买1BTC的委买单。这种做法好处是净头寸可以及时得到处理，坏处是净头寸处理的时机（价格）可能不是最优的。 （2）第二种方法是开立另外一个独立的程序，对累积的净头寸进行成本计算，然后按照成本价*（1+一定比例的手续费+一定比例的profit margin)，将该头寸反向甩出市场，甩出方法又有两种：a. 按限价单从价优到价劣依次甩出市场，超时不成交的部分则撤单，等待下次机会；b. 先按限价单从价优到价劣依次甩出市场，超时不成交的部分，则按市价单甩货。第一种方法的好处是甩货成本可控，但是甩货周期可能会拖得比较长；第二种方法则能有效地控制甩货周期，但是成本不可控，孰优孰劣，需要做市商根据自己的风险偏好慎重考虑。 3 期货换合约（移仓）的处理 期货合约都有一个到期日，在到期日结束时刻的前几个小时，我们不建议做市商继续做市，而是利用这几个小时，将即将到期的期货合约进行移仓。移仓的意思就是平掉当前期货合约的仓位，然后再开同样仓位大小的下周合约。当然，移仓也是需要考虑成本的。如果当前持仓是多头，那么我们希望移仓的时间点是在下周期货贴水最厉害的时候；反之，我们则希望移仓的时间点是在下周期货升水最厉害的时候。等移仓做完以后，做市策略继续恢复执行。 三、一个典型的比特币期货做市策略源码分享 注意，以下的策略需要其他WeQuant基础类库的支持才能运行，这里仅给出策略核心源码，是为了让读者对做市策略本身有一个具体的认识，而不用去太纠结底层下单、统计收益、收发邮件、进程监控等技术细节。关于代码的详细解释，欢迎入QQ群讨论：519538535。 期货做市策略源码： #!/usr/bin/env python # -*- coding: utf-8 -*- from signalGenerator.futureSpotArb import * from signalGenerator.strategyConfig import changeFutureContractConfig as rollCfg import time, threading class FutureMarketMaker(FutureSpotArb): def __init__(self, startRunningTime, orderRatio, timeInterval, orderWaitingTime, coinMarketType, open_diff, close_diff, heart_beat_time, depth_data, account_info, transaction_info, maximum_qty_multiplier=None, dailyExitTime=None): super(FutureMarketMaker, self).__init__(startRunningTime, orderRatio, timeInterval, orderWaitingTime, coinMarketType, open_diff, close_diff, heart_beat_time, depth_data, account_info, transaction_info, maximum_qty_multiplier=maximum_qty_multiplier, dailyExitTime=dailyExitTime) # 显示在邮件中的策略名字 self.strat_name = "期货做市-%s" % startRunningTime.strftime("%Y%m%d_%H%M%S") self.trade_threshold = 0.0003 * 1.01 self.sell_cut = 0.6 self.buy_cut = 0.6 self.leverage = 5 self.remaining_delta_cash = 0 # 策略下单参数 self.coin_type = helper.HUOBI_COIN_TYPE_BTC…