TWS API 开发手记——连接到TWS平台

龙听

TWS 是世界著名的盈透证券的交易平台，可以交易全球股票、期货、外汇等金融产品。而盈透证券的老板，又是一个以量化交易起家的传奇人物，因此在盈透很早的时候，就提供了基于TWS的API，供全世界的玩家开发出自己的交易系统。

因为个人兴趣爱好的原因，所以一直想开发一款属于自己的交易软件，后来注意到这个产品后，决定自己也试一试。

想要使用TWS，需要先去册盈透证券的官网注册投资者账号，并且在账号开通后三个月内向你的投资人账号打款以激活账号，否则注册了账号而不打款，三个月后账户就会被注销掉，也意味着你不能使用TWS进行下一步的开发了。

注册了账户、打入资金后，就可以在盈透证券的官网下载TWS交易客户端，同时还有IB API。IB API目前提供有Linux，Windows，MacOS三个系统的版本，根据你自己擅长的系统和语言，选择对应的API进行下载就行。这里笔者选择的是Windows，因为之后考虑做UI的时候，C#.NET 会十分方便。当然，笔者本人会Java，Python等语言技术，而且IB API的使用方法基本一致，所以也就无所谓语言的优劣，只要方便使用就好。

通信前准备

使用Windows编程，需要准备的是Visual Studio或者支持相关语言的开发工具和IDE，因为笔者用C#做这个项目，所以选择了Visual Studio。另一方面，因为Windows系统的限制，需要提前准备好程序的通信端口，并在防火墙、杀毒软件设置为打开。

通信前还需要做最后一个操作，打开TWS，并在全局设置中将允许连接打开，如果你只允许本地连接，那么点击“Allow connection from localhost only”就行，推荐这样做，因为比较安全。

开始编程

打开Visual studio并新建一个C#的工程，同时在工程“Solution Explorer”位置，找到工程的“References”，并添加IB API的DLL链接库。

IB API的库文件，存储于你安装的位置，只要找一找就能很容易找到。

工程目前包含两个主要文件，一个是Program.cs和TWSDeliverInterfaceImp.cs。

TWSDeliverInterfaceImp，是对EWrapper类的实现，这个是非常重要的一个类，包含了对所有事件的处理和响应，不过当前我们并不需要做太多的事件处理，因此可以把所有需要实现的方法空置即可。

1. using IBApi;
   
2. using System;
   
3. using System.Collections.Generic;
   
4. 
   
5. namespace AbsZeroTWS
   
6. {
   
7.     class TWSDeliverInterfaceImp : EWrapper
   
8.     {
   
9.         private EClientSocket clientSocket;
   
10.         private int nextOrderId;
    
11.         private int clientId;
    
12. 
    
13.         public TWSDeliverInterfaceImp(EReaderSignal signal)
    
14.         {
    
15.             clientSocket = new EClientSocket(this, signal);
    
16.         }
    
17. 
    
18.         public int ClientId
    
19.         {
    
20.             get { return clientId; }
    
21.             set { clientId = value; }
    
22.         }
    
23. 
    
24.         public EClientSocket ClientSocket
    
25.         {
    
26.             get { return clientSocket; }
    
27.             set { clientSocket = value; }
    
28.         }
    
29. 
    
30.         public int NextOrderId
    
31.         {
    
32.             get { return nextOrderId; }
    
33.             set { nextOrderId = value; }
    
34.         }
    
35. 
    
36.         public void accountDownloadEnd(string account) { }
    
37.         public void accountSummary(int reqId, string account, string tag, string value, string currency) { }
    
38.         public void accountSummaryEnd(int reqId) { }
    
39.         public void accountUpdateMulti(int requestId, string account, string modelCode, string key, string value, string currency) { }
    
40.         public void accountUpdateMultiEnd(int requestId) { }
    
41.         public void bondContractDetails(int reqId, ContractDetails contract) { }
    
42.         public void commissionReport(CommissionReport commissionReport) { }
    
43.         public void connectAck() { }
    
44.         public void connectionClosed() { }
    
45.         public void contractDetails(int reqId, ContractDetails contractDetails) { }
    
46.         public void contractDetailsEnd(int reqId) { }
    
47.         public void currentTime(long time) { }
    
48.         public void deltaNeutralValidation(int reqId, UnderComp underComp) { }
    
49.         public void displayGroupList(int reqId, string groups) { }
    
50.         public void displayGroupUpdated(int reqId, string contractInfo) { }
    
51.         public void error(string str) { }
    
52.         public void error(Exception e) { }
    
53.         public void error(int id, int errorCode, string errorMsg) { }
    
54.         public void execDetails(int reqId, Contract contract, Execution execution) { }
    
55.         public void execDetailsEnd(int reqId) { }
    
56.         public void fundamentalData(int reqId, string data) { }
    
57.         public void historicalData(int reqId, string date, double open, double high, double low, double close, int volume, int count, double WAP, bool hasGaps) { }
    
58.         public void historicalDataEnd(int reqId, string start, string end) { }
    
59.         public void managedAccounts(string accountsList) { }
    
60.         public void marketDataType(int reqId, int marketDataType) { }
    
61.         public void nextValidId(int orderId) { }
    
62.         public void openOrder(int orderId, Contract contract, Order order, OrderState orderState) { }
    
63.         public void openOrderEnd() { }
    
64.         public void orderStatus(int orderId, string status, double filled, double remaining, double avgFillPrice, int permId, int parentId, double lastFillPrice, int clientId, string whyHeld) { }
    
65.         public void position(string account, Contract contract, double pos, double avgCost) { }
    
66.         public void positionEnd() { }
    
67.         public void positionMulti(int requestId, string account, string modelCode, Contract contract, double pos, double avgCost) { }
    
68.         public void positionMultiEnd(int requestId) { }
    
69.         public void realtimeBar(int reqId, long time, double open, double high, double low, double close, long volume, double WAP, int count) { }
    
70.         public void receiveFA(int faDataType, string faXmlData) { }
    
71.         public void scannerData(int reqId, int rank, ContractDetails contractDetails, string distance, string benchmark, string projection, string legsStr) { }
    
72.         public void scannerDataEnd(int reqId) { }
    
73.         public void scannerParameters(string xml) { }
    
74.         public void securityDefinitionOptionParameter(int reqId, string exchange, int underlyingConId, string tradingClass, string multiplier, HashSet<string> expirations, HashSet<double> strikes) { }
    
75.         public void securityDefinitionOptionParameterEnd(int reqId) { }
    
76.         public void softDollarTiers(int reqId, SoftDollarTier[] tiers) { }
    
77.         public void tickEFP(int tickerId, int tickType, double basisPoints, string formattedBasisPoints, double impliedFuture, int holdDays, string futureLastTradeDate, double dividendImpact, double dividendsToLastTradeDate) { }
    
78.         public void tickGeneric(int tickerId, int field, double value) { }
    
79.         public void tickOptionComputation(int tickerId, int field, double impliedVolatility, double delta, double optPrice, double pvDividend, double gamma, double vega, double theta, double undPrice) { }
    
80.         public void tickPrice(int tickerId, int field, double price, int canAutoExecute) { }
    
81.         public void tickSize(int tickerId, int field, int size) { }
    
82.         public void tickSnapshotEnd(int tickerId) { }
    
83.         public void tickString(int tickerId, int field, string value) { }
    
84.         public void updateAccountTime(string timestamp) { }
    
85.         public void updateAccountValue(string key, string value, string currency, string accountName) { }
    
86.         public void updateMktDepth(int tickerId, int position, int operation, int side, double price, int size) { }
    
87.         public void updateMktDepthL2(int tickerId, int position, string marketMaker, int operation, int side, double price, int size) { }
    
88.         public void updateNewsBulletin(int msgId, int msgType, string message, string origExchange) { }
    
89.         public void updatePortfolio(Contract contract, double position, double marketPrice, double marketValue, double averageCost, double unrealisedPNL, double realisedPNL, string accountName) { }
    
90.         public void verifyAndAuthCompleted(bool isSuccessful, string errorText) { }
    
91.         public void verifyAndAuthMessageAPI(string apiData, string xyzChallenge) { }
    
92.         public void verifyCompleted(bool isSuccessful, string errorText) { }
    
93.         public void verifyMessageAPI(string apiData) { }
    
94.     }
    
95. }

复制代码

令一个类是主类，我们实现以下代码。

1. using IBApi;
   
2. using System;
   
3. using System.Collections.Generic;
   
4. using System.Linq;
   
5. using System.Text;
   
6. using System.Threading;
   
7. using System.Threading.Tasks;
   
8. 
   
9. namespace AbsZeroTWS
   
10. {
    
11.     class Program
    
12.     {
    
13.         static void Main(string[] args)
    
14.         {
    
15.             EReaderMonitorSignal signal = new EReaderMonitorSignal();
    
16.             TWSDeliverInterfaceImp tws = new TWSDeliverInterfaceImp(signal);
    
17.             tws.ClientSocket.eConnect("localhost", 7000, 0);
    
18. 
    
19.             var reader = new EReader(tws.ClientSocket, signal);
    
20.             reader.Start();
    
21. 
    
22.             if (tws.ClientSocket.IsConnected())
    
23.             {
    
24.                 Console.WriteLine("Connection is established!");
    
25.             }
    
26.             /*
    
27.             new Thread(() => {
    
28.                 while (tws.ClientSocket.IsConnected())
    
29.                 {
    
30.                     signal.waitForSignal();
    
31.                     reader.processMsgs();
    
32.                 }
    
33.             }) { IsBackground = true }.Start();
    
34.             */
    
35.             Console.ReadKey();
    
36.         }
    
37.     }
    
38. }

复制代码

点击运行后，程序就能跟TWS进行连接，并打印出connection is established.