首先我們先了解一下什麼是半雙工通信?
半雙工資料傳輸允許資料在兩個方向上傳輸,但是在某一時刻,隻允許資料在一個方向上傳輸,它實際上是一種切換方向的單工通信。
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用戶端代碼:
#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;
}
用戶端運作狀态: