| 在C#里面調(diào)用帶有回調(diào)函數(shù)和自定義結(jié)構(gòu)體的DLL的例程 | |
接口庫(kù)版本: CMPP2.0 API第二版(V2.6) 該例程演示了如何在C#里面調(diào)用VC6.0開發(fā)的帶回調(diào)函數(shù)的API，而且回調(diào)函數(shù)的參數(shù)包含結(jié)構(gòu)體，使用C#的委托和IntPtr方法實(shí)現(xiàn). 由于我使用C#剛兩天,這是我寫的第一個(gè)C#程序,因此例程寫的可能有點(diǎn)粗糙,但是編譯和運(yùn)行完全沒有問題. CMPP2.0的API封裝成了標(biāo)準(zhǔn)C調(diào)用的方法，提供以下三個(gè)接口，使用的時(shí)候只要有CMPPAPI.dll就可以了. #define DllExport extern "C" __declspec(dllexport) DllExport int __stdcall Cmpp2Start(LPCTSTR pchSmgIp, int nMtPort, int nMoPort, \ LPCTSTR pchUserName, LPCTSTR pchUserPwd, unsigned char uchVersion, \ void (__stdcall *OnSmgMsg)(CMPP_SMGTOSP* css), int nConnType, void (__stdcall *OnLogFile)(LPCTSTR str)); DllExport int __stdcall Cmpp2Submit(unsigned char uchPKtotal, unsigned char uchPKnumber, \ unsigned char uchNeedreport, unsigned char uchMsglevel, LPCTSTR pchServiceid, \ unsigned char uchFeeusertype, LPCTSTR pchFeeterminalid, unsigned char uchTppid, \ unsigned char uchTpudhi, unsigned char uchMsgfmt, LPCTSTR pchMsgsrc, \ LPCTSTR pchFeetype, LPCTSTR pchFeecode, LPCTSTR pchValidtime, \ LPCTSTR pchAttime, LPCTSTR pchSrcid, unsigned char uchDestusrtl, \ LPCTSTR pchDestterminalid, unsigned char uchMsglen, LPCTSTR pchMsgcontent); DllExport int __stdcall Cmpp2Release(); 在C#里面如何調(diào)用API,如何聲明結(jié)構(gòu)體,如何使用委托實(shí)現(xiàn)回調(diào)函數(shù),如何實(shí)現(xiàn)使用自定義結(jié)構(gòu)體作為參數(shù)的回調(diào)函數(shù),請(qǐng)仔細(xì)查看例程源碼。注意:CMPPAPI.dll要和可執(zhí)行文件放到同一個(gè)目錄下,或者放到可執(zhí)行文件能找到的目錄,或者放到系統(tǒng)目錄下(如:C:\windows\system32). 下面是C#下面的完整的調(diào)用代碼 //Class1.cs using System; // 該名稱空間包含了在Visual C#中調(diào)用API的一些必要集合 using System.Runtime.InteropServices; // 使用Sleep方法需要的命名空間 using System.Threading; namespace CMPPAPI_Sample_CSharp { //--------------------------------------------------------------------- //---------以下是DLL中需要使用的結(jié)構(gòu)體的定義--------------------------- //--------Pack = 1表示結(jié)構(gòu)體按一個(gè)字節(jié)對(duì)齊---------------------------- [StructLayout(LayoutKind.Sequential, Pack = 1)] public struct CMPP_HEAD { public uint nTotalLength; public uint nCommandId; public uint nSeqId; } [StructLayout(LayoutKind.Sequential, Pack = 1)] public struct CMPP_CONNECT { [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 6)] public string sSourceAddr; [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 16)] public string sAuthSource; public byte cVersion; public uint nTimeStamp; } [StructLayout(LayoutKind.Sequential, Pack = 1)] public struct CMPP_CONNECT_RESP { public byte uchStatus; [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 16)] public string sAuthISMG; public byte cVersion; } [StructLayout(LayoutKind.Sequential, Pack = 1)] public struct CMPP_SUBMIT_RESP { public long nMsgid; public byte uchResult; } [StructLayout(LayoutKind.Sequential, Pack = 1)] public struct CMPP_STATUS_REPORT { public long nMsgid; [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 7)] public string sStat; [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 10)] public string sSubmitTime; [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 10)] public string sDoneTime; [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 21)] public string sDestTerminalId; public uint nSmscSeq; } [StructLayout(LayoutKind.Sequential, Pack = 1)] public struct CMPP_MO_MSGCONTENT { [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 160)] public string sMsgcontent; public CMPP_STATUS_REPORT csr; } [StructLayout(LayoutKind.Sequential, Pack = 1)] public struct CMPP_DELIVER { public long nMsgid; [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 21)] public string sDestid; [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 10)] public string sServiceid; public byte uchTppid; public byte uchTpudhi; public byte uchMsgfmt; [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 21)] public string sSrcterminalid; public byte uchRegisteredDelivery; public byte uchMsglength; public CMPP_MO_MSGCONTENT mo_msg; [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 8)] public string sReserved; } [StructLayout(LayoutKind.Sequential, Pack = 1)] public struct CMPP_SUBMIT { public long nMsgid; public byte uchPkTotal; public byte uchPkNumber; public byte uchRegisteredDelivery; public byte uchMsgLevel; [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 10)] public string sServiceId; public byte uchFeeUserType; [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 21)] public string sFeeTerminalId; public byte uchTpPid; public byte uchTpUdhi; public byte uchMsgFmt; [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 6)] public string sMsgSrc; [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 2)] public string sFeeType; [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 6)] public string sFeeCode; [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 17)] public string sValidTime; [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 17)] public string sAtTime; [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 21)] public string sSrcId; public byte uchDstUsrTl; [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 21*100)] public string sDstTerminalId; public byte uchMsgLength; [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 160)] public string sMsgContent; [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 8)] public string sReserved; } [StructLayout(LayoutKind.Sequential, Pack = 1)] public struct CMPP_QUERY { [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 8)] public string sTime; public byte uchQueryType; [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 10)] public string sQueryCode; [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 8)] public string sReserved; } [StructLayout(LayoutKind.Sequential, Pack = 1)] public struct CMPP_QUERY_RESP { [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 8)] public string sTime; public byte uchQueryType; [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 10)] public string sQueryCode; public uint nMTTLMsg; //從SP接收消息總數(shù). public uint nMTTLUsr; //從SP接收用戶總數(shù). public uint nMTScs; //成功轉(zhuǎn)發(fā)數(shù)量. public uint nMTWT; //待轉(zhuǎn)發(fā)數(shù)量. public uint nMTFL; //轉(zhuǎn)發(fā)失敗數(shù)量. public uint nMOScs; //向SP成功送達(dá)數(shù)量. public uint nMOWT; //向SP待送達(dá)數(shù)量. public uint nMOFL; //向SP送達(dá)失敗數(shù)量. } [StructLayout(LayoutKind.Sequential, Pack = 1)] public struct CMPP_CANCEL { public long nMsgid; } [StructLayout(LayoutKind.Sequential, Pack = 1)] public struct CMPP_CANCEL_RESP { public byte uchSuccessId; } [StructLayout(LayoutKind.Sequential, Pack = 1)] public struct CMPP_ACTIVETEST_RESP { public byte uchReserved; } [StructLayout(LayoutKind.Sequential, Pack = 1)] public struct CMPP_BODY { public CMPP_CONNECT_RESP pk_connectresp; public CMPP_SUBMIT_RESP pk_submitresp; public CMPP_QUERY_RESP pk_queryresp; public CMPP_DELIVER pk_deliver; public CMPP_CANCEL_RESP pk_cancelresp; public CMPP_ACTIVETEST_RESP pk_activetestresp; } [StructLayout(LayoutKind.Sequential, Pack = 1)] public struct CMPP_SMGTOSP { public CMPP_HEAD pk_head; public CMPP_BODY pk_body; } //----------------DLL需要使用的結(jié)構(gòu)體的定義---------------------------- //--------------------------------------------------------------------- //----------------聲明兩個(gè)委托,相當(dāng)于VC里面的回調(diào)函數(shù)------------------ public delegate void OnSmgMsg(IntPtr css); public delegate void OnLogMsg(string str); //--------------------------------------------------------------------- class Class1 { //-------------------------------------------------------------------------- //--------------DLL中的API函數(shù)聲明------------------------------------------ // 1.Start Func [DllImport("CMPPAPI.dll")] public static extern int Cmpp2Start(string pchSmgIp, int nMtPort, int nMoPort, string pchUserName, string pchUserPwd, byte uchVersion, OnSmgMsg pf, int nConnType, OnLogMsg pf2); // 2.Submit Func [DllImport("CMPPAPI.dll")] public static extern int Cmpp2Submit(byte uchPKtotal, byte uchPKnumber, byte uchNeedreport, byte uchMsglevel, string pchServiceid, byte uchFeeusertype, string pchFeeterminalid, byte uchTppid, byte uchTpudhi, byte uchMsgfmt, string pchMsgsrc, string pchFeetype, string pchFeecode, string pchValidtime, string pchAttime, string pchSrcid, byte uchDestusrtl, string pchDestterminalid, byte uchMsglen, string pchMsgcontent); // 3.Release [DllImport("CMPPAPI.dll")] public static extern int Cmpp2Release(); //--------------DLL中的API函數(shù)聲明------------------------------------------ //-------------------------------------------------------------------------- //-------------這兒使用IntPtr實(shí)現(xiàn)與結(jié)構(gòu)體之間的轉(zhuǎn)換---------------- public static void OnMsg(IntPtr ptr) { CMPP_SMGTOSP css = new CMPP_SMGTOSP(); css = (CMPP_SMGTOSP)Marshal.PtrToStructure(ptr, typeof(CMPP_SMGTOSP)); uint nCmdId = css.pk_head.nCommandId; Console.WriteLine(css.pk_head.nCommandId); if ( nCmdId == 0x80000004) { // Submit應(yīng)答消息 } else if ( nCmdId == 0x0000005) { // Deliver消息 } return; } //------------第二個(gè)委托函數(shù)的定義------------------------------- public static void OnLog(string str) { Console.WriteLine(str); return; } /// /// 應(yīng)用程序的主入口點(diǎn)。 /// [STAThread] static void Main(string[] args) { Class1 c1 = new Class1(); OnSmgMsg pt = new OnSmgMsg(OnMsg); OnLogMsg pLog = new OnLogMsg(OnLog); //-------------啟動(dòng)模塊,連接網(wǎng)關(guān),收到消息以后會(huì)觸發(fā)OnSmgMsg函數(shù)------------------------------ int nRetCode = Cmpp2Start("127.0.0.1", 7890, 7891, "901234", "1234", (byte)0x20, pt, 0, pLog); if ( 0 == nRetCode) { Console.WriteLine("Connect Smg success\n"); while ( true) { //----------向網(wǎng)關(guān)提交Submit消息---------- nRetCode = Cmpp2Submit(1, 1, 1, 3, "2939", 0, "", 0, 0, 0, "901234", "02", "000020", "", "", "01850", 1, "8613660617374", 8, "測(cè)試消息"); if ( 0 == nRetCode) { Console.WriteLine("Submit Success."); } else { Console.WriteLine("Submit Fail."); } // Sleep5秒鐘 Thread.Sleep(5000); } //-----釋放連接----- Cmpp2Release(); } else { Console.WriteLine("Connect SMG Fail With Error: " + nRetCode); } } } } |
聯(lián)系客服
