设为首页收藏本站
开启辅助访问 切换到宽版

 找回密码
 立即注册

QQ登录

只需一步，快速开始

热门： 51单片机 | 24小时必答区 | 单片机教程 | 单片机DIY制作 | STM32 | Cortex M3 | 模数电子 | 电子DIY制作 | 音响/功放 | 拆机乐园 | Arduino | 嵌入式OS | 程序设计

搜索
»论坛 › 嵌入式/单片机论坛 › MCU综合技术区 › 嵌入式的TCP+IP协议的完整C源程序
返回列表 发新帖
查看: 2357|回复: 0
打印 上一主题 下一主题
收起左侧

嵌入式的TCP+IP协议的完整C源程序

[复制链接]
跳转到指定楼层
楼主
ID:232914 发表于 2017-9-14 10:44 | 只看该作者 |只看大图 回帖奖励 |倒序浏览 |阅读模式
做一个项目涉及到的tcp/ip 源代码




所有资料51hei提供下载:
TCP IP协议的完整C源程序.rar (26.62 KB, 下载次数: 26)

源程序如下:

  2. // 版权 2003, 王卫无，四川绵阳岷山集团有限公司--研究开发中心
  3. // wolver@minshan-inc.com
  4. // 保留一切权利
  5. //
  6. // 如果符合以下条件，则无论是以原代码或非原代码代码形式，且不论是否修改，
  7. // 再分发和使用本软件都是被允许的。
  8. // 1. 原代码的再分发必须保留上述的版权声明、本条件说明和以下免责声明。
  9. // 2. 非原代码形式的再分发，必须在证明文件和(或)其它一同提供的材料中重新
  10. //    作上述的版权声明、本条件说明和以下免责声明。
  11. // 3. 一切提及本软件和使用的广告材料必须显示以下致谢：
  12. //    本产品包含王卫无（四川绵阳岷山集团有限公司--研究开发中心）开发的软件。
  13. // 4. 如果没有预先得到特定的书面许可，不能用作者的名字来宣传推广基于本软件得到
  14. //    的产品。
  15. //
  16. // 免责声明：
  17. // 本软件是由某某作者提供，如果出现以下情况，作者都不承担任何责任。
  18. // 1. 因作者的说明以及任何明确的或暗示的保证(包括但不限于表达某种商业性和适合某一
  19. //    特定目的暗示性保证)而产生的损失。
  20. // 2. 无论在何种情况下，对使用本软件造成的任何直接的、间接的、偶然的、特定的、可预
  21. //    见性的和连带产生的损失(包括但不限于获取产品和服务、作用丧失、数据遗失、利益损
  22. //    失或商业干预)，无论这些损失是怎样造成的，并且是以何种方式阐释责任。
  23. // 3. 任何因使用本软件而相关的合同、严格赔偿责任和侵权行为(包含：疏忽或其它)的损失，
  24. //    甚至即便是可能的此类已经明示或暗示的损失。
  25. ///


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

  32. // 定义应用：1 表示开启功能，0 表示关闭功能
  33. #define cTCP_RS232   1    // TCP <-> RS232 的应用，只用于服务模式
  34. #define cTCP_ADAC    1    // TCP <-> Audio, 主要用于服务，也可以用于客户。要求高带宽： > 912Kbit



  38. // 分配本地用户自定义服务模式应用TCP端口号，不能与知名端口相同！如：23, 80
  39. // 注意：对不同的TCP事件使用不同的本地端口号，有助于快速查找TCP事件而不需要判断IP是否相同！
  40. //       这样做能使本地快速响应。
  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. // 客户应用模式的本地TCP端口号。不能与知名端口相同！如：23, 80
  52. // 注意：对不同的TCP事件使用不同的本地端口号（包括：本地侦听端口），有助于快速查找TCP事件而
  53. //       不需要判断IP是否相同！这样做能使本地快速响应。
  54. #if (cTCP_ADAC == 1) && (TCP_ACTIVE_OPEN == 1)
  55. #define cTCP_ActivePort_ADAC  0x3001   // 12289
  56. #endif




  61. // 分配系统应用临时缓冲区（按 wrod 存储）
  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);                // 用于侦听来自链路测试的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);                // 用于侦听来自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();                // 关闭FIQ中断，同时也禁止了ADAC

  103.         msip_Listen(cTCP_ListenPort_ADAC);                // 用于侦听来自远端的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. //      |工业设备|RS232| <---> |RS232|核心嵌入板|TCP/IP| <---> |TCP/IP|普通PC机|
  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 工作时：由于双向通讯，所以Listen和Active处理是一样的！
  164.         case cTCP_ListenPort_ADAC:
  165.                 goto link_adac_listen;
  166. #endif

  168. #if (cTCP_ADAC == 1) && (TCP_ACTIVE_OPEN == 1)        // ADAC 工作时：由于双向通讯，所以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透明传输通讯：本系统的一个应用。


  185. // 以下事件的过虑判断并不按照事件发生的顺序，是因为有些事件通常只会发生一次，
  186. // 从而在大多数其它经常发生的事件状态下，减少对那些事件的过滤判断，以提高速度!!!

  188.         if (msip_Poll() || msip_Acked()){        // 如果RS232有数据要发送，就转发TCP数据段！
  189.                 if (guwUartRxLen > 0) {        // 根据guwUartRxLen判断是否转发RS232数据
  190.                         MEMCPY(guwUartRxLen, guwUartRxBuf, cpTcpData);
  191.                         guwEthLen = guwUartRxLen;
  192.                         guwUartRxLen = 0;
  193.                         gptConn->PollTime = 0;        // 清除空闲时间记数
  194.                 } else        if (gptConn->PollTime++ > 3*cTCP_MAX_POLL){        // 太长时间空闲(900秒)，终止连接！
  195.                                 msip_Close();
  196.                 }

  198.                 return;
  199.         }

  201.         if (msip_NewData()){        // 收到TCP数据包，转发给RS232
  202.                 if (guwEthLen > 0){
  203.                         SP_UART_TX(guwEthLen, cpTcpData);
  204.                         guwEthLen = 0;
  205.                 }
  206.                 if (guwUartRxLen > 0) {        // 根据guwUartRxLen判断是否转发RS232数据
  207.                         MEMCPY(guwUartRxLen, guwUartRxBuf, cpTcpData);
  208.                         guwEthLen = guwUartRxLen;
  209.                         guwUartRxLen = 0;
  210.                         gptConn->PollTime = 0;        // 清除空闲时间记数
  211.                 }

  213.                 gptConn->PollTime = 0;        // 清除空闲时间记数
  214.                 return;
  215.         }

  217.         if (msip_Connected()){
  218.                 gptConn->PollTime = 0;        // 清除空闲时间记数
  219.                 guwEthLen = 0;                        // 释放TCP数据区

  221.                 return;
  222.         }


  225. //        if (msip_Aborted() || msip_Closed()){        // 如果异常关闭，那就关闭当前连接
  226.                 // Nothing to do!
  227. //                return;
  228. //        }

  230.         return;
  231. #endif



  235. #if cTCP_ADAC == 1        // ADAC 工作时：由于双向通讯，所以Listen和Active处理是一样的！
  236. link_adac_listen:
  237.         if (msip_Acked()){   // 如果有A/D数据要发送，就转发TCP数据包
  238.                 /*
  239.                 if (guwMicRxLen > 0) {        // 根据guwMicRxLen判断是否转发Audio数据
  240.                         SP_CLOSE_FIQ();                // 关闭FIQ中断，同时也禁止了ADAC
  241.                         MEMCPY(guwMicRxLen, guwMicRxBuf, cpTcpData);
  242.                         guwEthLen = guwMicRxLen;
  243.                         guwMicRxLen = 0;                // A/D 转换计数复位
  244.                         SP_OPEN_FIQ();                        // 开启FIQ中断，同时也开启了ADAC
  245.                         gptConn->PollTime = 0;        // 清除空闲时间记数
  246.                 } */
  247.                 guwEthLen = 0;
  248.                 return;
  249.         }


  252.         if (msip_NewData()){
  253.                 /*
  254.                 if (guwEthLen > 0){        // 收到Audio数据包
  255.                          // 如果上次没有转换完，就等....
  256.                         while(guwDAC1TxLen < guwDAC1TotalLen);
  257.                         // 如果转换完，就复制buffer
  258.                         SP_CLOSE_FIQ();                // 关闭FIQ中断，同时也禁止了ADAC
  259.                         if (guwEthLen > cDAC1_MAXLEN){  // 拦截超长bytes部分
  260.                                 guwEthLen = cDAC1_MAXLEN;
  261.                         }
  262.                         MEMCPY(guwEthLen, cpTcpData, guwDAC1TxBuf); // 将TCP数据Audio复制给DAC1的buffer
  263.                         guwDAC1TxLen = 0;                           // DAC1 转换计数复位
  264.                         guwDAC1TotalLen = guwEthLen;        // DAC1 转换buffer总长
  265.                         SP_OPEN_FIQ();                                        // 开启FIQ中断，同时也开启了ADAC

  267.                         guwEthLen = 0;
  268.                 }
  269.                 if (guwMicRxLen > 0) {        // 根据guwMicRxLen判断是否转发Audio数据
  270.                         SP_CLOSE_FIQ();                // 关闭FIQ中断，同时也禁止了ADAC
  271.                         MEMCPY(guwMicRxLen, guwMicRxBuf, cpTcpData);
  272.                         guwEthLen = guwMicRxLen;
  273.                         guwMicRxLen = 0;                // A/D 转换计数复位
  274.                         SP_OPEN_FIQ();                        // 开启FIQ中断，同时也开启了ADAC
  275.                 } */

  277.                 guwEthLen = 0;
  278.                 gptConn->PollTime = 0;        // 清除空闲时间记数
  279.                 return;

  281.         }


  284.         if (msip_Connected()){
  285.                 gptConn->PollTime = 0;        // 清除空闲时间记数
  286.                 guwEthLen = 0;                        // 释放TCP数据区
  287.                 /*
  288.                 guwMicRxLen = 0;                // A/D 转换计数复位
  289.                 guwDAC1TotalLen = 0;        // DAC1 转换计数复位
  290.                 SP_OPEN_FIQ();                        // 开启FIQ中断，同时也开启了ADAC
  291.                 */

  293.                 return;
  294.         }

  296.         if (msip_Poll()){
  297.                 if (gptConn->PollTime++ > 3*cTCP_MAX_POLL){        // 太长时间空闲(900秒)，终止连接！
  298.                                 msip_Close();
  299.                                 //SP_CLOSE_FIQ();                // 关闭FIQ中断，同时也禁止了ADAC
  300.                 }
  301.                 guwEthLen = 0;
  302.                 return;
  303.         }

  305.         if (msip_Aborted() || msip_Closed()){        // 如果异常关闭，那就关闭当前连接
  306.                 //SP_CLOSE_FIQ();                // 关闭FIQ中断，同时也禁止了ADAC
  307.                 return;
  308.         }

  310. link_adac_active:
  311.         if (msip_Acked()){   // 如果有A/D数据要发送，就转发TCP数据包
  312.                 /*
  313.                 if (guwMicRxLen > 0) {        // 根据guwMicRxLen判断是否转发Audio数据
  314.                         SP_CLOSE_FIQ();                // 关闭FIQ中断，同时也禁止了ADAC
  315.                         MEMCPY(guwMicRxLen, guwMicRxBuf, cpTcpData);
  316.                         guwEthLen = guwMicRxLen;
  317.                         guwMicRxLen = 0;                // A/D 转换计数复位
  318.                         SP_OPEN_FIQ();                        // 开启FIQ中断，同时也开启了ADAC
  319.                         gptConn->PollTime = 0;        // 清除空闲时间记数
  320.                 } */
  321.                 guwEthLen = 0;
  322.                 return;
  323.         }


  326.         if (msip_NewData()){
  327.                 /*
  328.                 if (guwEthLen > 0){        // 收到Audio数据包
  329.                          // 如果上次没有转换完，就等....
  330.                         while(guwDAC1TxLen < guwDAC1TotalLen);
  331.                         // 如果转换完，就复制buffer
  332.                         SP_CLOSE_FIQ();                // 关闭FIQ中断，同时也禁止了ADAC
  333.                         if (guwEthLen > cDAC1_MAXLEN){  // 拦截超长bytes部分
  334.                                 guwEthLen = cDAC1_MAXLEN;
  335.                         }
  336.                         MEMCPY(guwEthLen, cpTcpData, guwDAC1TxBuf); // 将TCP数据Audio复制给DAC1的buffer
  337.                         guwDAC1TxLen = 0;                           // DAC1 转换计数复位
  338.                         guwDAC1TotalLen = guwEthLen;        // DAC1 转换buffer总长
  339.                         SP_OPEN_FIQ();                                        // 开启FIQ中断，同时也开启了ADAC

  341.                         guwEthLen = 0;
  342.                 }
  343.                 if (guwMicRxLen > 0) {        // 根据guwMicRxLen判断是否转发Audio数据
  344.                         SP_CLOSE_FIQ();                // 关闭FIQ中断，同时也禁止了ADAC
  345.                         MEMCPY(guwMicRxLen, guwMicRxBuf, cpTcpData);
  346.                         guwEthLen = guwMicRxLen;
  347.                         guwMicRxLen = 0;                // A/D 转换计数复位
  348.                         SP_OPEN_FIQ();                        // 开启FIQ中断，同时也开启了ADAC
  349.                 } */

  351.                 guwEthLen = 0;
  352.                 gptConn->PollTime = 0;        // 清除空闲时间记数
  353.                 return;

  355.         }


  358.         if (msip_Connected()){
  359.                 gptConn->PollTime = 0;        // 清除空闲时间记数
  360.                 guwEthLen = 0;                        // 释放TCP数据区
  361.                 /*
  362.                 guwMicRxLen = 0;                // A/D 转换计数复位
  363.                 guwDAC1TotalLen = 0;        // DAC1 转换计数复位
  364.                 SP_OPEN_FIQ();                        // 开启FIQ中断，同时也开启了ADAC
  365.                 */

  367.                 return;
  368.         }

  370.         if (msip_Poll()){
  371.                 if (gptConn->PollTime++ > 3*cTCP_MAX_POLL){        // 太长时间空闲(900秒)，终止连接！
  372.                                 msip_Close();
  373.                                 //SP_CLOSE_FIQ();                // 关闭FIQ中断，同时也禁止了ADAC
  374.                 }
  375.                 guwEthLen = 1460;
  376.                 return;
  377.         }

  379.         if (msip_Aborted() || msip_Closed()){        // 如果异常关闭，那就关闭当前连接
  380.                 //SP_CLOSE_FIQ();                // 关闭FIQ中断，同时也禁止了ADAC
  381.                 return;
  382.         }


  385.         return;
  386. #endif





  392. // 以下部分用于Ping功能失效时的网络测试！TMD现在网络病毒太多，许多ISP运营商都禁Ping了！
  393. // 不管是否传数据，都将在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){        // 太长时间空闲，终止连接！
  430.                         msip_Close();
  431.                 }

  433.                 return;
  434.         }


  437.         if (msip_Connected()){
  438.                 gptConn->PollTime = 0;        // 清除空闲时间记数
  439.                 return;
  440.         }

  442. //        if (msip_Aborted() || msip_Closed()){        // 如果异常关闭，那就关闭当前连接
  443.                 // Nothing to do!
  444. //                return;
  445. //        }

  447.         return;
  448. }
复制代码




分享到:  QQ好友和群QQ好友和群 QQ空间QQ空间 腾讯微博腾讯微博 腾讯朋友腾讯朋友
收藏收藏 分享淘帖 顶顶 踩踩
回复

使用道具 举报

返回列表 发新帖
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

手机版|小黑屋|51黑电子论坛 |51黑电子论坛6群 QQ 管理员QQ:125739409;技术交流QQ群281945664

Powered by 单片机教程网

快速回复 返回顶部 返回列表