ADX 减弱策略
平均方向指数(ADX)衡量趋势强度。当 ADX 开始下降时,通常说明当前走势动能减弱。本策略在价格位于简单移动平均线另一侧时,逆势交易这种减弱的趋势。
测试表明年均收益约为 136%,该策略在股票市场表现最佳。
每根K线计算 ADX 和 MA。如果 ADX 相比上一值下降且价格在 MA 上方,则入场做多;若 ADX 下跌而价格在 MA 下方,则做空。风险通过固定百分比止损控制。
由于该方法预期的是动能减弱而非完全反转,持仓通常直到 ADX 再次上升或止损触发。
细节
- 入场条件:ADX 低于前一值,且价格相对于 MA 的位置。
- 多/空:双向。
- 退出条件:止损。
- 止损:是,按百分比。
- 默认值:
AdxPeriod= 14MaPeriod= 20StopLossPercent= 2CandleType= 15 分钟
- 过滤条件:
- 类别: 趋势跟随
- 方向: 双向
- 指标: ADX, MA
- 止损: 有
- 复杂度: 基础
- 时间框架: 日内
- 季节性: 无
- 神经网络: 无
- 背离: 无
- 风险级别: 中等
using System;
using System.Collections.Generic;
using Ecng.Common;
using StockSharp.Algo.Indicators;
using StockSharp.Algo.Strategies;
using StockSharp.BusinessEntities;
using StockSharp.Messages;
namespace StockSharp.Samples.Strategies;
/// <summary>
/// ADX Weakening strategy.
/// While flat, a fall of ADX from the previous candle buys when the close is above the SMA and sells when it is below.
/// The position is held until ADX rises again or the percent stop is hit.
/// </summary>
public class AdxWeakeningStrategy : Strategy
{
private readonly StrategyParam<int> _adxPeriod;
private readonly StrategyParam<int> _maPeriod;
private readonly StrategyParam<decimal> _stopLossPercent;
private readonly StrategyParam<DataType> _candleType;
private decimal? _prevAdx;
/// <summary>
/// ADX period.
/// </summary>
public int AdxPeriod
{
get => _adxPeriod.Value;
set => _adxPeriod.Value = value;
}
/// <summary>
/// SMA period.
/// </summary>
public int MaPeriod
{
get => _maPeriod.Value;
set => _maPeriod.Value = value;
}
/// <summary>
/// Stop-loss percentage.
/// </summary>
public decimal StopLossPercent
{
get => _stopLossPercent.Value;
set => _stopLossPercent.Value = value;
}
/// <summary>
/// Candle type.
/// </summary>
public DataType CandleType
{
get => _candleType.Value;
set => _candleType.Value = value;
}
/// <summary>
/// Constructor.
/// </summary>
public AdxWeakeningStrategy()
{
_adxPeriod = Param(nameof(AdxPeriod), 14)
.SetGreaterThanZero()
.SetDisplay("ADX Period", "Period for ADX", "Indicators");
_maPeriod = Param(nameof(MaPeriod), 20)
.SetGreaterThanZero()
.SetDisplay("MA Period", "Period for SMA", "Indicators");
_stopLossPercent = Param(nameof(StopLossPercent), 2m)
.SetNotNegative()
.SetDisplay("Stop Loss %", "Stop loss percentage from entry price", "Risk");
_candleType = Param(nameof(CandleType), TimeSpan.FromMinutes(15).TimeFrame())
.SetDisplay("Candle Type", "Type of candles to use", "General");
}
/// <inheritdoc />
public override IEnumerable<(Security sec, DataType dt)> GetWorkingSecurities()
{
return [(Security, CandleType)];
}
/// <inheritdoc />
protected override void OnReseted()
{
base.OnReseted();
_prevAdx = null;
}
/// <inheritdoc />
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
_prevAdx = null;
var sma = new SimpleMovingAverage { Length = MaPeriod };
var adx = new AverageDirectionalIndex { Length = AdxPeriod };
var subscription = SubscribeCandles(CandleType);
subscription
.BindEx(sma, adx, ProcessCandle)
.Start();
StartProtection(new Unit(), new Unit(StopLossPercent, UnitTypes.Percent), useMarketOrders: true, isLocalStop: true);
// The stop has to see prices between candles, not only at their close.
foreach (var field in new[] { Level1Fields.BestBidPrice, Level1Fields.BestAskPrice })
{
var quotes = new Subscription(DataType.Level1, Security);
quotes.MarketData.BuildField = field;
SubscribeLevel1(quotes).Bind(ObserveProtectionQuote).Start();
}
var area = CreateChartArea();
if (area != null)
{
DrawCandles(area, subscription);
DrawIndicator(area, sma);
DrawIndicator(area, adx);
DrawOwnTrades(area);
}
}
private void ObserveProtectionQuote(Level1ChangeMessage quote)
{
// The high-level handler activates native protection before this callback, also between signal bars.
}
private void ProcessCandle(ICandleMessage candle, IIndicatorValue smaIv, IIndicatorValue adxIv)
{
if (candle.State != CandleStates.Finished || !adxIv.IsFormed || !smaIv.IsFormed)
return;
if (adxIv is not AverageDirectionalIndexValue { MovingAverage: decimal adx })
return;
var prevAdx = _prevAdx;
_prevAdx = adx;
if (prevAdx is not decimal lastAdx || !IsFormedAndOnlineAndAllowTrading())
return;
var sma = smaIv.GetValue<decimal>();
var close = candle.ClosePrice;
if (Position > 0)
{
if (adx > lastAdx)
SellMarket(Position);
}
else if (Position < 0)
{
if (adx > lastAdx)
BuyMarket(-Position);
}
else if (adx < lastAdx)
{
if (close > sma)
BuyMarket(Volume);
else if (close < sma)
SellMarket(Volume);
}
}
}
import clr
clr.AddReference("StockSharp.Messages")
clr.AddReference("StockSharp.Algo")
clr.AddReference("StockSharp.Algo.Indicators")
clr.AddReference("StockSharp.Algo.Strategies")
clr.AddReference("StockSharp.BusinessEntities")
from System import TimeSpan, Decimal
from StockSharp.Messages import DataType, CandleStates, Unit, UnitTypes, Level1Fields
from StockSharp.BusinessEntities import Subscription
from StockSharp.Algo.Indicators import SimpleMovingAverage, AverageDirectionalIndex
from StockSharp.Algo.Strategies import Strategy
class adx_weakening_strategy(Strategy):
"""
ADX Weakening strategy.
While flat, a fall of ADX from the previous candle buys when the close is above the SMA and sells when it is below.
The position is held until ADX rises again or the percent stop is hit.
"""
def __init__(self):
super(adx_weakening_strategy, self).__init__()
self._adx_period = self.Param("AdxPeriod", 14).SetGreaterThanZero().SetDisplay("ADX Period", "Period for ADX", "Indicators")
self._ma_period = self.Param("MaPeriod", 20).SetGreaterThanZero().SetDisplay("MA Period", "Period for SMA", "Indicators")
self._stop_loss_percent = self.Param("StopLossPercent", 2.0).SetNotNegative().SetDisplay("Stop Loss %", "Stop loss percentage from entry price", "Risk")
self._candle_type = self.Param("CandleType", DataType.TimeFrame(TimeSpan.FromMinutes(15))).SetDisplay("Candle Type", "Type of candles to use", "General")
self._prev_adx = None
@property
def candle_type(self):
return self._candle_type.Value
def OnReseted(self):
super(adx_weakening_strategy, self).OnReseted()
self._prev_adx = None
def OnStarted2(self, time):
super(adx_weakening_strategy, self).OnStarted2(time)
self._prev_adx = None
sma = SimpleMovingAverage()
sma.Length = self._ma_period.Value
adx = AverageDirectionalIndex()
adx.Length = self._adx_period.Value
subscription = self.SubscribeCandles(self.candle_type)
subscription.BindEx(sma, adx, self._process_candle).Start()
self.StartProtection(Unit(), Unit(Decimal(self._stop_loss_percent.Value), UnitTypes.Percent), useMarketOrders=True, isLocalStop=True)
# The stop has to see prices between candles, not only at their close.
for field in (Level1Fields.BestBidPrice, Level1Fields.BestAskPrice):
quotes = Subscription(DataType.Level1, self.Security)
quotes.MarketData.BuildField = field
self.SubscribeLevel1(quotes).Bind(self._observe_protection_quote).Start()
area = self.CreateChartArea()
if area is not None:
self.DrawCandles(area, subscription)
self.DrawIndicator(area, sma)
self.DrawIndicator(area, adx)
self.DrawOwnTrades(area)
def _observe_protection_quote(self, quote):
# The high-level handler activates native protection before the callback, including between bars.
pass
def _process_candle(self, candle, sma_iv, adx_iv):
if candle.State != CandleStates.Finished or not adx_iv.IsFormed or not sma_iv.IsFormed:
return
if adx_iv.MovingAverage is None:
return
adx = adx_iv.MovingAverage
prev_adx = self._prev_adx
self._prev_adx = adx
if prev_adx is None or not self.IsFormedAndOnlineAndAllowTrading():
return
sma = sma_iv.GetValue[Decimal](None)
close = candle.ClosePrice
if self.Position > 0:
if adx > prev_adx:
self.SellMarket(self.Position)
elif self.Position < 0:
if adx > prev_adx:
self.BuyMarket(-self.Position)
elif adx < prev_adx:
if close > sma:
self.BuyMarket(self.Volume)
elif close < sma:
self.SellMarket(self.Volume)
def CreateClone(self):
return adx_weakening_strategy()