通视实时服务器源码

using System;
using System.Runtime.InteropServices;
using System.Collections;
using System.Drawing;
using System.ComponentModel;
using System.Windows.Forms;
using System.Data;
using System.IO;
using System.Threading;
using System.Text;
using Excel;


namespace TSRTD
{
/// <summary>
/// Class1 的摘要说明。
/// </summary>
[ProgId("RTDServer.Tongshi"),ComVisible(true)]
public class RTDServer:IRtdServer
{
private Hashtable QuoteCache=Hashtable.Synchronized(new Hashtable());
private Hashtable TopicTable=Hashtable.Synchronized(new Hashtable());
private ArrayList SymbolMonitor=new ArrayList ();

private IRTDUpdateEvent m_xlRTDUpdate;
protected TongshiWindow fTSdrv;


//
public RTDServer()
{
//
// TODO: 在此处添加构造函数逻辑
//
Win32.MessageBox(0, "（软）通视卡实时数据服务器 tom_sh@163.com出品", "程序信息", 0);

fTSdrv=new TongshiWindow();
fTSdrv.OnQuote+=new TSQuoteEventHandler(fTSdrv_OnQuote);

}
#region IRtdServer 成员

public void ServerTerminate()
{
// TODO: 添加 RTDServer.ServerTerminate 实现
m_xlRTDUpdate=null;
if(fTSdrv.Drvloaded==true)
{
fTSdrv.DrvQuit();
}
}

public int Heartbeat()
{
// TODO: 添加 RTDServer.Heartbeat 实现
return 1;
}

public void DisconnectData(int TopicID)
{
// TODO: 添加 RTDServer.DisconnectData 实现
if(TopicTable.ContainsKey(TopicID))
{
TopicTable.Remove(TopicID);
}

}

public Array RefreshData(ref int TopicCount)
{
// TODO: 添加 RTDServer.RefreshData 实现

object[,] aRetVal=new object [2,TopicTable.Count];
TopicCount=TopicTable.Count;
for(int i=0;i<TopicTable.Count;i++)
{
// RCV_REPORT_STRUCTExV3 report=(RCV_REPORT_STRUCTExV3)QuoteCache[SymbolMonitor];
aRetVal[0,i]=((RTDData)TopicTable).TopicID;
aRetVal[1,i]=((RTDData)TopicTable).Data;
}
return aRetVal;
}

public int ServerStart(IRTDUpdateEvent CallbackObject)
{
// TODO: 添加 RTDServer.ServerStart 实现
m_xlRTDUpdate = CallbackObject;
if(!fTSdrv.Drvloaded)
{
fTSdrv.DrvInit();
}

return 1;
}

public object ConnectData(int TopicID, ref Array Strings, ref bool GetNewValues)
{
// TODO: 添加 RTDServer.ConnectData 实现
string strType,strField, strTicker;
RTDData objRTDData;

GetNewValues = true;
try
{
strType =((string)Strings.GetValue(0)).ToUpper();
strTicker =((string)Strings.GetValue(1)).ToUpper();
strField = ((string)Strings.GetValue(2)).ToLower();



switch(strType)
{
case "TICK":
if(!TopicTable.ContainsKey(TopicID))
{
objRTDData=new RTDData (strTicker,strType,strField);
TopicTable.Add(TopicID,objRTDData);
}
else
{
objRTDData=(RTDData)TopicTable[TopicID];
}

if(objRTDData.TopicID==-1)
{
objRTDData.TopicID=TopicID;
}

if(QuoteCache.ContainsKey(strTicker))
{
RCV_REPORT_STRUCTExV3 report=(RCV_REPORT_STRUCTExV3)QuoteCache[strTicker];

switch(strField)
{
case "last":
objRTDData.Data= report.m_fNewPrice;
break;
case "open":
objRTDData.Data= report.m_fOpen;
break;
case "high":
objRTDData.Data= report.m_fHigh;
break;
case "low":
objRTDData.Data= report.m_fLow;
break;
case "volume":
objRTDData.Data= report.m_fVolume;
break;
case "time":
objRTDData.Data= DateTime.FromFileTimeUtc (10000000*(long)report.m_time + 116444736000000000).ToLocalTime();
break;
default:
objRTDData.Data= "格式错误";
break;
}
}
else
{
objRTDData.Data= "稍候";
}
return objRTDData.Data;
break;
default:
return "数据类型不支持";
break;
}
}
catch(Exception e)
{
return "报价错误";
}
}

#endregion
private void UpdateQuote(string Symbol)
{
foreach(RTDData objRTDData in TopicTable.Values )
{
if(objRTDData.Symbol==Symbol)
{
RCV_REPORT_STRUCTExV3 report=(RCV_REPORT_STRUCTExV3)QuoteCache[Symbol];

switch(objRTDData.Field)
{
case "last":
objRTDData.Data= report.m_fNewPrice;
break;
case "open":
objRTDData.Data= report.m_fOpen;
break;
case "high":
objRTDData.Data= report.m_fHigh;
break;
case "low":
objRTDData.Data= report.m_fLow;
break;
case "volume":
objRTDData.Data= report.m_fVolume;
break;
case "time":
objRTDData.Data= DateTime.FromFileTimeUtc (10000000*(long)report.m_time + 116444736000000000).ToLocalTime();
break;
default:
objRTDData.Data= "格式错误";
break;
}
}
}

m_xlRTDUpdate.UpdateNotify();
}

private void fTSdrv_OnQuote(object sender, TSQuoteEventArgs e)
{
string symbol=e.Symbol;
RCV_REPORT_STRUCTExV3 report=e.QuoteData;

if(!QuoteCache.ContainsKey(symbol))
{
QuoteCache.Add(symbol,report);

UpdateQuote(symbol);


}
else
{
RCV_REPORT_STRUCTExV3 lastreport=(RCV_REPORT_STRUCTExV3)QuoteCache[symbol];

if(lastreport.m_fVolume<report.m_fVolume||(lastreport.m_fVolume==report.m_fVolume&&lastreport.m_fNewPrice!=report.m_fNewPrice))
{
QuoteCache[symbol]=report;
UpdateQuote(symbol);
}
}

}

}
public class TongshiWindow:UserControl
{
private const int TSMSG=55;
private const uint SHMKT=18515;
private const uint SZMKT=23123;
private const int RCV_WORK_SENDMSG = 4;
private const int RCV_REPORT=0x3f001234;
private const int RCV_FILEDATA = 0x3f001235;
private const int STKLABEL_LEN = 10 ; // 股号数据长度,国内市场股号编码兼容钱龙
private const int STKNAME_LEN = 32 ; // 股名长度
private string DRVLOCATION="C:\\Program Files\\FreeStar\\Stock.dll";
public bool Drvloaded=false;
private const short fProviderID=102;

private System.Windows.Forms.TextBox textName;

private System.ComponentModel.IContainer components;
public event TSQuoteEventHandler OnQuote;

public TongshiWindow()
{
InitializeComponent();
}


// Initialize the control elements.
public void InitializeComponent()
{
textName = new System.Windows.Forms.TextBox();
textName.Location = new System.Drawing.Point(120, 8);
textName.Size = new System.Drawing.Size(232, 20);
textName.TabIndex = 0;

components = new System.ComponentModel.Container();
Controls.Add(textName);
Size = new System.Drawing.Size(375, 150);
}


[DllImport("C:\\Program Files\\FreeStar\\Stock.dll", CharSet=CharSet.Auto)]
public static extern int Stock_Init(int hWnd, uint Msg,int nWorkMode);

[DllImport("C:\\Program Files\\FreeStar\\Stock.dll", CharSet=CharSet.Auto)]
public static extern int Stock_Quit(int hWnd);

public void DrvInit()
{
Drvloaded=true;
Stock_Init(this.Handle.ToInt32(),TSMSG,RCV_WORK_SENDMSG);

}
public void DrvQuit()
{
if(Drvloaded)
{
Stock_Quit(this.Handle.ToInt32());
Drvloaded=false;
}
}


protected override void WndProc(ref Message m)
{
RCV_DATA data;
TSQuoteEventArgs qtarg;

if(m.Msg==TSMSG&&Drvloaded)
{
data=(RCV_DATA)m.GetLParam(typeof(RCV_DATA));

// Listen for operating system messages.
switch (m.WParam.ToInt32())
{
case RCV_REPORT:

if(OnQuote!=null)
{
for(int i=0;i<data.m_nPacketNum;i++)
{
RCV_REPORT_STRUCTExV3 report=(RCV_REPORT_STRUCTExV3)Marshal.PtrToStructure
(new IntPtr((int)data.ptr+158 * i),typeof(RCV_REPORT_STRUCTExV3));

string symbol=new string (report.m_szLabelName,0,6);
qtarg=new TSQuoteEventArgs (symbol,report);
OnQuote(this,qtarg);
}
}
break;
case RCV_FILEDATA:
// RCV_HISTORY_STRUCTEx history=(RCV_HISTORY_STRUCTEx)Marshal.PtrToStructure(data.ptr,typeof(RCV_HISTORY_STRUCTEx));
// RCV_HISTORY_STRUCTEx_tag taginfo= (RCV_HISTORY_STRUCTEx_tag)Marshal.PtrToStructure(data.ptr,typeof(RCV_HISTORY_STRUCTEx_tag));
// RCV_HISTORY_STRUCTEx_data hdata= (RCV_HISTORY_STRUCTEx_data)Marshal.PtrToStructure(new IntPtr((int)data.ptr+Marshal.SizeOf(typeof(RCV_HISTORY_STRUCTEx_data))),typeof(RCV_HISTORY_STRUCTEx_data));
//
// Console.WriteLine("data received + ");

break;
}
}
base.WndProc(ref m);

}

[ StructLayout( LayoutKind.Sequential )]
public struct RCV_REPORT_STRUCTExV2
{
public System.UInt16 m_cbSize; // 结构大小
public System.Int32 m_time; // 成交时间
public System.UInt16 m_wMarket; // 股票市场类型
[ MarshalAs( UnmanagedType.ByValArray, SizeConst=STKLABEL_LEN )]
public char[] m_szLabel; // 股票代码,以'\0'结尾
[ MarshalAs( UnmanagedType.ByValArray, SizeConst=STKNAME_LEN )]
public char[] m_szName; // 股票名称,以'\0'结尾

public float m_fLastClose; // 昨收
public float m_fOpen; // 今开
public float m_fHigh; // 最高
public float m_fLow; // 最低
public float m_fNewPrice; // 最新
public float m_fVolume; // 成交量
public float m_fAmount; // 成交额

[ MarshalAs( UnmanagedType.ByValArray, SizeConst=3 )]
public float[] m_fBuyPrice; // 申买价1,2,3
[ MarshalAs( UnmanagedType.ByValArray, SizeConst=3 )]
public float[] m_fBuyVolume; // 申买量1,2,3
[ MarshalAs( UnmanagedType.ByValArray, SizeConst=3 )]
public float[] m_fSellPrice; // 申卖价1,2,3
[ MarshalAs( UnmanagedType.ByValArray, SizeConst=3 )]
public float[] m_fSellVolume; // 申卖量1,2,3

public float m_fBuyPrice4; // 申买价4
public float m_fBuyVolume4; // 申买量4
public float m_fSellPrice4; // 申卖价4
public float m_fSellVolume4; // 申卖量4

// public float m_fBuyPrice5; // 申买价5
// public float m_fBuyVolume5; // 申买量5
// public float m_fSellPrice5; // 申卖价5
// public float m_fSellVolume5;


}

[ StructLayout( LayoutKind.Sequential )]
public struct RCV_REPORT_STRUCTEx
{
// public System.UInt16 m_cbSize; // 结构大小
// public DateTime m_time; // 成交时间
public System.UInt16 m_wMarket; // 股票市场类型
[ MarshalAs( UnmanagedType.ByValArray, SizeConst=STKLABEL_LEN )]
public char[] m_szLabel; // 股票代码,以'\0'结尾
[ MarshalAs( UnmanagedType.ByValArray, SizeConst=STKNAME_LEN )]
public char[] m_szName; // 股票名称,以'\0'结尾

public float m_fLastClose; // 昨收
public float m_fOpen; // 今开
public float m_fHigh; // 最高
public float m_fLow; // 最低
public float m_fNewPrice; // 最新
public float m_fVolume; // 成交量
public float m_fAmount; // 成交额

[ MarshalAs( UnmanagedType.ByValArray, SizeConst=3 )]
public float[] m_fBuyPrice; // 申买价1,2,3
[ MarshalAs( UnmanagedType.ByValArray, SizeConst=3 )]
public float[] m_fBuyVolume; // 申买量1,2,3
[ MarshalAs( UnmanagedType.ByValArray, SizeConst=3 )]
public float[] m_fSellPrice; // 申卖价1,2,3
[ MarshalAs( UnmanagedType.ByValArray, SizeConst=3 )]
public float[] m_fSellVolume; // 申卖量1,2,3

// public float m_fBuyPrice4; // 申买价4
// public float m_fBuyVolume4; // 申买量4
// public float m_fSellPrice4; // 申卖价4
// public float m_fSellVolume4; // 申卖量4
//
// public float m_fBuyPrice5; // 申买价5
// public float m_fBuyVolume5; // 申买量5
// public float m_fSellPrice5; // 申卖价5
// public float m_fSellVolume5;


}

[ StructLayout( LayoutKind.Sequential )]
public struct RCV_EKE_HEADEx
{
public System.UInt32 m_dwHeadTag; // = EKE_HEAD_TAG
public System.UInt16 m_wMarket; // 市场类型
[ MarshalAs( UnmanagedType.ByValTStr, SizeConst=STKLABEL_LEN )]
public string m_szLabel; // 股票代码
}
[ StructLayout( LayoutKind.Sequential )]
public struct HistoryData
{
public System.UInt32 m_time; //UCT
public float m_fOpen; //开盘
public float m_fHigh; //最高
public float m_fLow; //最低
public float m_fClose; //收盘
public float m_fVolume; //量
public float m_fAmount; //额
public System.UInt16 m_wAdvance; //涨数,仅大盘有效
public System.UInt16 m_wDecline; //跌数,仅大盘有效

}

// [ StructLayout( LayoutKind.Explicit )]
// public struct RCV_HISTORY_STRUCTEx
// {
// [ FieldOffset( 0 )]
// public HistoryData H;
//
// [ FieldOffset( 0 )]
// public RCV_EKE_HEADEx m_head;
// }

[ StructLayout( LayoutKind.Sequential )]
public struct RCV_HISTORY_STRUCTEx_tag
{
public RCV_EKE_HEADEx m_head;
}

[ StructLayout( LayoutKind.Sequential )]
public struct RCV_HISTORY_STRUCTEx_data
{
public HistoryData data;
}

[ StructLayout( LayoutKind.Sequential )]
public struct rcvdata
{
public IntPtr rpt3;
// [ FieldOffset( 0 )]
// public IntPtr rpt2;
// [ FieldOffset( 0 )]
// public IntPtr rpt;
// [ FieldOffset( 0 )]
// [ FieldOffset( 0 )]
}

[ StructLayout( LayoutKind.Sequential )]
public struct RCV_FILE_HEADEx
{
public System.UInt32 m_dwAttrib; // 文件子类型
public System.UInt32 m_dwLen; // 文件长度
public System.UInt32 m_dwSerialNo; // 序列号
[ MarshalAs( UnmanagedType.ByValTStr , SizeConst=260 )]
public string m_szFileName; // 文件名 or URL
}

[ StructLayout( LayoutKind.Explicit )]
public struct FileInfo
{
[ FieldOffset( 0 )]
public System.UInt32 m_dwSerialNo; // 序列号
[ FieldOffset( 0 )]
public System.Int32 m_FileTime; // 文件创建时间
}
[ StructLayout( LayoutKind.Sequential )]
public struct RCV_DATA
{
public System.Int32 m_wDataType; // 文件类型
public System.Int32 m_nPacketNum; // 记录数,参见注一
public RCV_FILE_HEADEx m_File; // 文件接口
public System.Int32 m_bDISK;
// [ MarshalAs( UnmanagedType.LPArray)]
// public RCV_REPORT_STRUCTExV3[] rpt;
// [ MarshalAs( UnmanagedType.AsAny)]
public IntPtr ptr;
// public rcvdata data;
}

}
public class TSQuoteEventArgs:EventArgs
{
public string Symbol;
public DateTime TimeStamp;
public RCV_REPORT_STRUCTExV3 QuoteData;

public TSQuoteEventArgs(string symbol,RCV_REPORT_STRUCTExV3 qt)
{
Symbol=symbol;
QuoteData=qt;
TimeStamp=DateTime.FromFileTimeUtc (10000000*(long)QuoteData.m_time + 116444736000000000);
}
}

public delegate void TSQuoteEventHandler(object sender, TSQuoteEventArgs e);
[ StructLayout( LayoutKind.Explicit )]
public struct RCV_REPORT_STRUCTExV3
{
[ FieldOffset( 0 )]public System.UInt16 m_cbSize; // 结构大小
[ FieldOffset( 2 )]public System.UInt32 m_time; // 成交时间
[ FieldOffset( 6 )]public System.UInt16 m_wMarket; // 股票市场类型

[ MarshalAs( UnmanagedType.ByValArray, SizeConst=42)]
[ FieldOffset( 8 )]public char[] m_szLabelName; // 股票代码,以'\0'结尾
//
// [ MarshalAs( UnmanagedType.ByValTStr, SizeConst=32 )]
// [ FieldOffset( 18 )]public string m_szName; // 股票名称,以'\0'结尾
// [ MarshalAs( UnmanagedType.ByValArray, SizeConst=STKLABEL_LEN-1 )]
// public char[] m_szLabel; // 股票代码,以'\0'结尾
// [ MarshalAs( UnmanagedType.ByValArray, SizeConst=STKNAME_LEN-1 )]
// public char[] m_szName; // 股票名称,以'\0'结尾

[ FieldOffset( 50 )]public System.Single m_fLastClose; // 昨收
[ FieldOffset( 54 )]public System.Single m_fOpen; // 今开
[ FieldOffset( 58 )]public System.Single m_fHigh; // 最高
[ FieldOffset( 62 )]public System.Single m_fLow; // 最低
[ FieldOffset( 66 )]public System.Single m_fNewPrice; // 最新
[ FieldOffset( 70 )]public System.Single m_fVolume; // 成交量
[ FieldOffset( 74 )]public System.Single m_fAmount; // 成交额

// [ MarshalAs( UnmanagedType.ByValArray, SizeConst=3 )]
[ FieldOffset( 78 )]public System.Single m_fBuyPrice1; // 申买价1
[ FieldOffset( 82 )]public System.Single m_fBuyPrice2; // 申买价2
[ FieldOffset( 86 )]public System.Single m_fBuyPrice3; // 申买价3
[ FieldOffset( 90 )]public System.Single m_fBuyVolume1; // 申买量1
[ FieldOffset( 94 )]public System.Single m_fBuyVolume2; // 申买量2
[ FieldOffset( 98 )]public System.Single m_fBuyVolume3; // 申买量3
[ FieldOffset( 102 )]public System.Single m_fSellPrice1; // 申卖价1
[ FieldOffset( 106 )]public System.Single m_fSellPrice2; // 申卖价2
[ FieldOffset( 110 )]public System.Single m_fSellPrice3; // 申卖价3
[ FieldOffset( 114 )]public System.Single m_fSellVolume1; // 申卖量1
[ FieldOffset( 118 )]public System.Single m_fSellVolume2; // 申卖量2
[ FieldOffset( 122 )]public System.Single m_fSellVolume3; // 申卖量3

// [ MarshalAs( UnmanagedType.ByValArray, SizeConst=3 )]
// [ FieldOffset( 0 )]public System.Single[] m_fBuyVolume; // 申买量1,2,3
// [ MarshalAs( UnmanagedType.ByValArray, SizeConst=3 )]
// [ FieldOffset( 0 )]public System.Single[] m_fSellPrice; // 申卖价1,2,3
// [ MarshalAs( UnmanagedType.ByValArray, SizeConst=3 )]
// [ FieldOffset( 0 )]public System.Single[] m_fSellVolume; // 申卖量1,2,3

[ FieldOffset( 126 )]public System.Single m_fBuyPrice4; // 申买价4
[ FieldOffset( 130 )]public System.Single m_fBuyVolume4; // 申买量4
[ FieldOffset( 134 )]public System.Single m_fSellPrice4; // 申卖价4
[ FieldOffset( 138 )]public System.Single m_fSellVolume4; // 申卖量4

[ FieldOffset( 142 )]public System.Single m_fBuyPrice5; // 申买价5
[ FieldOffset( 146 )]public System.Single m_fBuyVolume5; // 申买量5
[ FieldOffset( 150 )]public System.Single m_fSellPrice5; // 申卖价5
[ FieldOffset( 154 )]public System.Single m_fSellVolume5;
}

public class RTDData
{
private int m_intTopicID=-1;
private string m_strSymbol;
private object m_objData;
private string m_strType;
private string m_strField;
private bool m_boolIsUpdated=false;
public int TopicID
{
get
{
return m_intTopicID;
}
set
{
m_intTopicID=value;
}
}
public string Symbol
{
get
{
return m_strSymbol;
}
}
public object Data
{
get
{
return m_objData;
}
set
{
m_objData=value;
}
}
public string Type
{
get
{
return m_strType;
}
}
public string Field
{
get
{
return m_strField;
}
}
public bool IsUpdated
{
get
{
return m_boolIsUpdated;
}
set
{
m_boolIsUpdated=value;
}
}
public RTDData(string symbol,string datatype,string datafield)
{
m_strSymbol=symbol;
m_strType=datatype;
m_strField=datafield;
}
}
public class Win32
{
[DllImport("user32.dll", CharSet=CharSet.Auto)]
public static extern int MessageBox(int hWnd, String text,
String caption, uint type);
}
}

 

项目引用microsoft excel 10.0 object library。
另外需要默认安装FREESTAR

 

这个程序有两个主要类：RTDServer和TongshiWindow。RTDServer实现服务器本身，TongshiWindow从FREESTAR接收股票行情并发送实时数据给RTDServer。
RTDServer实现EXCEL的IRtdServer接口，包括ServerStart，ServerTerminate，Heartbeat，ConnectData，DisconnectData，RefreshData几个预定义子程序（方法）。这些方法与EXCEL按约定的方式（即IRtdServer接口）交流，提供数据，交换程序状态。RTDServer最后将注册为一个COM组件。
TongshiWindow按照通视规范调用FREESTAR，获得实时行情数据，并把RTDServer订阅的分笔行情数据以事件通知的方式传递给RTDServer，由其向EXCEL发送。
程序的辅助类有TSQuoteEventArgs（行情事件）、TSQuoteEventHandler（行情事件处理）、RCV_REPORT_STRUCTExV3（分笔数据结构）、RTDData（实时数据）、Win32（版权信息处理）。

 

[ProgId("RTDServer.Tongshi"),ComVisible(true)]//COM接口标识，生成的程序可以注册为一个COM组件
public class RTDServer:IRtdServer//实现IRtdServer接口，为EXCEL所识别
{
private Hashtable QuoteCache=Hashtable.Synchronized(new Hashtable());//以股票代码为KEY，以分笔成交记录为VALUE的最新行情数据表
private Hashtable TopicTable=Hashtable.Synchronized(new Hashtable());//以TOPICID（EXCEL动态唯一生成）为KEY，以行情字段值（如高开低收）为VALUE的数据表
private ArrayList SymbolMonitor=new ArrayList ();//冗余未用，本行可删

private IRTDUpdateEvent m_xlRTDUpdate;//IRTDUpdateEvent 对象实例，更新EXCEL用
protected TongshiWindow fTSdrv; //TongshiWindow 对象实例，从FREESTAR接收行情用

 

是c#源码。我没有做软通视驱动选择功能，但这不是技术障碍。源码在这里，无论你用哪种驱动，替换TSWINDOW类中两处DllImport("C:\\Program Files\\FreeStar\\Stock.dll"为各人使用的驱动路径，重新编译即可。
此外，注意这是一个C#类库项目，不是WINDOWS应用程序项目。

 

目前的程序只接收开高低收量时间6个字段数据，分笔成交的盘口数据没有放进去，不过既然源代码在这里，自己添加有关字段或其他统计指标应该都不是难事。
此外，这个程序设计上接收的是实时数据，如果想提取历史分笔（当天或更早之前的），需要自己写保存和提取代码。
数畅等驱动程序一经本程序启动，就会不断发送（单向广播）实时行情，本程序与数畅除了关闭通知以外没有其他的交互。
此外，数畅驱动有其他股票驱动没有的交互功能（即点播），想利用这项功能也需要自己写代码（按数畅公布的规范写）。

 

1、FREESTAR可下载分时数据，即每分钟一笔汇总成交，包括平均价、总成交量、总成交额，不是分笔数据。分时数据在盘后可以下载，盘中不知道行不行，没试过。下载的分时数据是一个数组，数据项的结构定义参见通视卡协议（通视网站、MACD上有）。FREESTAR以WINDOWS消息的方式传递指向分时数据数组的内存指针和数组长度。
2、分时数据数据一次性下载。如何以编码的方式通知FREESTAR服务器开发者没有公布，外人无法得知，目前都是通过用户界面手动做。

 

可能是FREESTAR的问题，它的兼容性不如HELLOWORLD，经验判断。或者把nmode改成LONG试试（估计没用）。
如果HELLOWORLD不行，再试MACD上公布的其他网络接口。
另外，Stock_Init的第三个参数是整数4，你直接写4进去看看。

 

Re: 大家好，初次灌水

http://www.hylt.net/club/viewtopic.php?t=4160 :o

 

vb下如何接收和处理窗口消息我是不懂的，所以看你的程序也没法直接提供帮助（VB应该有自己的WINDOWS消息处理方法吧，我看你调用了不少user32函数，需要直接使用这些低层次处理机制么？通视公司给的C++源码也没有这些）。我只知道在C#下，控间窗口的消息处理函数要自己做OVERRIDE编码，然后用wm-user定义来判断是否为FREESTAR发送，然后根据数据类别（分笔数据或是文件数据）的不同把指针转换成相应的数据结构。