多程序併發C/S通訊基本模型及實現
阿新 • • 發佈:2019-01-06
本例實現如下功能:
服務端接收來自客戶端傳送過來的字串,將小寫轉換為大寫後傳送回客戶端。
其中,每一個新客戶端連線後,服務端主程序為此客戶端建立一個子程序進行資料的處理。
多程序併發服務端程式碼:
/*server.c*/
#include <stdio.h>
#include <string.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <signal.h>
#include <sys/wait.h>
#include <sys/types.h>
#include <stdlib.h>
#include <errno.h>
#include <sys/socket.h>
#define BUFSIZE 666
#define SERV_PORT 8888
int main()
{
struct sockaddr_in servaddr, cliaddr;
socklen_t cliaddr_len;
int listenfd, connfd;
char buf[BUFSIZE];
char str[INET_ADDRSTRLEN];
int i, n;
pid_t pid;
listenfd = socket(AF_INET, SOCK_STREAM, 0 ); //開啟一個網路通訊埠,分配一個檔案描述符listenfd
bzero(&servaddr, sizeof(servaddr)); //清空服務端套接字
servaddr.sin_family = AF_INET; //地址採用IPv4地址
servaddr.sin_addr.s_addr = htonl(INADDR_ANY);//地址從主機位元組順序轉換成網路位元組順序
servaddr.sin_port = htons(SERV_PORT); //埠號從主機位元組順序轉換成網路位元組順序
/*將檔案描述符listenfd和伺服器地址繫結在一起*/
bind(listenfd, (struct sockaddr*)&servaddr, sizeof(servaddr));
/*宣告listenfd處於監聽狀態,連結個數限制為5*/
listen(listenfd, 20);
printf("等待連線....\n");
while(1){
cliaddr_len = sizeof(cliaddr);
/*connfd檔案描述符用於和客戶端通訊,服務端呼叫accept()接受連線*/
connfd = accept(listenfd, (struct sockaddr*)&cliaddr, &cliaddr_len);
pid = fork();
if(pid == 0){ //建立一個子程序處理資料
close(listenfd);//關閉子程序端的監聽
while(1){
/*從connfd檔案描述符指向的檔案讀取資料*/
n = read(connfd, buf, BUFSIZE);
if(n == 0){
printf("另一端已關閉\n");
break;
}
/*服務端列印*/
printf("從地址%s 埠號%d 接收到資料\n",
(char*)inet_ntop(AF_INET, &cliaddr.sin_addr, str, sizeof(str)),
ntohs(cliaddr.sin_port));
/*將buf轉化為大寫後寫入connfd*/
for(i = 0; i < n;i++ ){
buf[i] = toupper(buf[i]);
}
write(connfd, buf, n);
}
close(connfd);//處理完畢關閉連線
exit(0);
}else if(pid > 0){ //父程序
close(connfd);//任務交由子程序處理,父程序關閉
}else{
printf("fork err\n");
}
if(n == 0 || n == -1){
break;
}
}
return 0;
}
多程序併發客戶端程式碼:
/*client.c*/
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <netinet/in.h>
#define BUFSIZE 666
#define SERV_PORT 8888
int main(int argc, char *argv[])
{
struct sockaddr_in servaddr;
char buf[BUFSIZE];
int sockfd, n;
sockfd = socket(AF_INET, SOCK_STREAM, 0);
bzero(&servaddr, sizeof(servaddr));
servaddr.sin_family = AF_INET;
inet_pton(AF_INET, "127.0.0.1", &servaddr.sin_addr);
servaddr.sin_port = htons(SERV_PORT);
/*連線伺服器*/
connect(sockfd, (struct sockaddr*)&servaddr, sizeof(servaddr));
while(fgets(buf, BUFSIZE, stdin) != NULL){
write(sockfd, buf, strlen(buf));
/*接收服務端資料*/
n = read(sockfd, buf, BUFSIZE);
if(n == 0){
printf("server closed\n");
}else{
/*列印輸出buf*/
write(STDOUT_FILENO, buf, n);
}
}
close(sockfd);
return 0;
}
執行測試:
yu@ubuntu:~/Linux/219/duojincheng$ ls
client.c server.c
yu@ubuntu:~/Linux/219/duojincheng$ gcc -o server server.c
yu@ubuntu:~/Linux/219/duojincheng$ gcc -o client client.c
yu@ubuntu:~/Linux/219/duojincheng$ ./server
等待連線....
從地址127.0.0.1 埠號32874 接收到資料
從地址127.0.0.1 埠號32874 接收到資料
從地址127.0.0.1 埠號32875 接收到資料
從地址127.0.0.1 埠號32874 接收到資料
從地址127.0.0.1 埠號32875 接收到資料
另開一終端執行客戶端:
yu@ubuntu:~/Linux/219/duojincheng$ ./client
hey guys
HEY GUYS
guole bye
GUOLE BYE
另開一終端執行客戶端:
yu@ubuntu:~/Linux/219/duojincheng$ ./client
nihao ma wo hen hao ne
NIHAO MA WO HEN HAO NE
zai jian
ZAI JIAN
ssssssssssssss
SSSSSSSSSSSSSS