天天看點

基于TCP的半雙工網絡程式設計實踐

作者:編碼小哥

首先我們先了解一下什麼是半雙工通信?

半雙工資料傳輸允許資料在兩個方向上傳輸,但是在某一時刻,隻允許資料在一個方向上傳輸,它實際上是一種切換方向的單工通信。

TCP服務端代碼:

#include <stdio.h>

#include <string.h>

#include <stdlib.h>

#include <netdb.h>

#include <netinet/in.h>

#include <stdint.h>

#include <sys/socket.h>

#include <sys/types.h>

#include <unistd.h>

#define PORT 8100

/* 列印錯誤資訊 */

void error()

{

perror("Socket Creation Failed");

exit(EXIT_FAILURE);

}

int main()

{

uint32_t sockfd,conn;

char server_msg[10000],client_msg[10000];

struct sockaddr_in server_addr,client_addr;

/* 建立流式套接字 */

if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0)

{

error();

}

/* 服務端綁定位址和端口 */

bzero(&server_addr, sizeof(server_addr));

server_addr.sin_family = AF_INET;

server_addr.sin_port = htons(PORT);

server_addr.sin_addr.s_addr = htonl(INADDR_ANY);

printf("Server is running...\n");

/* 綁定socket到服務端 */

if (bind(sockfd, (struct sockaddr *)&server_addr, sizeof(server_addr)) < 0)

{

error(); /// If binding is unsuccessful

}

/* 監聽用戶端,監聽的數量上限,我們這裡設定為5 */

listen(sockfd, 5);

printf("Server is listening...\n");

/* 當服務端發現有新的連接配接請求,服務端建立一個socket描述符響應accept,用來發送和接收資料 */

conn = accept(sockfd, (struct sockaddr *)NULL, NULL);

printf("Server is connected...\n");

while (1)

{

bzero(&server_msg, sizeof(server_msg));

bzero(&client_msg, sizeof(client_msg));

/* 發送消息 */

printf("\nEnter message here: ");

fgets(server_msg, 10000, stdin);

send(conn, server_msg, strlen(server_msg) + 1, 0);

/* 接收消息 */

recv(conn, client_msg, sizeof(client_msg), 0);

printf("\nClient Message: %s\n", client_msg);

}

/* 關閉socket */

close(sockfd);

printf("Server is offline...\n");

return 0;

}

服務端運作狀态:

基于TCP的半雙工網絡程式設計實踐

TCP用戶端代碼:

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include <netdb.h>

#include <netinet/in.h>

#include <stdint.h>

#include <sys/socket.h>

#include <sys/types.h>

#include <unistd.h>

#define PORT 8100

void error()

{

perror("Socket Creation Failed");

exit(EXIT_FAILURE);

}

int main()

{

uint32_t sockfd;

struct sockaddr_in server_addr;

char serverResponse[10000],clientResponse[10000];

/* 用戶端建立socket */

if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0)

{

error();

}

bzero(&server_addr, sizeof(server_addr));

server_addr.sin_family = AF_INET;

server_addr.sin_port = htons(PORT);

server_addr.sin_addr.s_addr = htonl(INADDR_ANY);

printf("Client is running...\n");

/* 連接配接服務端 */

connect(sockfd, (struct sockaddr *)&server_addr, sizeof(server_addr));

printf("Client is connected...\n");

while (1)

{

bzero(&serverResponse, sizeof(serverResponse));

bzero(&clientResponse, sizeof(clientResponse));

/* 接收消息 */

recv(sockfd,serverResponse,sizeof(serverResponse), 0);

printf("\nServer-message:%s\n", serverResponse);

/* 發送消息 */

printf("\nEnter message here: ");

fgets(clientResponse, 10000, stdin);

send(sockfd, clientResponse, strlen(clientResponse) + 1, 0);

}

/* 關閉socket */

close(sockfd);

printf("Client is offline...\n");

return 0;

}

用戶端運作狀态:

基于TCP的半雙工網絡程式設計實踐

繼續閱讀