EtherNet/IP开发：C++搭建基础模块，EtherNet/IP源代码

这里是CIP资料的协议层级图，讲解协议构造。

ODVA（www.ODVA.org）成立于1995年，是一个全球性协会，其成员包括世界领先的自动化公司。结合其成员的支持，ODVA的使命是在工业自动化中推进开放、可互操作的信息和通信技术。成员团体的基础是其在制定标准和促进通过《共同工业议定书》方面的主要共同利益™), ODVA的媒体独立网络协议，以及CIP–EtherNet/IP的网络适配™, DeviceNet™, CompoNet™ 和ControlNet™. ODVA管理这些技术，并在一个通用结构中开发和分发这四个网络的规范，以帮助确保一致性和准确性。下图说明了由四个网络组成的库的组织结构。

中文总线资料和方案 www.jngbus.com

广州金南瓜科技

我们可以看到，其中一个EtherNet/IP是基于TCP/UDP之上。

那么我们就可以理解为，基于socket应用之上就可以了。

如果只是纯应用角度去开发EtherNet/IP，可以借助一些成熟的socket库。奈何我们早期学C++的人，没有那么多成熟模块，都是靠自己撸出来。

把TCP/IP通讯单独做成一个dll

① 目的是后续我们讲解开发modbus tcp、profinet等这些以太网协议时候，就不需要每种协议都单独写一次TCP/UDP通讯了

头文件代码


// 用于TCP/IP通讯
class CTcpCommunication : public CTcpCommExport
{
public:
    CTcpCommunication();
    virtual ~CTcpCommunication();

    // 释放
    void Release();    

    void SetCallback(OnCommDataHandle* pDataCallback, OnCommEventNotify* pEventCallback, void* pObject);
    CResult Connect(const char* pIP, __int32 nPort);        // 连接
    void Disconnect();                                        // 关闭连接
    CResult SendData(const char* pData, __int32 nSize);        // 数据发读
    void SetLanguage(__int32 nType);

protected:

    // 数据接收    
private:
    
    void InitSockWSA();
    void ReleaseSockWSA();

    // 接收数据线程
    void CreateRecvThread();        // 创建接收线程
    void ExitRecvThread();            // 退出接收线程
    static void RunRecvThread(void* lp);
    void RecvHandle();
    bool IsExitThread();
    void OneRecvData();                // 一次接收数据
    void StartRecvData();            // 开始接收数据
    void StopRecvData();            
    void CloseConnect();            // 关闭通讯

private:

    CData m_pData;

};

② socket处理很简单，其实就是围绕着收发

connect和send、recv

至于性能问题，就是如何优化在这处理和同步问题了。

程序稳定可靠需要靠自身的积累了。

建立通讯代码。

	if(m_hSock == INVALID_SOCKET)
	{
		m_hSock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
		if(m_hSock != INVALID_SOCKET)
		{		
			if(connect(m_hSock, (struct sockaddr*)&m_pSA, sizeof(m_pSA)) < 0)
			{					
				closesocket(m_hSock);
				m_hSock = INVALID_SOCKET;	

				// MC TCP连接失败,请查看网络是否通讯上、或者端口问题
				return CResult(TCP_SOCKET_CONNECT_FAIL, GetLanguage(TCP_SOCKET_CONNECT_FAIL));			
			}	
		}
		else
		{
			return CResult(TCP_SOCKET_CREATE_FAIL,  GetLanguage(TCP_SOCKET_CREATE_FAIL));				
		}
	}

	return CResult();

发送数据