標(biāo)題: 嵌入式的TCP+IP協(xié)議的完整C源程序 [打印本頁(yè)]
作者: 阿凡達(dá)特    時(shí)間: 2017-9-14 10:44
標(biāo)題: 嵌入式的TCP+IP協(xié)議的完整C源程序
做一個(gè)項(xiàng)目涉及到的tcp/ip 源代碼




所有資料51hei提供下載:
TCP IP協(xié)議的完整C源程序.rar (26.62 KB, 下載次數(shù): 26)

源程序如下:

  2. // 版權(quán) 2003, 王衛(wèi)無(wú)，四川綿陽(yáng)岷山集團(tuán)有限公司--研究開發(fā)中心
  3. // wolver@minshan-inc.com
  4. // 保留一切權(quán)利
  5. //
  6. // 如果符合以下條件，則無(wú)論是以原代碼或非原代碼代碼形式，且不論是否修改，
  7. // 再分發(fā)和使用本軟件都是被允許的。
  8. // 1. 原代碼的再分發(fā)必須保留上述的版權(quán)聲明、本條件說(shuō)明和以下免責(zé)聲明。
  9. // 2. 非原代碼形式的再分發(fā)，必須在證明文件和(或)其它一同提供的材料中重新
  10. //    作上述的版權(quán)聲明、本條件說(shuō)明和以下免責(zé)聲明。
  11. // 3. 一切提及本軟件和使用的廣告材料必須顯示以下致謝：
  12. //    本產(chǎn)品包含王衛(wèi)無(wú)（四川綿陽(yáng)岷山集團(tuán)有限公司--研究開發(fā)中心）開發(fā)的軟件。
  13. // 4. 如果沒(méi)有預(yù)先得到特定的書面許可，不能用作者的名字來(lái)宣傳推廣基于本軟件得到
  14. //    的產(chǎn)品。
  15. //
  16. // 免責(zé)聲明：
  17. // 本軟件是由某某作者提供，如果出現(xiàn)以下情況，作者都不承擔(dān)任何責(zé)任。
  18. // 1. 因作者的說(shuō)明以及任何明確的或暗示的保證(包括但不限于表達(dá)某種商業(yè)性和適合某一
  19. //    特定目的暗示性保證)而產(chǎn)生的損失。
  20. // 2. 無(wú)論在何種情況下，對(duì)使用本軟件造成的任何直接的、間接的、偶然的、特定的、可預(yù)
  21. //    見性的和連帶產(chǎn)生的損失(包括但不限于獲取產(chǎn)品和服務(wù)、作用喪失、數(shù)據(jù)遺失、利益損
  22. //    失或商業(yè)干預(yù))，無(wú)論這些損失是怎樣造成的，并且是以何種方式闡釋責(zé)任。
  23. // 3. 任何因使用本軟件而相關(guān)的合同、嚴(yán)格賠償責(zé)任和侵權(quán)行為(包含：疏忽或其它)的損失，
  24. //    甚至即便是可能的此類已經(jīng)明示或暗示的損失。
  25. ///


  28. #include "system.h"
  29. #include "tcpip.h"
  30. #include "drivers.h"

  32. // 定義應(yīng)用：1 表示開啟功能，0 表示關(guān)閉功能
  33. #define cTCP_RS232   1    // TCP <-> RS232 的應(yīng)用，只用于服務(wù)模式
  34. #define cTCP_ADAC    1    // TCP <-> Audio, 主要用于服務(wù)，也可以用于客戶。要求高帶寬： > 912Kbit



  38. // 分配本地用戶自定義服務(wù)模式應(yīng)用TCP端口號(hào)，不能與知名端口相同！如：23, 80
  39. // 注意：對(duì)不同的TCP事件使用不同的本地端口號(hào)，有助于快速查找TCP事件而不需要判斷IP是否相同！
  40. //       這樣做能使本地快速響應(yīng)。
  41. #define cTCP_ListenPort_TEST   0x1000   // 4096

  43. #if cTCP_RS232 == 1
  44. #define cTCP_ListenPort_RS232  0x2000   // 8192
  45. #endif

  47. #if cTCP_ADAC == 0
  48. #define cTCP_ListenPort_ADAC   0x3000   // 12288
  49. #endif

  51. // 客戶應(yīng)用模式的本地TCP端口號(hào)。不能與知名端口相同！如：23, 80
  52. // 注意：對(duì)不同的TCP事件使用不同的本地端口號(hào)（包括：本地偵聽端口），有助于快速查找TCP事件而
  53. //       不需要判斷IP是否相同！這樣做能使本地快速響應(yīng)。
  54. #if (cTCP_ADAC == 1) && (TCP_ACTIVE_OPEN == 1)
  55. #define cTCP_ActivePort_ADAC  0x3001   // 12289
  56. #endif




  61. // 分配系統(tǒng)應(yīng)用臨時(shí)緩沖區(qū)（按 wrod 存儲(chǔ)）
  62. UINT16 guwAppBuf[cAppSizeMax];

  64. //--------------------------------------------------------------------------------------

  66. main(){
  67. #if  TCP_ACTIVE_OPEN == 1
  68.         UINT16 temp[2];
  69. #endif


  72. // 1. Hardware initialize: SPCE061A
  73.         SP_IO_INIT();

  75. // 2. Open and Enable Hardware interrupt 2Hz and Clear WatchDog!
  76.         SP_OpenTime2();

  78. // 3. Hardware initialize: RTL8019AS
  79.         RTL8019AS_RESET();
  80.         RTL8019AS_INIT();

  82. // 4. vIP4 TCP/IP initialize
  83.         msip_Init();

  85. // 5. We listen test port
  86.         msip_Listen(cTCP_ListenPort_TEST);                // 用于偵聽來(lái)自鏈路測(cè)試的TCP包


  89. #if cTCP_RS232 == 1
  90.         SP_UART_INIT(C_UART_Baud_115200);                // Hardware initialize: UART of SPCE061A

  92.         msip_Listen(cTCP_ListenPort_RS232);                // 用于偵聽來(lái)自RS232的TCP包
  93. #endif


  96. #if cTCP_ADAC == 1
  97. //        SP_ADAC_INIT(cSample_4096);                                // Open ADAC
  98. //        SP_ADAC_INIT(cSample_8192);                                // Open ADAC
  99. //        SP_ADAC_INIT(cSample_16384);                        // Open ADAC
  100. //        SP_ADAC_INIT(cSample_32768);                        // Open ADAC
  101. //        SP_CLOSE_FIQ();                // 關(guān)閉FIQ中斷，同時(shí)也禁止了ADAC

  103.         msip_Listen(cTCP_ListenPort_ADAC);                // 用于偵聽來(lái)自遠(yuǎn)端的Audio的TCP包
  104. #endif


  107. #if (cTCP_ADAC == 1) && (TCP_ACTIVE_OPEN == 1)
  108. // for test audio, wo active link remote: 192.168.0.60
  109.         temp[0] = ((192<<8)|168);
  110.         temp[1] = ((0<<8)|30);
  111.         msip_Connect(cTCP_ActivePort_ADAC, temp, cTCP_ListenPort_ADAC);
  112. #endif



  116. // 6. We do TCP/IP Check Loop
  117. loop:
  118.         // 接收新的以太包，并處理
  119.         if ((guwEthLen = ether_Receive()) != 0){
  120.                 switch (cptEthHdrBuf->EthType){
  121.                 case cEthType_Arp:
  122.                         msip_Arp_In();
  123.                         break;
  124.                 case cEthType_Ip:
  125.                         msip_Input();
  126.                 }
  127.         }

  129.         // ARP表老化處理
  130.         if (guwMsg_Route & cM_ARP_TIME){
  131.                 msip_Arp_Time();
  132.         }

  134.         // TCP事件輪詢
  135.         if (guwMsg_Route & cM_TCP_PERIODIC){
  136.                 msip_Periodic();
  137.         }

  139.     goto loop;

  141. }



  145. // SUB-SUB-SUB-SUB-SUB-SUB-SUB-SUB-SUB-SUB-SUB-SUB-SUB-SUB-SUB-SUB-SUB-SUB-SUB-SUB-SUB


  148. //--------------------------------------------------------------------------------------
  149. //
  150. //      |--------------|       |-----|----------|------|       |------|--------|
  151. //      |工業(yè)設(shè)備|RS232| <---> |RS232|核心嵌入板|TCP/IP| <---> |TCP/IP|普通PC機(jī)|
  152. //      |--------------|       |-----|----------|------|       |------|--------|
  153. //
  154. //-------------------------------------------------------------------------------------
  155. void userapp(){

  157.         switch (gptConn->LocalPort){
  158. #if cTCP_RS232 == 1
  159.         case cTCP_ListenPort_RS232:
  160.                 goto link_rs232;
  161. #endif

  163. #if cTCP_ADAC == 1        // ADAC 工作時(shí)：由于雙向通訊，所以Listen和Active處理是一樣的！
  164.         case cTCP_ListenPort_ADAC:
  165.                 goto link_adac_listen;
  166. #endif

  168. #if (cTCP_ADAC == 1) && (TCP_ACTIVE_OPEN == 1)        // ADAC 工作時(shí)：由于雙向通訊，所以Listen和Active處理是一樣的！
  169.         case cTCP_ActivePort_ADAC:
  170.                 goto link_adac_active;
  171. #endif

  173.         case cTCP_ListenPort_TEST:
  174.                 goto test_net;

  176.         default:
  177.                 return;
  178.         }


  181. #if cTCP_RS232 == 1
  182. link_rs232:         // 與RS232透明傳輸通訊：本系統(tǒng)的一個(gè)應(yīng)用。


  185. // 以下事件的過(guò)慮判斷并不按照事件發(fā)生的順序，是因?yàn)橛行┦录ǔＶ粫?huì)發(fā)生一次，
  186. // 從而在大多數(shù)其它經(jīng)常發(fā)生的事件狀態(tài)下，減少對(duì)那些事件的過(guò)濾判斷，以提高速度!!!

  188.         if (msip_Poll() || msip_Acked()){        // 如果RS232有數(shù)據(jù)要發(fā)送，就轉(zhuǎn)發(fā)TCP數(shù)據(jù)段！
  189.                 if (guwUartRxLen > 0) {        // 根據(jù)guwUartRxLen判斷是否轉(zhuǎn)發(fā)RS232數(shù)據(jù)
  190.                         MEMCPY(guwUartRxLen, guwUartRxBuf, cpTcpData);
  191.                         guwEthLen = guwUartRxLen;
  192.                         guwUartRxLen = 0;
  193.                         gptConn->PollTime = 0;        // 清除空閑時(shí)間記數(shù)
  194.                 } else        if (gptConn->PollTime++ > 3*cTCP_MAX_POLL){        // 太長(zhǎng)時(shí)間空閑(900秒)，終止連接！
  195.                                 msip_Close();
  196.                 }

  198.                 return;
  199.         }

  201.         if (msip_NewData()){        // 收到TCP數(shù)據(jù)包，轉(zhuǎn)發(fā)給RS232
  202.                 if (guwEthLen > 0){
  203.                         SP_UART_TX(guwEthLen, cpTcpData);
  204.                         guwEthLen = 0;
  205.                 }
  206.                 if (guwUartRxLen > 0) {        // 根據(jù)guwUartRxLen判斷是否轉(zhuǎn)發(fā)RS232數(shù)據(jù)
  207.                         MEMCPY(guwUartRxLen, guwUartRxBuf, cpTcpData);
  208.                         guwEthLen = guwUartRxLen;
  209.                         guwUartRxLen = 0;
  210.                         gptConn->PollTime = 0;        // 清除空閑時(shí)間記數(shù)
  211.                 }

  213.                 gptConn->PollTime = 0;        // 清除空閑時(shí)間記數(shù)
  214.                 return;
  215.         }

  217.         if (msip_Connected()){
  218.                 gptConn->PollTime = 0;        // 清除空閑時(shí)間記數(shù)
  219.                 guwEthLen = 0;                        // 釋放TCP數(shù)據(jù)區(qū)

  221.                 return;
  222.         }


  225. //        if (msip_Aborted() || msip_Closed()){        // 如果異常關(guān)閉，那就關(guān)閉當(dāng)前連接
  226.                 // Nothing to do!
  227. //                return;
  228. //        }

  230.         return;
  231. #endif



  235. #if cTCP_ADAC == 1        // ADAC 工作時(shí)：由于雙向通訊，所以Listen和Active處理是一樣的！
  236. link_adac_listen:
  237.         if (msip_Acked()){   // 如果有A/D數(shù)據(jù)要發(fā)送，就轉(zhuǎn)發(fā)TCP數(shù)據(jù)包
  238.                 /*
  239.                 if (guwMicRxLen > 0) {        // 根據(jù)guwMicRxLen判斷是否轉(zhuǎn)發(fā)Audio數(shù)據(jù)
  240.                         SP_CLOSE_FIQ();                // 關(guān)閉FIQ中斷，同時(shí)也禁止了ADAC
  241.                         MEMCPY(guwMicRxLen, guwMicRxBuf, cpTcpData);
  242.                         guwEthLen = guwMicRxLen;
  243.                         guwMicRxLen = 0;                // A/D 轉(zhuǎn)換計(jì)數(shù)復(fù)位
  244.                         SP_OPEN_FIQ();                        // 開啟FIQ中斷，同時(shí)也開啟了ADAC
  245.                         gptConn->PollTime = 0;        // 清除空閑時(shí)間記數(shù)
  246.                 } */
  247.                 guwEthLen = 0;
  248.                 return;
  249.         }


  252.         if (msip_NewData()){
  253.                 /*
  254.                 if (guwEthLen > 0){        // 收到Audio數(shù)據(jù)包
  255.                          // 如果上次沒(méi)有轉(zhuǎn)換完，就等....
  256.                         while(guwDAC1TxLen < guwDAC1TotalLen);
  257.                         // 如果轉(zhuǎn)換完，就復(fù)制buffer
  258.                         SP_CLOSE_FIQ();                // 關(guān)閉FIQ中斷，同時(shí)也禁止了ADAC
  259.                         if (guwEthLen > cDAC1_MAXLEN){  // 攔截超長(zhǎng)bytes部分
  260.                                 guwEthLen = cDAC1_MAXLEN;
  261.                         }
  262.                         MEMCPY(guwEthLen, cpTcpData, guwDAC1TxBuf); // 將TCP數(shù)據(jù)Audio復(fù)制給DAC1的buffer
  263.                         guwDAC1TxLen = 0;                           // DAC1 轉(zhuǎn)換計(jì)數(shù)復(fù)位
  264.                         guwDAC1TotalLen = guwEthLen;        // DAC1 轉(zhuǎn)換buffer總長(zhǎng)
  265.                         SP_OPEN_FIQ();                                        // 開啟FIQ中斷，同時(shí)也開啟了ADAC

  267.                         guwEthLen = 0;
  268.                 }
  269.                 if (guwMicRxLen > 0) {        // 根據(jù)guwMicRxLen判斷是否轉(zhuǎn)發(fā)Audio數(shù)據(jù)
  270.                         SP_CLOSE_FIQ();                // 關(guān)閉FIQ中斷，同時(shí)也禁止了ADAC
  271.                         MEMCPY(guwMicRxLen, guwMicRxBuf, cpTcpData);
  272.                         guwEthLen = guwMicRxLen;
  273.                         guwMicRxLen = 0;                // A/D 轉(zhuǎn)換計(jì)數(shù)復(fù)位
  274.                         SP_OPEN_FIQ();                        // 開啟FIQ中斷，同時(shí)也開啟了ADAC
  275.                 } */

  277.                 guwEthLen = 0;
  278.                 gptConn->PollTime = 0;        // 清除空閑時(shí)間記數(shù)
  279.                 return;

  281.         }


  284.         if (msip_Connected()){
  285.                 gptConn->PollTime = 0;        // 清除空閑時(shí)間記數(shù)
  286.                 guwEthLen = 0;                        // 釋放TCP數(shù)據(jù)區(qū)
  287.                 /*
  288.                 guwMicRxLen = 0;                // A/D 轉(zhuǎn)換計(jì)數(shù)復(fù)位
  289.                 guwDAC1TotalLen = 0;        // DAC1 轉(zhuǎn)換計(jì)數(shù)復(fù)位
  290.                 SP_OPEN_FIQ();                        // 開啟FIQ中斷，同時(shí)也開啟了ADAC
  291.                 */

  293.                 return;
  294.         }

  296.         if (msip_Poll()){
  297.                 if (gptConn->PollTime++ > 3*cTCP_MAX_POLL){        // 太長(zhǎng)時(shí)間空閑(900秒)，終止連接！
  298.                                 msip_Close();
  299.                                 //SP_CLOSE_FIQ();                // 關(guān)閉FIQ中斷，同時(shí)也禁止了ADAC
  300.                 }
  301.                 guwEthLen = 0;
  302.                 return;
  303.         }

  305.         if (msip_Aborted() || msip_Closed()){        // 如果異常關(guān)閉，那就關(guān)閉當(dāng)前連接
  306.                 //SP_CLOSE_FIQ();                // 關(guān)閉FIQ中斷，同時(shí)也禁止了ADAC
  307.                 return;
  308.         }

  310. link_adac_active:
  311.         if (msip_Acked()){   // 如果有A/D數(shù)據(jù)要發(fā)送，就轉(zhuǎn)發(fā)TCP數(shù)據(jù)包
  312.                 /*
  313.                 if (guwMicRxLen > 0) {        // 根據(jù)guwMicRxLen判斷是否轉(zhuǎn)發(fā)Audio數(shù)據(jù)
  314.                         SP_CLOSE_FIQ();                // 關(guān)閉FIQ中斷，同時(shí)也禁止了ADAC
  315.                         MEMCPY(guwMicRxLen, guwMicRxBuf, cpTcpData);
  316.                         guwEthLen = guwMicRxLen;
  317.                         guwMicRxLen = 0;                // A/D 轉(zhuǎn)換計(jì)數(shù)復(fù)位
  318.                         SP_OPEN_FIQ();                        // 開啟FIQ中斷，同時(shí)也開啟了ADAC
  319.                         gptConn->PollTime = 0;        // 清除空閑時(shí)間記數(shù)
  320.                 } */
  321.                 guwEthLen = 0;
  322.                 return;
  323.         }


  326.         if (msip_NewData()){
  327.                 /*
  328.                 if (guwEthLen > 0){        // 收到Audio數(shù)據(jù)包
  329.                          // 如果上次沒(méi)有轉(zhuǎn)換完，就等....
  330.                         while(guwDAC1TxLen < guwDAC1TotalLen);
  331.                         // 如果轉(zhuǎn)換完，就復(fù)制buffer
  332.                         SP_CLOSE_FIQ();                // 關(guān)閉FIQ中斷，同時(shí)也禁止了ADAC
  333.                         if (guwEthLen > cDAC1_MAXLEN){  // 攔截超長(zhǎng)bytes部分
  334.                                 guwEthLen = cDAC1_MAXLEN;
  335.                         }
  336.                         MEMCPY(guwEthLen, cpTcpData, guwDAC1TxBuf); // 將TCP數(shù)據(jù)Audio復(fù)制給DAC1的buffer
  337.                         guwDAC1TxLen = 0;                           // DAC1 轉(zhuǎn)換計(jì)數(shù)復(fù)位
  338.                         guwDAC1TotalLen = guwEthLen;        // DAC1 轉(zhuǎn)換buffer總長(zhǎng)
  339.                         SP_OPEN_FIQ();                                        // 開啟FIQ中斷，同時(shí)也開啟了ADAC

  341.                         guwEthLen = 0;
  342.                 }
  343.                 if (guwMicRxLen > 0) {        // 根據(jù)guwMicRxLen判斷是否轉(zhuǎn)發(fā)Audio數(shù)據(jù)
  344.                         SP_CLOSE_FIQ();                // 關(guān)閉FIQ中斷，同時(shí)也禁止了ADAC
  345.                         MEMCPY(guwMicRxLen, guwMicRxBuf, cpTcpData);
  346.                         guwEthLen = guwMicRxLen;
  347.                         guwMicRxLen = 0;                // A/D 轉(zhuǎn)換計(jì)數(shù)復(fù)位
  348.                         SP_OPEN_FIQ();                        // 開啟FIQ中斷，同時(shí)也開啟了ADAC
  349.                 } */

  351.                 guwEthLen = 0;
  352.                 gptConn->PollTime = 0;        // 清除空閑時(shí)間記數(shù)
  353.                 return;

  355.         }


  358.         if (msip_Connected()){
  359.                 gptConn->PollTime = 0;        // 清除空閑時(shí)間記數(shù)
  360.                 guwEthLen = 0;                        // 釋放TCP數(shù)據(jù)區(qū)
  361.                 /*
  362.                 guwMicRxLen = 0;                // A/D 轉(zhuǎn)換計(jì)數(shù)復(fù)位
  363.                 guwDAC1TotalLen = 0;        // DAC1 轉(zhuǎn)換計(jì)數(shù)復(fù)位
  364.                 SP_OPEN_FIQ();                        // 開啟FIQ中斷，同時(shí)也開啟了ADAC
  365.                 */

  367.                 return;
  368.         }

  370.         if (msip_Poll()){
  371.                 if (gptConn->PollTime++ > 3*cTCP_MAX_POLL){        // 太長(zhǎng)時(shí)間空閑(900秒)，終止連接！
  372.                                 msip_Close();
  373.                                 //SP_CLOSE_FIQ();                // 關(guān)閉FIQ中斷，同時(shí)也禁止了ADAC
  374.                 }
  375.                 guwEthLen = 1460;
  376.                 return;
  377.         }

  379.         if (msip_Aborted() || msip_Closed()){        // 如果異常關(guān)閉，那就關(guān)閉當(dāng)前連接
  380.                 //SP_CLOSE_FIQ();                // 關(guān)閉FIQ中斷，同時(shí)也禁止了ADAC
  381.                 return;
  382.         }


  385.         return;
  386. #endif





  392. // 以下部分用于Ping功能失效時(shí)的網(wǎng)絡(luò)測(cè)試！TMD現(xiàn)在網(wǎng)絡(luò)病毒太多，許多ISP運(yùn)營(yíng)商都禁Ping了！
  393. // 不管是否傳數(shù)據(jù)，都將在300秒后斷開.....
  394. test_net:

  396.         if (msip_NewData()){
  397.                 // Message: 收到！別惹我，煩著呢......
  398.                 cpTcpData[0] = 0xcad5;
  399.                 cpTcpData[1] = 0xb5bd;
  400.                 cpTcpData[2] = 0xa3a1;
  401.                 cpTcpData[3] = 0xb1f0;
  402.                 cpTcpData[4] = 0xc8c7;
  403.                 cpTcpData[5] = 0xced2;
  404.                 cpTcpData[6] = 0xb7b3;
  405.                 cpTcpData[7] = 0xb7b1;
  406.                 cpTcpData[8] = 0xd7c5;
  407.                 cpTcpData[9] = 0xc4d8;
  408.                 cpTcpData[10] = 0x2e2e;
  409.                 cpTcpData[11] = 0x2e2e;
  410.                 cpTcpData[12] = 0x2e2e;
  411.                 guwEthLen = 26;
  412.                 return;
  413.         }

  415.         if (msip_Poll()){
  416.                 if (gptConn->PollTime == 0){
  417.                         // Message: Welcome to you!
  418.                         cpTcpData[0] = 0x5765;        // "We"+
  419.                         cpTcpData[1] = 0x6c63;        // "lc"+
  420.                         cpTcpData[2] = 0x6f6d;        // "om"+
  421.                         cpTcpData[3] = 0x6520;        // "e "+
  422.                         cpTcpData[4] = 0x746f;        // "to"+
  423.                         cpTcpData[5] = 0x2079;        // "yo"+
  424.                         cpTcpData[6] = 0x6f75;        // " u"+
  425.                         cpTcpData[7] = 0x2120;        // "! "
  426.                         guwEthLen = 16;
  427.                 }

  429.                 if (gptConn->PollTime++ > cTCP_MAX_POLL){        // 太長(zhǎng)時(shí)間空閑，終止連接！
  430.                         msip_Close();
  431.                 }

  433.                 return;
  434.         }


  437.         if (msip_Connected()){
  438.                 gptConn->PollTime = 0;        // 清除空閑時(shí)間記數(shù)
  439.                 return;
  440.         }

  442. //        if (msip_Aborted() || msip_Closed()){        // 如果異常關(guān)閉，那就關(guān)閉當(dāng)前連接
  443.                 // Nothing to do!
  444. //                return;
  445. //        }

  447.         return;
  448. }
復(fù)制代碼



歡迎光臨 (http://www.torrancerestoration.com/bbs/) Powered by Discuz! X3.1