易盛信息9.0外盘期货行情数据API接口公共授权开发包例子代码

怎么才能获取到外盘期货行情数据API接口呢？不少朋友就会考虑到易盛9.0行情API接口，本身易盛就是一个软件提供商，提供行情API接口也无可厚非。但是由于市场上外盘行情API接口都是收费的，所以软件商提供行情API接口不太合理。实时上，不少朋友也用过易盛行情数据API接口，反馈问题不少，经常莫名其妙断了，而且得不到上游断数据原因。易盛9.0行情API不稳定性显而易见。另外易盛外盘数据也不全面，选择产品上非常受限制。

BIGI行情非常全面行情数据API接口，提供国内期货、国际期货、贵金属、全球股指、外汇、期权、现货、A股、数字货币等实时行情数据，不限制频率和次数；并且拥有推送接口socket websocket http和获取接口http post get等满足各层次的需求。BIGI行情价格实惠、数据实时、稳定获得业内好评。

下面介绍一下C# socket和websocket开发包例子代码

using System;

using System.Collections.Generic;

using System.Linq;

using System.Net;

using System.Text;

using System.Threading;

using TCPLibrary;

using TCPLibrary.Abstracts;

using TCPLibrary.DefaultImplements;

namespace SocketTest

{

class Program

{

static BaseClientSocket _client;

static string ip = "";

static int port = 8091;

static DateTime lastTim = DateTime.Now;

static void Main(string[] args)

{

//域名转ip

IPAddress[] IPs = Dns.GetHostAddresses("127.0.0.1");

ip = IPs[0].ToString();

_client = new BaseClientSocket();

_client.Connected += new ConnectedEventHandler(_client_Connected);

_client.DisConnected += new DisConnectedEventHandler(_client_DisConnected);

_client.MessageReceived += new MessageReceivedEventHandler(_client_MessageReceived);

_client.Connect(ip, port);

ThreadPool.QueueUserWorkItem(new WaitCallback(MonitorConnect), 1000);

while (Console.ReadLine() != "q") ;

}

static void MonitorConnect(object o)

{

while (true)

{

if ((DateTime.Now - lastTim).TotalSeconds > 40)

{

Console.WriteLine("重新连接并订阅...");

if (_client != null)

{

_client.Release();

}

_client.Connect(ip, port);

lastTim = DateTime.Now;

}

}

}

static void _client_MessageReceived(ZProxySocket proxySocket, ZMessage message)

{

lastTim = DateTime.Now;

BaseMessage msg = message as BaseMessage;

string strs = Encoding.UTF8.GetString(msg.MsgContent, 0, msg.MsgContent.Length).Trim();

if (string.IsNullOrEmpty(strs))

{

return;

}

if (strs == "ok")

{

//1.连接成功发送登陆信息

proxySocket.SendMessage(new BaseMessage(1, Encoding.UTF8.GetBytes("0=login|1=1|2=A8C7E85B958645419910F0E07F1D08F0\n"))); ;

}

else

{

Dictionary dic = new Dictionary();//解析数据各项

string[] groups = strs.Split(new char[] { '|' }, StringSplitOptions.RemoveEmptyEntries);

for (int i = 0; groups != null && groups.Length > i; i++)

{

string[] items = groups[i].Split(new char[] { '=' }, StringSplitOptions.RemoveEmptyEntries);

if (items.Length == 2 && !dic.ContainsKey(items[0]))

{

dic.Add(items[0], items[1].Trim());

}

}

if (dic["0"] == "login")

{

if (dic["1"] == "0")

{

//2.登陆成功后 订阅产品

proxySocket.SendMessage(new BaseMessage(1, Encoding.UTF8.GetBytes("0=subscribe|1=6BML,HSIML,USDJPY,CLML,HGML,ZSML,VXML,KCML,CCML,BRNML,FDAXML,A50ML,BTCML,DOWJONES,N225,PLML,NGML,SIML,ZCML,TCHZ8,METZ8,AGML,AUML,RBML,BUML,SRML,CFML,10001547,10001548,GC,CL\n")));

//2.登陆成功后 订阅产品带k线

//proxySocket.SendMessage(new BaseMessage(1, Encoding.UTF8.GetBytes("0=subscribe|1=6BML,HSIML,USDJPY,CLML,HGML,ZSML,VXML,KCML,CCML,BRNML,FDAXML,A50ML,BTCML,DOWJONES,N225,PLML,NGML,SIML,ZCML,TCHZ8,METZ8,AGML,AUML,RBML,BUML,SRML,CFML,10001547,10001548,GC,CL|2=k\n")));

}

else

{

//登陆失败

Console.WriteLine("登陆失败:" + dic["2"]);

}

}

else if (dic["0"] == "subscribe")

{

if (dic["1"] == "0")

{

//3.订阅成功返回

Console.WriteLine(dic["2"]);

}

else

{

//订阅失败

Console.WriteLine("订阅失败:" + dic["2"]);

}

}

else if (dic["0"] == "hq")

{

//开始处理行情 行情各项在 dic 中

Console.WriteLine(strs);

}

}

}

static void _client_DisConnected(ZProxySocket proxySocket)

{

Console.WriteLine("重新连接并订阅...");

if (_client != null)

{

_client.Release();

}

_client.Connect(ip, port);

}

static void _client_Connected(ZProxySocket proxySocket)

{

Console.WriteLine("连接服务器成功!");

}

}

}

朋友们，学会了吗？有疑问的话欢迎留言交流。