SetChannelData

在频道上发布最新的状态数据。该函数用于实盘之间的通信，可将当前实盘的状态数据广播到频道上，供其他实盘订阅获取。

    
    
    
SetChannelData(data)

示例

• 频道广播端示例 - 发布 BTC 行情价格数据

  • javascript
  • python
  • rust
  • cpp

  
      javascript
      
      
  function main() {
      var updateId = 0
      var robotId = _G()  // 获取当前实盘 ID
  
      while(true) {
          // 获取实时市场价格
          var ticker = exchange.GetTicker("BTC_USDT")
          if (!ticker) {
              Sleep(5000)
              continue
          }
  
          // 构造当前频道状态数据
          var channelState = {
              robotId: robotId,
              updateId: ++updateId,
              timestamp: Date.now(),
              symbol: "BTC_USDT",
              lastPrice: ticker.Last,
              volume: ticker.Volume,
              high: ticker.High,
              low: ticker.Low
          }
  
          // 在频道上发布最新状态（覆盖旧状态）
          SetChannelData(channelState)
  
          // 显示当前频道状态
          LogStatus("Channel Broadcaster [Bot ID: " + robotId + "]\n" +
                    "Update ID: #" + channelState.updateId + "\n" +
                    "Time: " + _D(channelState.timestamp) + "\n" +
                    "Symbol: " + channelState.symbol + "\n" +
                    "Last Price: $" + channelState.lastPrice.toFixed(2) + "\n" +
                    "Volume: " + channelState.volume.toFixed(4) + "\n" +
                    "High: $" + channelState.high.toFixed(2) + "\n" +
                    "Low: $" + channelState.low.toFixed(2))
  
          Sleep(60000)  // 每分钟更新一次频道状态
      }
  }
  

  
      python
      
      
  def main():
      updateId = 0
      robotId = _G()  # 获取当前实盘 ID
  
      while True:
          # 获取实时市场价格
          ticker = exchange.GetTicker("BTC_USDT")
          if not ticker:
              Sleep(5000)
              continue
  
          # 构造当前频道状态数据
          channelState = {
              "robotId": robotId,
              "updateId": updateId + 1,
              "timestamp": time.time() * 1000,
              "symbol": "BTC_USDT",
              "lastPrice": ticker["Last"],
              "volume": ticker["Volume"],
              "high": ticker["High"],
              "low": ticker["Low"]
          }
          updateId += 1
  
          # 在频道上发布最新状态（覆盖旧状态）
          SetChannelData(channelState)
  
          # 显示当前频道状态
          LogStatus("Channel Broadcaster [Bot ID: {}]\n".format(robotId) +
                    "Update ID: #{}\n".format(channelState["updateId"]) +
                    "Time: {}\n".format(_D(channelState["timestamp"])) +
                    "Symbol: {}\n".format(channelState["symbol"]) +
                    "Last Price: ${:.2f}\n".format(channelState["lastPrice"]) +
                    "Volume: {:.4f}\n".format(channelState["volume"]) +
                    "High: ${:.2f}\n".format(channelState["high"]) +
                    "Low: ${:.2f}".format(channelState["low"]))
  
          Sleep(60000)  # 每分钟更新一次频道状态
  

  
      rust
      
      
  fn main() {
      let mut updateId = 0;
      let robotId = _G!();  // 获取当前实盘 ID
  
      loop {
          // 获取实时市场价格
          let ticker = match exchange.GetTicker("BTC_USDT") {
              Ok(t) => t,
              Err(_) => {
                  Sleep(5000);
                  continue;
              }
          };
  
          // 构造当前频道状态数据
          // Rust 的 SetChannelData 仅接受字符串参数，因此使用 format! 构造 JSON 文本
          updateId += 1;
          let timestamp = Unix() * 1000;
          let channelState = format!(
              r#"{{"robotId": {}, "updateId": {}, "timestamp": {}, "symbol": "BTC_USDT", "lastPrice": {}, "volume": {}, "high": {}, "low": {}}}"#,
              robotId, updateId, timestamp, ticker.Last, ticker.Volume, ticker.High, ticker.Low
          );
  
          // 在频道上发布最新状态（覆盖旧状态）
          SetChannelData(&channelState);
  
          // 显示当前频道状态
          LogStatus!(format!(
              "Channel Broadcaster [Bot ID: {}]\nUpdate ID: #{}\nTime: {}\nSymbol: BTC_USDT\nLast Price: ${:.2}\nVolume: {:.4}\nHigh: ${:.2}\nLow: ${:.2}",
              robotId, updateId, _D(timestamp), ticker.Last, ticker.Volume, ticker.High, ticker.Low
          ));
  
          Sleep(60000);  // 每分钟更新一次频道状态
      }
  }
  

  
      c++
      
      
  

• 跨平台发送示例 - 模拟外部平台（如 TradingView）向 FMZ 实盘发送数据

  • javascript
  • python
  • rust
  • cpp

  
      javascript
      
      
  // 此示例演示如何使用 HttpQuery 发送 HTTP POST 请求，模拟外部平台向 FMZ 实盘发送数据
  // 在实际场景中，外部平台（如 TradingView 的 Webhook 告警 URL、第三方交易系统等）会直接调用 FMZ API 端点
  
  function main() {
      let uuid = "6BC42A119B5DBFA2188A8279DA3B5C30"
      let robotId = 123456  // 目标实盘 ID（用于接收数据的实盘）
      let baseUrl = "https://www.fmz.com"
  
      while (true) {
          // 准备待发送的数据（可以是 JSON、文本或其他格式）
          let sendData = {
              "action": "buy",
              "symbol": "BTC_USDT",
              "price": 50000,
              "timestamp": Date.now()
          }
  
          // 构造 HTTP POST 请求
          let options = {
              method: "POST",
              body: JSON.stringify(sendData)  // body 可以是 JSON 字符串、普通文本等
          }
          let url = `${baseUrl}/api/v1?method=pub&robot=${robotId}&channel=${uuid}`
  
          // 发送数据
          let ret = HttpQuery(url, options)
          Log("Simulated external platform sending data, result:", ret)
  
          Sleep(10000)  // 每 10 秒发送一次
      }
  }
  

  
      python
      
      
  # 此示例演示如何使用 HttpQuery 发送 HTTP POST 请求，模拟外部平台向 FMZ 实盘发送数据
  # 在实际场景中，外部平台（如 TradingView 的 Webhook 告警 URL、第三方交易系统等）会直接调用 FMZ API 端点
  
  import json
  
  def main():
      uuid = "6BC42A119B5DBFA2188A8279DA3B5C30"
      robotId = 123456  # 目标实盘 ID（用于接收数据的实盘）
      baseUrl = "https://www.fmz.com"
  
      while True:
          # 准备待发送的数据（可以是 JSON、文本或其他格式）
          sendData = {
              "action": "buy",
              "symbol": "BTC_USDT",
              "price": 50000,
              "timestamp": time.time() * 1000
          }
  
          # 构造 HTTP POST 请求
          options = {
              "method": "POST",
              "body": json.dumps(sendData)  # body 可以是 JSON 字符串、普通文本等
          }
          url = "{}/api/v1?method=pub&robot={}&channel={}".format(baseUrl, robotId, uuid)
  
          # 发送数据
          ret = HttpQuery(url, options)
          Log("Simulated external platform sending data, result:", ret)
  
          Sleep(10000)  # 每 10 秒发送一次
  

  
      rust
      
      
  // 此示例演示如何使用 HttpQuery 发送 HTTP POST 请求，模拟外部平台向 FMZ 实盘发送数据
  // 在实际场景中，外部平台（如 TradingView 的 Webhook 告警 URL、第三方交易系统等）会直接调用 FMZ API 端点
  
  fn main() {
      let uuid = "6BC42A119B5DBFA2188A8279DA3B5C30";
      let robotId = 123456;  // 目标实盘 ID（用于接收数据的实盘）
      let baseUrl = "https://www.fmz.com";
  
      loop {
          // 准备待发送的数据（可以是 JSON、文本或其他格式）
          let sendData = format!(
              r#"{{"action": "buy", "symbol": "BTC_USDT", "price": 50000, "timestamp": {}}}"#,
              Unix() * 1000
          );
  
          // 构造 HTTP POST 请求，{:?} 会将 body 转义为合法的 JSON 字符串值
          let options = format!(r#"{{"method": "POST", "body": {:?}}}"#, sendData);
          let url = format!("{}/api/v1?method=pub&robot={}&channel={}", baseUrl, robotId, uuid);
  
          // 发送数据
          let ret: String = HttpQuery(&url, options.as_str());
          Log!("Simulated external platform sending data, result:", ret);
  
          Sleep(10000);  // 每 10 秒发送一次
      }
  }
  

  
      c++
      
      
  

返回值

参数

参考

备注

SetChannelData()函数为非阻塞调用，调用后立即返回，不会等待数据传输完成。

每个实盘都拥有一个独立的频道，频道ID即为实盘ID（可通过_G()函数获取）。

频道上仅保存最新的状态数据，每次调用SetChannelData()都会覆盖之前发布的数据，而非追加历史消息。

频道数据支持跨实盘、跨托管者、跨服务器进行广播，多个实盘可以订阅同一个频道。

订阅端使用GetChannelData()函数订阅频道数据。

频道通信适用于实盘环境，在回测系统中该功能可能受到限制。

传入的数据参数data在JSON序列化后的字节长度不得超过1024字节，超出限制可能导致数据发布失败。建议仅传输必要的状态信息，避免传输过大的数据对象。

发布的数据应根据硬件设备的内存和网络带宽合理使用，避免发布过大的数据对象。

SetChannelData()函数发布的数据不仅可以被FMZ平台内的其他实盘订阅，还支持跨平台数据发送功能。外部平台（如TradingView的Webhook告警、第三方交易系统、监控软件等）可以通过HTTP POST请求向指定的FMZ实盘发送数据。

跨平台发送数据的方式： 外部系统通过HTTP POST请求将数据发送到FMZ平台API端点：https://www.fmz.com/api/v1?method=pub&robot={robotId}&channel={uuid}，其中robotId为目标实盘ID，uuid为32位字符的频道标识符。发送的数据在请求body中传递，可以是JSON格式、文本或其他格式。注意：必须先有实盘订阅该UUID频道，外部系统才能成功发送数据；广播的数据会发送到robotId实盘所在托管者下的所有实盘，同一托管者下订阅了该UUID频道的实盘均可接收数据。