Windows C語言 Socket程式設計 client端(客戶端)--斷線重連版
阿新 • • 發佈:2019-01-03
瞭解了最基礎的C語言客戶端的編寫流程,稍稍加以改動即可實現斷線重連。
當伺服器掉線時,客戶端會以固定的頻率不停的重連。
#include <stdio.h>
#include <winsock2.h>
#pragma comment(lib,"ws2_32.lib")
static SOCKET socket_client; //本地建立的客戶端socket
static struct sockaddr_in server_in; //用於儲存伺服器的基本資訊
static void analysis(char* data, int datal);
static void reconnect();
int main(int argc, char* argv[])
{
char recData[255]; //這個地方一定要酌情設定大小,這決定了每次能獲取多少資料
int ret; //recv函式的返回值 有三種狀態每種狀態的含義在下方有解釋
WORD socket_version;
WSADATA wsadata;
socket_version = MAKEWORD(2,2);
if(WSAStartup(socket_version, &wsadata) != 0 )
{
printf("wsastartup error !");
system("pause");
return;
}
reconnect();
while(1)
{
ret = recv(socket_client, recData, 255, 0);
/************************************************************************
recv函式 的實質就是從socket的緩衝區裡拷貝出資料
返回值就是拷貝出位元組數的大小。
上面定義的載體(revData)大小是255,所以recv的第三個引數最大隻能設定為255,
如果設定為大於255的數值,當執行recv函式時恰好緩衝區的內容大於255,
就會導致記憶體洩漏,導致ret值小於零,解除阻塞狀態。因此這裡最好將第三個引數
設定為revData的大小,那麼當緩衝區內的資料小於255的時候
只需要執行一次recv就可以將緩衝區的內容都拷貝出來,但當緩衝區的資料大
於255的時候,就要執行多次recv函式。當緩衝區內沒有內容的時候,會處於阻塞
狀態,這個while函式會停在這裡。直到新的資料進來或者出現異常。
************************************************************************/
if(ret > 0)
{
recData[ret] = 0x00;//正常情況下不必這麼做,我這麼做只是為了能按字串的形式輸出它
analysis(recData, ret);
}
else if(ret == 0)
{
//當ret == 0 說明伺服器掉線。
printf("lost connection , Ip = %s\n", inet_ntoa(server_in.sin_addr));
closesocket(socket_client);
reconnect();//重連
//break;注意這裡不要跳出這個迴圈,要是跳出的話這個程式就停止了
}
else//ret < 0
{
//當ret < 0 說明出現了異常 例如阻塞狀態解除,或者讀取資料時出現指標錯誤等。
//所以我們這裡要主動斷開和客戶端的連結。
printf("something wrong of %s\n", inet_ntoa(server_in.sin_addr));
closesocket(socket_client);
reconnect();//重連
//break;注意這裡不要跳出這個迴圈,要是跳出的話這個程式就停止了
}
}
closesocket(socket_client);
WSACleanup();
return 0;
}
void reconnect()
{
socket_client = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
if(socket_client == INVALID_SOCKET)
{
printf("invalid socket !");
system("pause");
return;
}
server_in.sin_family = AF_INET; //IPV4協議族
server_in.sin_port = htons(6666); //伺服器的埠號
server_in.sin_addr.S_un.S_addr = inet_addr("127.0.0.1"); //服務IP
while(connect(socket_client, (struct sockaddr *)&server_in, sizeof(server_in)) == SOCKET_ERROR)
{
printf("connection failed,reconnection after 3 seconds。\n");
Sleep(3 * 1000);
}
printf("connect %s:%d\n", inet_ntoa(server_in.sin_addr), server_in.sin_port);
send(socket_client, "hello i am client", strlen("hello i am client"), 0);
}
static void analysis(char* data, int datal)
{
printf("recv data:%s datal:%d\n", data, datal);
//在這裡我們可以對已接收到的資料進行處理
//一般情況下這裡都是處理“粘包”的地方
//解決粘包之後 將完整的資料傳送給資料處理函式
}