2. 程式人生 > 其它 >C++中簡單使用HP-Socket

C++中簡單使用HP-Socket

阿新 • • 發佈：2021-11-12
HP-Socket 是一套通用的高效能 TCP/UDP /HTTP 通訊 框架 ，包含服務端元件、客戶端元件和 Agent 元件，廣泛適用於各種不同應用場景的 TCP/UDP /HTTP 通訊系統，提供 C/C++ 、 C# 、 Delphi 、 E （易語言）、 Java 、 Python 等程式語言介面。 HP-Socket包含30多個元件 ，可根據通訊角色Client/Server）、通訊協議TCP/UDP/HTTP）和接收模型PUSH/PULL/PACK）進行歸類，支援PUSH、PULL和PACK三種接收模型。 目錄

簡介

HP-Socket 是一套通用的高效能 TCP/UDP /HTTP 通訊 框架 ，包含服務端元件、客戶端元件和 Agent 元件，廣泛適用於各種不同應用場景的 TCP/UDP /HTTP 通訊系統，提供 C/C++ 、 C# 、 Delphi 、 E （易語言）、 Java 、 Python 等程式語言介面。

HP-Socket是一套國產的開源通訊庫，使用C++語言實現，提供多種程式語言的介面，支援 Windows 和 Linux 平臺：

HP-Socket包含30多個元件 ，可根據通訊角色Client/Server）、通訊協議TCP/UDP/HTTP）和接收模型PUSH/PULL/PACK）進行歸類，這裡只簡單介紹一下：

  • Server元件：基於IOCP/EPOLL通訊模型 ，並結合快取池 、私有堆等技術實現高效記憶體管理，支援超大規模、高併發通訊場景。
  • Agent元件：實質上是Multi-Client元件，與Server元件採用相同的技術架構，可同時建立和高效處理大規模Socket連線 。
  • Client元件：基於Event Select/POLL通訊模型，每個元件物件建立一個通訊執行緒並管理一個Socket連線， 適用於小規模客戶端場景。
  • Thread Pool元件：HP-Socket實現的高效易用的執行緒池元件，當成普通的第三方執行緒池庫使用即可。

HP-Socket的TCP元件支援PUSH、PULL和PACK三種接收模型：

  • PUSH模型：元件接收到資料時會觸發監聽器物件的OnReceive(pSender,dwConnID,pData,iLength)事件，把資料“推”給應用程式，這種模型使用起來是最自由的。
  • PULL模型：元件接收到資料時會觸發監聽器物件的OnReceive(pSender,dwConnID,iTotalLength)事件 ，告訴應用程式當前已經接收到多少資料，應用程式檢查資料的長度，如果滿足需要則呼叫元件的**Fetch(dwConnID,pData,iDataLength)方法把需
    要的資料“拉”出來。
  • PACK模型：PACK模型系列元件是PUSH和PULL模型的結合體，應用程式不必處理分包與資料抓取,元件保證每個OnReceive事件都向應用程式提供一個完整資料包。

注：PACK模型元件會對應用程式傳送的每個資料包自動加上 4 位元組（32位的包頭），前10位為用於資料包校驗的包頭標識位，後22位為記錄包體長度的長度位。

使用方式

HP-Socket支援MBCS和Unicode字符集，支援32位和64位應用程式。可以通過原始碼、 DLL或LIB方式使用HP-Socket。 HP-Socket發行包中已經提供了HPSocket DLL和HPSocket4C DLL。
HP-Socket提供了各種情況下的dll檔案，不需要我們重新編譯，dll檔案按程式設計介面分為兩大類：

  • HPSocket DLL：匯出C++程式設計介面 ，C++程式的首選方式，使用時需要把SocketInterface.h（及其依賴檔案HPTypeDef.h） 、HPSocket.h以及 DLL 對應的 *.lib 檔案加入到工程專案，用到SSL元件還需要HPSocket-SSL.h檔案。
  • HPSocket4C DLL：匯出C程式設計介面，提供給C語言或其它程式語言使用，使用時需要把HPSocket4C.h以及 DLL 對應的 *.lib 檔案加入到工程專案，用到SSL元件還需要HPSocket4C-SSL.h檔案。

實現簡單執行緒池

使用HP-Socket的執行緒池元件可以在程式中實現一個簡單的、公用的執行緒池，TCP通訊的斷線重連、傳送心跳都會用到執行緒池。執行緒池元件的主要函式如下：

  • Start：啟動執行緒池，具體的使用可以參考原始碼的註釋。
  • Submit：提交任務，主要使用BOOL Submit(fnTaskProc,pvArg,dwMaxWait=INFINITE)，另一個函式過載是使用一個特殊的資料型別（把Socket任務引數和任務函式封裝成一個數據結構）作為引數。
  • Stop：關閉執行緒池，引數dwMaxWait代表最大等待時間（毫秒，預設： INFINITE ，一直等待）。

先實現執行緒池的CHPThreadPoolListener介面，然後構造IHPThreadPool智慧指標，後面執行緒池的操作都通過智慧指標操作，程式碼如下：

class CHPThreadPoolListenerImpl : public CHPThreadPoolListener
{
private:
	void LogInfo(string logStr)
	{
		cout <<"ThreadPool " <<logStr << endl;
	}
public:
	virtual void OnStartup(IHPThreadPool* pThreadPool) 
	{
		LogInfo("執行緒池啟動");
	}
	virtual void OnShutdown(IHPThreadPool* pThreadPool) 
	{
		LogInfo("執行緒池啟動關閉");
	}
	virtual void OnWorkerThreadStart(IHPThreadPool* pThreadPool, THR_ID dwThreadID) 
	{				
		LogInfo("[" + to_string(dwThreadID) + "] " + "工作執行緒啟動");
	}
	virtual void OnWorkerThreadEnd(IHPThreadPool* pThreadPool, THR_ID dwThreadID) 
	{
		LogInfo("[" + to_string(dwThreadID) + "] " + "工作執行緒退出");
	}
};

CHPThreadPoolListenerImpl ThreadPoolListener;
//全域性共享變數使用extern關鍵字修飾
extern CHPThreadPoolPtr ThreadPool(&ThreadPoolListener);

實現TCP客戶端

先實現一個列印函式，顯示客戶端相關的資訊，程式碼如下：

void PrintInfo(ITcpClient* pSender, CONNID dwConnID)
{
	char buffer[20];	
	TCHAR* ipAddr = buffer;
	int ipLen;
	USHORT port;

	pSender->GetLocalAddress(ipAddr, ipLen, port);	
	cout << string(ipAddr,0,ipLen) << ":" << port << " " << " [" << dwConnID << "] -> ";

	pSender->GetRemoteHost(ipAddr, ipLen, port);	
	cout << string(ipAddr, 0, ipLen) << ":" << port << " ";
}

實現CTcpClientListener監聽介面，客戶端斷線後自動重連，以換行符分割接收到的字串，程式碼如下：

bool SysExit = false;
void ReConnect(ITcpClient* pSender)
{
	while (pSender->GetState() != SS_STOPPED)
	{
		Sleep(10);
	}
	pSender->Start("127.0.0.1", 60000);
}

class CClientListenerImpl : public CTcpClientListener
{

public:	
	virtual EnHandleResult OnConnect(ITcpClient* pSender, CONNID dwConnID) 
	{ 
		PrintInfo(pSender, dwConnID);
		cout << "連線成功" << endl;
		return HR_OK;		
	}

	string resStr = "";
	string commStr="";
	virtual EnHandleResult OnReceive(ITcpClient* pSender, CONNID dwConnID, const BYTE* pData, int iLength) 
	{
		
		string str((char*)pData,0, iLength);
		resStr.append(str);
		int index;
		while (true)
		{
			index = resStr.find("\r\n");
			if (index == -1)break;

			commStr = resStr.substr(0, index);
			resStr = resStr.substr(index +2, resStr.length() - (index +2));
			if (commStr!="")
			{
				PrintInfo(pSender, dwConnID);
				cout << "收到分割字串 " << commStr << endl;
			}
		}	

		PrintInfo(pSender, dwConnID);
		cout << "資料接受 " << str << endl;

		return HR_OK;
	}

	virtual EnHandleResult OnClose(ITcpClient* pSender, CONNID dwConnID, EnSocketOperation enOperation, int iErrorCode)
	{
		resStr = "";

		PrintInfo(pSender, dwConnID);
		cout << "連線斷開，"<< enOperation <<"操作導致錯誤，錯誤碼 " << iErrorCode<< endl;
		if (!SysExit) 
		{
			ThreadPool->Submit((Fn_TaskProc)(&ReConnect), (PVOID)pSender);
		}		
		return HR_OK;
	}	
};

迴圈輸入字串傳送服務端，程式碼如下：

int main()
{
	//啟動執行緒池
	ThreadPool->Start();

	CClientListenerImpl listener;
	CTcpClientPtr client(&listener);

	if (!client->Start("127.0.0.1", 60000))
	{
		cout << "連線錯誤：" << client->GetLastError() << "-" << client->GetLastErrorDesc();
	}
	
	string sendMsg;
	while (!SysExit)
	{		
		cin >> sendMsg;
		if (sendMsg == "esc") 
		{
			SysExit = true;
			break;
		}

		if (client->GetState() == SS_STARTED) 
		{
			const BYTE* data = (BYTE*)(sendMsg.c_str());
			if (client->Send(data, sizeof(data)))
			{
				PrintInfo(client, client->GetConnectionID());
				cout << "傳送成功 "<<sendMsg<<endl;
			}
			else
			{
				PrintInfo(client, client->GetConnectionID());
				cout << "傳送失敗，錯誤描述 " << client->GetLastError() << "-" << client->GetLastErrorDesc() << endl;
			}
		}
		else 
		{
			PrintInfo(client, client->GetConnectionID());			
			cout << "無法傳送，當前狀態 " <<client->GetState()<< endl;
		}
	}	
	client->Stop();
	//關閉執行緒池
	ThreadPool->Stop();

	return 0;	
}

實現TCP服務端

先實現一個列印函式，基本上和客戶端的相同，只有獲取本地IP的地方不同，程式碼如下：

void PrintInfo(ITcpServer* pSender, CONNID dwConnID)
{
	char buffer[20];
	TCHAR* ipAddr = buffer;
	int ipLen;
	USHORT port;

	pSender->GetListenAddress(ipAddr, ipLen, port);
	cout << string(ipAddr, 0, ipLen) << ":" << port << " " << "<-  [" << dwConnID << "] ";

	pSender->GetRemoteAddress(dwConnID, ipAddr, ipLen, port);
	cout << string(ipAddr, 0, ipLen) << ":" << port << " ";
}

為了演示客戶端和應用資料的繫結，定義一個使用者資料型別並建立一個佇列，程式碼如下：

class UserData 
{
public:
	UserData(string name="") 
	{
		Name = name;
	}
	string Name;
};
queue<UserData*> qName;  //建立佇列物件

實現CTcpServerListener監聽介面，收到字串後加上使用者名稱再發送回去，程式碼如下：

class CTcpServerListenerImpl : public CTcpServerListener
{
public:	
	virtual EnHandleResult OnAccept(ITcpServer* pSender, CONNID dwConnID, UINT_PTR soClient)
	{ 

		pSender->SetConnectionExtra(dwConnID,qName.front());
		qName.pop();
		PrintInfo(pSender, dwConnID);
		cout << "連線成功" << endl;
		return HR_OK;
	}
	virtual EnHandleResult OnReceive(ITcpServer* pSender, CONNID dwConnID, const BYTE* pData, int iLength)
	{ 
		string str((char*)pData, 0, iLength);
		PrintInfo(pSender, dwConnID);
		cout << "資料接受 " << str<<endl;

		PVOID pInfo = nullptr;		
		pSender->GetConnectionExtra(dwConnID, &pInfo);
		str = "reply-" + ((UserData*)pInfo)->Name + str;

		const BYTE* data = (BYTE*)(str.c_str());		
		pSender->Send(dwConnID, data,str.size());
		return HR_OK;
	}	
	virtual EnHandleResult OnClose(ITcpServer* pSender, CONNID dwConnID, EnSocketOperation enOperation, int iErrorCode)
	{
		PVOID pInfo = nullptr;
		pSender->GetConnectionExtra(dwConnID, &pInfo);
		qName.push((UserData*)pInfo);
		PrintInfo(pSender, dwConnID);
		cout << "斷開連線"<< endl;

		pSender->SetConnectionExtra(dwConnID, NULL);		
		return HR_OK;
	}
};

迴圈輸入字串傳送到客戶端，自動回覆客戶端傳送的訊息，程式碼如下：

bool SysExit = false;
int main()
{	
	UserData user1("NO1-User");
	UserData user2("NO2-User");
	UserData user3("NO3-User");
	UserData user4("NO4-User");

	qName.push(&user1);
	qName.push(&user2);
	qName.push(&user3);
	qName.push(&user4);

	CTcpServerListenerImpl listener;
	CTcpServerPtr server(&listener);
		
	if (!server->Start("127.0.0.1", 60000))
	{
		cout << "啟動錯誤：" << server->GetLastError() << "-" << server->GetLastErrorDesc();
	}
	
	string sendMsg;
	while (!SysExit)
	{
		cin >> sendMsg;
		if (sendMsg == "esc")
		{
			SysExit = true;
			break;
		}

		//如果陣列長度小於當前連線數量，則獲取失敗
		DWORD count= 1000;			
		CONNID pIDs[1000]; 
		ZeroMemory(pIDs, 1000);;

		if (server->GetAllConnectionIDs(pIDs, count)&& count >0)
		{
			for (size_t i = 0; i < count; i++)
			{
				const BYTE* data = (BYTE*)(sendMsg.c_str());
				if (server->Send(*(pIDs+i),data, sendMsg.size()))
				{
					PrintInfo(server, pIDs[i]);
					cout << "傳送成功 " << sendMsg << endl;
				}
				else
				{
					PrintInfo(server, pIDs[i]);
					cout << "傳送失敗，錯誤描述 " << server->GetLastError() << "-" << server->GetLastErrorDesc() << endl;
				}
			}		
		}
		else
		{			
			cout << "無法傳送，當前連線數 " << count << endl;
		}
	}
	server->Stop();
}

注：獲取連線時指標陣列的長度一定要大於當前連線數量，否則會失敗。

實現Http客戶端

HP-Socket的Http客戶端有同步、非同步兩種，同步客戶端不需要繫結監聽器，這裡使用同步客戶端演示。

Sync Client：同步HTTP客戶端元件（CHttpSyncClient和CHttpsSyncClient）內部會處理所有事件，因此，它們不需要繫結監聽器（構造方法的監聽器引數傳入null）; 如果綁定了監聽器則可以跟蹤元件的通訊過程。

測試客戶端可以使用實時天氣介面上面的測試示例，當前的測試示例為：

http://api.k780.com/?app=weather.today&weaId=1&appkey=10003&sign=b59bc3ef6191eb9f747dd4e83c99f2a4&format=json

直接開始測試，程式碼如下：

int main()
{
    CHttpSyncClientPtr SyncClient;
    THeader type;
    type.name = "Content-Type";
    type.value = "text/html;charset=UTF-8";
    
    if (SyncClient->OpenUrl("GET", "http://api.k780.com/?app=weather.today&weaId=1&appkey=10003&sign=b59bc3ef6191eb9f747dd4e83c99f2a4&format=json",&type))
    {
        LPCBYTE pData = nullptr;
        int iLength = 0;
        SyncClient->GetResponseBody(&pData, &iLength);        
        string body((char*)pData, iLength);
        //返回的有中文，需要轉化編碼格式
        cout << body << endl;        
        cout << endl;
        cout << StringToUtf(body) << endl;
        cout << endl;
        cout << UtfToString(StringToUtf(body)) << endl;
    }
    else
    {
        cout << "開啟失敗："<<SyncClient->GetLastError()<<"-"<< SyncClient->GetLastErrorDesc()<<endl;
    }   
}

上面的StringToUtf和UtfToString函式是轉載至C++ 中文亂碼的問題，該函式實現UTF-8和ANSI編碼格式的轉化，程式碼如下：

string UtfToString(string strValue)
{
    int nwLen = ::MultiByteToWideChar(CP_ACP, 0, strValue.c_str(), -1, NULL, 0);
    wchar_t* pwBuf = new wchar_t[nwLen + 1];//加上末尾'\0'
    ZeroMemory(pwBuf, nwLen * 2 + 2);
    ::MultiByteToWideChar(CP_ACP, 0, strValue.c_str(), strValue.length(), pwBuf, nwLen);
    int nLen = ::WideCharToMultiByte(CP_UTF8, 0, pwBuf, -1, NULL, NULL, NULL, NULL);
    char* pBuf = new char[nLen + 1];
    ZeroMemory(pBuf, nLen + 1);
    ::WideCharToMultiByte(CP_UTF8, 0, pwBuf, nwLen, pBuf, nLen, NULL, NULL);
    std::string retStr(pBuf);
    delete[]pwBuf;
    delete[]pBuf;
    pwBuf = NULL;
    pBuf = NULL;
    return retStr;
}

string StringToUtf(string strValue)
{
    int nwLen = MultiByteToWideChar(CP_UTF8, 0, strValue.c_str(), -1, NULL, 0);
    wchar_t* pwBuf = new wchar_t[nwLen + 1];//加上末尾'\0'
    memset(pwBuf, 0, nwLen * 2 + 2);
    MultiByteToWideChar(CP_UTF8, 0, strValue.c_str(), strValue.length(), pwBuf, nwLen);
    int nLen = WideCharToMultiByte(CP_ACP, 0, pwBuf, -1, NULL, NULL, NULL, NULL);
    char* pBuf = new char[nLen + 1];
    memset(pBuf, 0, nLen + 1);
    WideCharToMultiByte(CP_ACP, 0, pwBuf, nwLen, pBuf, nLen, NULL, NULL);
    std::string retStr = pBuf;
    delete[]pBuf;
    delete[]pwBuf;
    return retStr;
}

注：函式實現需放在main函式之前。

附件

相關推薦

C++中簡單使用HP-Socket

HP-Socket 是一套通用的高效能 TCP/UDP /HTTP 通訊 框架 ，包含服務端元件、客戶端元件和 Agent 元件，廣泛適用於各種不同應用場景的 TCP/UDP /HTTP 通訊系統，提供 C/C++ 、 C# 、 Delphi 、 E （易語言）、 Java

C#中簡單的正則表示式

學習C#中簡單的正則表示式 感謝千峰教育的學習視訊 正則表示式：用來判斷某個字串是否匹配一定的格式

C#中BitConverter.ToUInt16()和BitConverter.ToString()的簡單使用

下面是msdn中的一個例子，在我剛看到這裡例子時，該例子有三點是我可以學到的。

SQL Server儲存過程在C#中呼叫的簡單實現方法

0. 簡介 【定義】：儲存過程（Stored Procedure） 是在大型資料庫系統中，一組為了完成特定功能的SQL 語句集，它儲存在資料庫中，一次編譯後永久有效，使用者通過指定儲存過程的名字並給出引數（如果該儲存過程帶有引

c#中使用OLEDB簡單操作Excel檔案

使用OLEDB操作Excel 關於OLEDB介紹參考 http://www.cnblogs.com/moss_tan_jun/archive/2012/07/28/2612889.html

c#中json的簡單使用

JSON是儲存和交換文字資訊的語法，類似XML。比XML更小，更快，更易解析，和XML一樣是一種資料格式。這裡使用litjson簡單讀取一下文字資訊。

簡單介紹C# 中的擴充套件方法

擴充套件方法是C#3.0引入的新特性，使用它，可以在不修改某一類的程式碼的情況下，實現該類方法的擴充套件。

C/C++中，利用curl庫函式傳送簡單的POST請求

技術標籤：c/c++httpjsonc++c語言 C/C++中，利用curl庫函式傳送簡單的POST請求 void curl_post(const char *json)

C#中的非同步程式設計--探索await與async關鍵字的奧妙之處，原來理解和使用非同步程式設計可以這麼簡單

技術標籤：C#教程c# 前言 await與async是C#5.0推出的新語法，關於await與async有很多文章講解。但看完後有沒有這樣一種感覺，感覺這東西像是不錯，但好像就是看不太懂，也不清楚該怎麼使用。雖然偶有接觸，但是一

C#中File和FileStream的簡單介紹和用法

前言 在近期的工作過程中發現自己的基礎比較薄弱，所以最近在惡補基礎知識。下面就對我所學習的File類和FileStream進行簡單的總結。

C# 中，使用 Math.Round 方法時，需要注意這不是簡單的四捨五入！

> 為什麼 Math.Round(4.125, 2) 的結果是 4.12 而不是 4.13 在計算機中對浮點數的處理是按 IEEE 754 標準進行的，同時該標準對舍入規則也做了約定。 預設情況下，使用 Math.Round 方法時執行的舍入規則，主要是中

c++中函式分檔案編寫簡單小例子

技術標籤：小練習c++ 函式分檔案編寫四步驟： 1.建立字尾名為.h的標頭檔案 2.建立字尾名為.cpp的原始檔 3.在標頭檔案中寫函式的宣告 4.在原始檔中寫函式的定義

C# 在WinForm 中簡單實現雙向繫結 VM

/// <summary> /// 將繫結資料來源和控制元件繫結 /// </summary> /// <param name=\"ctl\">控制元件</param>

C#中IEumerable的簡單瞭解

參考網址：https://blog.csdn.net/qq_39806817/article/details/115024666 一、IEnumerable簡單介紹IEnumerable是可列舉型別，一般在迭代時應用廣泛，如foreach中要迴圈訪問的集合或陣列都實現了IEnumerable介面。只

在C#中利用Keep-Alive處理Socket網路異常斷開的方法

　　最近我負責一個IM專案的開發，服務端和客戶端採用TCP協議連線。服務端採用C#開發，客戶端採用Delphi開發。在服務端開發中我碰到了各種各樣的網路異常斷開現象。在處理這些異常的時候有了一些心得，現在寫出來和

簡單談談c/c++中#import、#include和@class的區別

對於#import，我想做過iOS開發的人應該都不陌生。在開發過程中，當我們需要宣告某一個類時，都需要去引用。而#imclude的話，在我們學習C時就已經知道了，他的作用也是引用宣告的意思。在表面上他們的作用似乎都是一

簡單討論C中的字元陣列相關的問題

1.字元陣列跟字元指標有什麼區別？ 首先我們知道，定義一個字元陣列如下：

在C#中使用正則表示式最簡單的方式

更新記錄 本文遷移自Panda666原部落格，原發布時間：2021年5月11日。 在.NET中使用正則表示式與其他語言並無太大差異。最簡單的使用就是使用Regex型別自帶的靜態方法。

理解Objective-C中的物件

本文以同步釋出到個人部落格，為獲得更好的閱讀體驗，請訪問這裡 OC是C語言的超集，在其之上提供了面向物件的能力。可我們面向的物件在OC中到底是個什麼東西，或者說它在記憶體中如何表現呢？今天我們一起來說道說

如何優雅地管理C++ 中的記憶體

C++的記憶體管理 C++是一門Native Language，而說到Native Languages就不得不說資源管理，其中記憶體管理又是資源管理中的一個大問題，由於堆記憶體需要手動分配和釋放，所以必須確保申請的記憶體得到正確的釋放。對