2. 程式人生 > >循序漸進學unix——上機記錄（七）,socket

循序漸進學unix——上機記錄（七）,socket

阿新 • • 發佈：2019-01-11

本次的主題是基本網路程式設計：socket，涉及到的概念比較多，就不詳細展開了。從程式設計角度簡單的說，為了在客戶端和伺服器之間建立一個連線，伺服器端需要依次呼叫這些函式：

  1. socket，獲得一個socket
  2. bind，將獲得的socket繫結到指定的地址和埠
  3. listen，讓此socket進入等待狀態，等待客戶端的連線
  4. accept，當建立起與客戶端之間的連線時，此函式返回代表此連線的socket。即類似於檔案描述符，我們可以把客戶端看作檔案，向網路上進行讀寫操作，從而完成通訊過程。
客戶端需要呼叫的函式：
  1. socket
  2. connect，向指定地址的伺服器的指定埠發起連線
伺服器和客戶端都需用到的通訊函式：
  1. send
  2. recv
詳細資訊和函式方法等就不贅述了，請參見man 文件。
下面來看幾道練習。 1. 從客戶端把使用者輸入的資訊傳送到伺服器，直到使用者輸入“over”。這是一道基礎題，直接上程式碼了。 server： 
#include <arpa/inet.h>
#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <errno.h>
#include <string.h>
#include <unistd.h>

int main(int argc, char *argv[])
{
	int numPort, lenMsg, i;
	int sockServ, sockClient;
	struct sockaddr_in adrServ, adrClient;
	char message[256];
	char * overMsg = "over";
	int adrSize = sizeof(adrClient);
	int yes = 1;

	if(argc < 2)
	{
		printf("syntaxe : %s numPort\n", argv[0]);
		return -1;
	}
	

	//set local addr and port
	numPort = atoi(argv[1]);
	adrServ.sin_addr.s_addr = INADDR_ANY;
	adrServ.sin_family = AF_INET;
	adrServ.sin_port = htons(numPort);
	bzero(&(adrServ.sin_zero), 8) ;
	
	//Get a socket
	if((sockServ = socket(PF_INET, SOCK_STREAM, 0)) == -1) { perror("sockServet"); return -1; }
	
	//We can set some param here.// paramètrage de la socket pour réutiliser le N° ce port sans délai
	if(setsockopt(sockServ, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(int)) == -1) { perror("setsockopt"); return -1; }

	// bind
	if(bind(sockServ, (struct sockaddr *)(&adrServ), sizeof(adrServ)) == -1) { perror("bind"); return -1; }

	// place la socket en écoute
	if(listen(sockServ, 1) == -1) { perror("listen"); return -1; }
	

	// wait for a connection from a client
	if((sockClient = accept(sockServ, (struct sockaddr *)(&adrClient), &adrSize)) == -1) { perror("accept"); return -1; }
	printf("New socket client : %s\n", inet_ntoa(adrClient.sin_addr));
	do
	{
		// Read a msg from client
		if((lenMsg = recv(sockClient, message, 256, 0)) == -1)
		{ perror("recv"); return -1; }
		message[lenMsg] = '\0';
		printf("New msg received : %s\n", message);
		//printf("New msg received : %s, %d\n", message, strcmp(message, overMsg));
		
	}while(strcmp(message, overMsg) != 0);	
	// fermeture de la connexion
	close(sockServ);
	
	return 0;
}


client： 
#include<stdio.h>
#include<stdlib.h>
#include<netinet/in.h>
#include<sys/types.h>
#include<unistd.h>
#include<sys/socket.h>
#include<string.h>
void main(int argc, char* argv[])
{
	if(argc < 3)
	{
		printf("Syntax:%s server_addr <portNum>\n", argv[0]);
		exit(0);
	}


	int fdSock;
	//get a socket
	if( (fdSock=socket(AF_INET, SOCK_STREAM, 0)) == -1){perror("socket"); exit(1);}
	
	//config the address of the server to connect
	struct sockaddr_in addrServer;
	addrServer.sin_family = AF_INET;//Address family
	inet_pton(AF_INET, argv[1], &(addrServer.sin_addr));//Convert the addr from "presentation" to "numeric"
	addrServer.sin_port=htons(atoi(argv[2]));//set the port number
	//Connect to server
	if( connect( fdSock, (struct sockaddr *)(&addrServer), sizeof(addrServer))== -1){perror("connect"); exit(1);}
	
	char buf[1024];
	gets(buf);//get a msg from terminal
	while(buf[0] != '\0')
	{
		printf("Gets gets : %s\n", buf);
		//Send the msg to server. See also "sendto" and "sendmsg"
		if( send(fdSock, buf, strlen(buf), 0) == -1){perror("Send"); exit(1);}
		if(strcmp(buf, "over") == 0)
		{
			printf("Exit...\n");
			close(fdSock);
			exit(0);
		}
		gets(buf);
	}


}
執行結果： 
client：
[email protected]:~/Bureau/POLYTECH/unix/TD UNIX2012/td6$ ./client12 127.0.0.1 9999
hello
Gets gets : hello
byebye
Gets gets : byebye
over
Gets gets : over
Exit...
[email protected]:~/Bureau/POLYTECH/unix/TD UNIX2012/td6$ 


server：
[email protected]:~/Bureau/POLYTECH/unix/TD UNIX2012/td6$ ./server12 9999
New socket client : 127.0.0.1
New msg received : hello
New msg received : byebye
New msg received : over
[email protected]:~/Bureau/POLYTECH/unix/TD UNIX2012/td6$




2. 這次結合上exec，從客戶端傳送命令到伺服器，伺服器在本地執行命令。 server： 
#include <arpa/inet.h>
#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <errno.h>
#include <string.h>
#include <unistd.h>

#define MAX_NUM_ARG 10
void exeCmd(char * cmd);

int main(int argc, char *argv[])
{
	int numPort, lenMsg, i;
	int sockServ, sockClient;
	struct sockaddr_in adrServ, adrClient;
	char message[256];
	char * overMsg = "over";
	int adrSize = sizeof(adrClient);
	int yes = 1;

	if(argc < 2)
	{
		printf("syntaxe : %s numPort\n", argv[0]);
		return -1;
	}
	

	//set local addr and port
	numPort = atoi(argv[1]);
	adrServ.sin_addr.s_addr = INADDR_ANY;
	adrServ.sin_family = AF_INET;
	adrServ.sin_port = htons(numPort);
	bzero(&(adrServ.sin_zero), 8) ;
	
	//Get a socket
	if((sockServ = socket(PF_INET, SOCK_STREAM, 0)) == -1) { perror("sockServet"); return -1; }
	
	//We can set some param here.// paramètrage de la socket pour réutiliser le N° ce port sans délai
	if(setsockopt(sockServ, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(int)) == -1) { perror("setsockopt"); return -1; }

	// bind
	if(bind(sockServ, (struct sockaddr *)(&adrServ), sizeof(adrServ)) == -1) { perror("bind"); return -1; }

	// place la socket en écoute
	if(listen(sockServ, 1) == -1) { perror("listen"); return -1; }
	

	// wait for a connection from a client
	if((sockClient = accept(sockServ, (struct sockaddr *)(&adrClient), &adrSize)) == -1) { perror("accept"); return -1; }
	printf("New socket client : %s\n", inet_ntoa(adrClient.sin_addr));
	do
	{
		// Read a cmd from client
		if((lenMsg = recv(sockClient, message, 256, 0)) == -1)
			{ perror("recv"); return -1; }
		message[lenMsg] = '\0';
		printf("\nNew cmd received : %s, result:\n", message);
		exeCmd(message);
		//printf("New msg received : %s, %d\n", message, strcmp(message, overMsg));
		
	}while(strcmp(message, overMsg) != 0);	
	// fermeture de la connexion
	close(sockServ);
	
	return 0;
}


void exeCmd(char * cmd)
{
	if(fork()==0)
	{
		char *argv[MAX_NUM_ARG] = {NULL};
		int i;
		char *arg;
		for(i=0; i<MAX_NUM_ARG; i++)
		{
			if(i>0) cmd = NULL;
			arg = strtok(cmd, " ");
			if(arg != NULL)
			{
				//put this arg into argv[]
				argv[i] = calloc( sizeof(char), strlen(arg+1)) ;
				strcpy(argv[i], arg);
			}
			else
			{//execute this cmd
				execvp(argv[0], argv);
				exit(0);
			}
			
		}
		exit(0);
	}
}

client： 
#include<stdio.h>
#include<stdlib.h>
#include<netinet/in.h>
#include<sys/types.h>
#include<unistd.h>
#include<sys/socket.h>
#include<string.h>
void main(int argc, char* argv[])
{
	if(argc < 3)
	{
		printf("Syntax:%s server_addr <portNum>\n", argv[0]);
		exit(0);
	}

	int fdSock;
	//get a socket
	if( (fdSock=socket(AF_INET, SOCK_STREAM, 0)) == -1){perror("socket"); exit(1);}
	
	//config the address of the server to connect
	struct sockaddr_in addrServer;
	addrServer.sin_family = AF_INET;//Address family
	inet_pton(AF_INET, argv[1], &(addrServer.sin_addr));//Convert the addr from "presentation" to "numeric"
	addrServer.sin_port=htons(atoi(argv[2]));//set the port number
	//Connect to server
	if( connect( fdSock, (struct sockaddr *)(&addrServer), sizeof(addrServer))== -1){perror("connect"); exit(1);}
	
	char buf[1024];
	printf("\nexcute_cmd_in_distance$");
	gets(buf);//get a cmd from terminal
	while(buf[0] != '\0')
	{
		//printf("Gets gets : %s\n", buf);
		//Send the msg to server. See also "sendto" and "sendmsg"
		if( send(fdSock, buf, strlen(buf), 0) == -1){perror("Send"); exit(1);}
		if(strcmp(buf, "over") == 0)
		{
			printf("Exit...\n");
			close(fdSock);
			exit(0);
		}
		printf("\nexcute_cmd_in_distance$");
		gets(buf);
	}

}

執行結果： client： 
[email protected]:~/Bureau/POLYTECH/unix/TD UNIX2012/td6$ ./client3 127.0.0.1 9999

excute_cmd_in_distance$ls

excute_cmd_in_distance$ls -l

excute_cmd_in_distance$pwd

excute_cmd_in_distance$over
Exit...
[email protected]:~/Bureau/POLYTECH/unix/TD UNIX2012/td6$

server： 
[email protected]:~/Bureau/POLYTECH/unix/TD UNIX2012/td6$ ./server3 9999
New socket client : 127.0.0.1

New cmd received : ls, result:
12_client.c  3_client.c  client   client12  in.h      server3    td6-1_serveur-modif.c  types.h
12_server.c  3_server.c  client1  client3   server12  socket.h    td6.pdf

New cmd received : ls -l, result:
total 152
-rw-r--r-- 1 administrateur administrateur  1171 déc.  26 12:39 12_client.c
-rw-r--r-- 1 administrateur administrateur  1842 déc.  26 12:36 12_server.c
-rw-r--r-- 1 administrateur administrateur  1250 déc.  26 13:28 3_client.c
-rw-r--r-- 1 administrateur administrateur  2323 déc.  26 13:28 3_server.c
-rw-r--r-- 1 administrateur administrateur  7563 déc.   5 15:17 client
-rwxrwxr-x 1 administrateur administrateur  7549 déc.  26 11:47 client1
-rwxrwxr-x 1 administrateur administrateur  7623 déc.  26 12:31 client12
-rwxrwxr-x 1 administrateur administrateur  7622 déc.  26 13:28 client3
-rw-r--r-- 1 administrateur administrateur 18637 janv. 22  2011 in.h
-rwxrwxr-x 1 administrateur administrateur  7668 déc.  26 12:36 server12
-rwxrwxr-x 1 administrateur administrateur  7914 déc.  26 13:28 server3
-rw-r--r-- 1 administrateur administrateur  9597 janv. 22  2011 socket.h
-rw-r--r-- 1 administrateur administrateur  1953 déc.  26 11:46 td6-1_serveur-modif.c
-rw-r--r-- 1 administrateur administrateur 44356 nov.  30 15:39 td6.pdf
-rw-r--r-- 1 administrateur administrateur  6838 janv. 22  2011 types.h

New cmd received : pwd, result:
/home/administrateur/Bureau/POLYTECH/unix/TD UNIX2012/td6

New cmd received : over, result:
[email protected]:~/Bureau/POLYTECH/unix/TD UNIX2012/td6$



3. 理解”一切皆檔案“的概念。將server的標準輸入輸出重定向到client，即從client讀取命令字串，並將執行結果返回給client輸出。到這裡不難發現我們所要做的有點像個遠端終端。 並無特殊，加上重定向（在執行命令的子程序中）即可。 server： 
#include <arpa/inet.h>
#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <errno.h>
#include <string.h>
#include <unistd.h>

#define MAX_NUM_ARG 10
void exeCmd(int sockClient, char * cmd)
{
	
	if(fork()==0)
	{
		//Set redirection
		dup2(sockClient, 0);
		dup2(sockClient, 1);
		close(sockClient);

		char *argv[MAX_NUM_ARG] = {NULL};
		int i;
		char *arg;
		for(i=0; i<MAX_NUM_ARG; i++)
		{
			if(i>0) cmd = NULL;
			arg = strtok(cmd, " ");
			if(arg != NULL)
			{
				//put this arg into argv[]
				//argv[i] = calloc( sizeof(char), strlen(arg+1)) ;
				//strcpy(argv[i], arg);
				argv[i] = arg;//We can also simply do like this.
				fprintf(stderr, "cmd[%d] = %s\n",i,arg);
			}
			else
			{//execute this cmd
				execvp(argv[0], argv);
				exit(0);
			}
			
		}
		exit(0);
	}
}

int main(int argc, char *argv[])
{
	

	int numPort, lenMsg, i;
	int sockServ, sockClient;
	struct sockaddr_in adrServ, adrClient;
	char message[256];
	char * overMsg = "over";
	int adrSize = sizeof(adrClient);
	int yes = 1;

	if(argc < 2)
	{
		printf("syntaxe : %s numPort\n", argv[0]);
		return -1;
	}
	

	//set local addr and port
	numPort = atoi(argv[1]);
	adrServ.sin_addr.s_addr = INADDR_ANY;
	adrServ.sin_family = AF_INET;
	adrServ.sin_port = htons(numPort);
	bzero(&(adrServ.sin_zero), 8) ;
	
	//Get a socket
	if((sockServ = socket(PF_INET, SOCK_STREAM, 0)) == -1) { perror("sockServet"); return -1; }
	
	//We can set some param here.// paramètrage de la socket pour réutiliser le N° ce port sans délai
	if(setsockopt(sockServ, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(int)) == -1) { perror("setsockopt"); return -1; }

	// bind
	if(bind(sockServ, (struct sockaddr *)(&adrServ), sizeof(adrServ)) == -1) { perror("bind"); return -1; }

	// place la socket en écoute
	if(listen(sockServ, 1) == -1) { perror("listen"); return -1; }
	

	// wait for a connection from a client
	if((sockClient = accept(sockServ, (struct sockaddr *)(&adrClient), &adrSize)) == -1) { perror("accept"); return -1; }
	printf("New socket client : %s\n", inet_ntoa(adrClient.sin_addr));

	do
	{
		// Read a cmd from client
		//fgets(stdin, message);
		//fscanf(sockClient,"%s",message);
		if((lenMsg = recv(sockClient, message, 256, 0)) == -1)
			{ perror("recv"); return -1; }
		else if (lenMsg == 0)
		{
			close(sockClient);
			return 0;
		}
		message[lenMsg] = '\0';
		printf("New cmd received : %s\n", message);
		exeCmd(sockClient, message);
		//fflush(sockClient);
		//printf("New msg received : %s, %d\n", message, strcmp(message, overMsg));
		
	}while(strcmp(message, overMsg) != 0);	
	// fermeture de la connexion
	close(sockClient);
	
	return 0;
}
server執行結果： 
[email protected]:~/Bureau/POLYTECH/unix/TD UNIX2012/td6$ ./server4 9999
New socket client : 127.0.0.1
New cmd received : ls
cmd[0] = ls
New cmd received : pwd
cmd[0] = pwd
New cmd received : date
cmd[0] = date
New cmd received : ls -l
cmd[0] = ls
cmd[1] = -l
New cmd received : over
[email protected]:~/Bureau/POLYTECH/unix/TD UNIX2012/td6$ cmd[0] = over

client： 
#include<stdio.h>
#include<stdlib.h>
#include<netinet/in.h>
#include<sys/types.h>
#include<unistd.h>
#include<sys/socket.h>
#include<string.h>
void main(int argc, char* argv[])
{
	if(argc < 3)
	{
		printf("Syntax:%s server_addr <portNum>\n", argv[0]);
		exit(0);
	}

	int fdSock, res;
	//get a socket
	if( (fdSock=socket(AF_INET, SOCK_STREAM, 0)) == -1){perror("socket"); exit(1);}
	
	//config the address of the server to connect
	struct sockaddr_in addrServer;
	addrServer.sin_family = AF_INET;//Address family
	inet_pton(AF_INET, argv[1], &(addrServer.sin_addr));//Convert the addr from "presentation" to "numeric"
	addrServer.sin_port=htons(atoi(argv[2]));//set the port number
	//Connect to server
	if( connect( fdSock, (struct sockaddr *)(&addrServer), sizeof(addrServer))== -1){perror("connect"); exit(1);}
	
	char buf[1024];
	printf("\nexcute_cmd_in_distance$");
	gets(buf);//get a cmd from terminal
	while(buf[0] != '\0')
	{
		//printf("Gets gets : %s\n", buf);
		//Send the msg to server. See also "sendto" and "sendmsg"
		if( send(fdSock, buf, strlen(buf), 0) == -1){perror("Send"); exit(1);}
		if(strcmp(buf, "over") == 0)
		{
			printf("Exit...\n");
			close(fdSock);
			exit(0);
		}
		if( (res = recv(fdSock, buf, 1024, 0)) == -1){perror("recv"); exit(1);}
		else if(res == 0) {close(fdSock); exit(0);}
		else
		{
			buf[res] = '\0';
			printf("\n%s",buf);
		}
		printf("\nexcute_cmd_in_distance$");
		gets(buf);
	}

}

client執行結果： 
/home/administrateur/Bureau/POLYTECH/unix/TD UNIX2012/td6

excute_cmd_in_distance$date

mercredi 26 décembre 2012, 17:10:46 (UTC+0100)

excute_cmd_in_distance$ls -l

total 88
-rw-r--r-- 1 administrateur administrateur  1171 déc.  26 12:39 12_client.c
-rw-r--r-- 1 administrateur administrateur  1842 déc.  26 12:36 12_server.c
-rw-r--r-- 1 administrateur administrateur  1250 déc.  26 13:28 3_client.c
-rw-r--r-- 1 administrateur administrateur  2323 déc.  26 13:28 3_server.c
-rw-r--r-- 1 administrateur administrateur  1433 déc.  26 17:10 4_client.c
-rw-r--r-- 1 administrateur administrateur  2626 déc.  26 17:06 4_server.c
-rwxrwxr-x 1 administrateur administrateur  7658 déc.  26 17:10 client4
drwxrwxr-x 2 administrateur administrateur  4096 déc.  26 14:54 doc
-rwxrwxr-x 1 administrateur administrateur  7947 déc.  26 17:10 server4
-rw-r--r-- 1 administrateur administrateur 44356 nov.  30 15:39 td6.pdf

excute_cmd_in_distance$over
Exit...
[email protected]:~/Bureau/POLYTECH/unix/TD UNIX2012/td6$

5. 在第4題的基礎上，我們考慮I/O多路複用。試想，當client傳送完命令，並且正在等待執行結果的時候，使用者又在終端輸入了一條命令。由於程式被recv阻塞，使用者輸入的命令並不會被處理。有沒有一種方法可以監聽所有的io操作，並在任何一個操作結束阻塞的時候通知我們呢？沒錯，我們在談select和poll函式。下面的實現使用了poll函式，請注意看它是如何同時監聽所有io並在任何一個io操作準備就緒時返回的。 client： 
#include<stdio.h>
#include<stdlib.h>
#include<netinet/in.h>
#include<sys/types.h>
#include<unistd.h>
#include<sys/socket.h>
#include<string.h>
#include<poll.h>
void main(int argc, char* argv[])
{
	if(argc < 3)
	{
		printf("Syntax:%s server_addr <portNum>\n", argv[0]);
		exit(0);
	}

	int fdSock, res, nready;
	//get a socket
	if( (fdSock=socket(AF_INET, SOCK_STREAM, 0)) == -1){perror("socket"); exit(1);}
	
	//config the address of the server to connect
	struct sockaddr_in addrServer;
	addrServer.sin_family = AF_INET;//Address family
	inet_pton(AF_INET, argv[1], &(addrServer.sin_addr));//Convert the addr from "presentation" to "numeric"
	addrServer.sin_port=htons(atoi(argv[2]));//set the port number
	//Connect to server
	if( connect( fdSock, (struct sockaddr *)(&addrServer), sizeof(addrServer))== -1){perror("connect"); exit(1);}
	
	char buf[1024];
	printf("\nexcute_cmd_in_distance$");
	//gets(buf);//get a cmd from terminal
	
	//POLL added here
	struct pollfd pfds[2];
	bzero(pfds, sizeof(pfds[0]));	
	bzero(pfds+1, sizeof(pfds[0]));
	pfds[0].fd = 0;
	pfds[0].events = POLLRDNORM;//The event waited.(Normal read)

	pfds[1].fd = fdSock;
	pfds[1].events = POLLRDNORM;
	
	while(buf[0] != '\0')
	{
		printf("\nexcute_cmd_in_distance$");
		nready = poll(pfds, 2, -1);//nready is the number of ready fds
		if(pfds[0].revents & POLLRDNORM)
		{
			//deal with user input, send cmd to server
			gets(buf);
			if( send(fdSock, buf, strlen(buf), 0) == -1){perror("Send"); exit(1);}
			if(strcmp(buf, "over") == 0)
			{
				printf("Exit...\n");
				close(fdSock);
				exit(0);
			}
			
			pfds[0].revents = 0;
			nready --;
			if(nready == 0)
				continue;
		}
		if(pfds[1].revents & POLLRDNORM )
		{
			//deal with socket, display the result of the last cmd
			pfds[1].revents = 0;
				
			if( (res = recv(fdSock, buf, 1024, 0)) == -1){perror("recv"); exit(1);}
			else if(res == 0) {close(fdSock); exit(0);}
			else
			{
				buf[res] = '\0';
				printf("\n%s",buf);
			}
		}
		
	}

}

server：程式碼無太大變化，除了exeCmd函式。現在我們使用”bash“命令來執行其它命令。 
#include <arpa/inet.h>
#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <errno.h>
#include <string.h>
#include <unistd.h>

#define MAX_NUM_ARG 10
void exeCmd(int sockClient, char * cmd)
{
	
	if(fork()==0)
	{
		//Set redirection
		dup2(sockClient, 0);
		dup2(sockClient, 1);
		close(sockClient);

		execlp("bash", "bash", "-c", cmd, NULL);
		exit(0);
	}
}

int main(int argc, char *argv[])
{
	

	int numPort, lenMsg, i;
	int sockServ, sockClient;
	struct sockaddr_in adrServ, adrClient;
	char message[256];
	char * overMsg = "over";
	int adrSize = sizeof(adrClient);
	int yes = 1;

	if(argc < 2)
	{
		printf("syntaxe : %s numPort\n", argv[0]);
		return -1;
	}
	

	//set local addr and port
	numPort = atoi(argv[1]);
	adrServ.sin_addr.s_addr = INADDR_ANY;
	adrServ.sin_family = AF_INET;
	adrServ.sin_port = htons(numPort);
	bzero(&(adrServ.sin_zero), 8) ;
	
	//Get a socket
	if((sockServ = socket(PF_INET, SOCK_STREAM, 0)) == -1) { perror("sockServet"); return -1; }
	
	//We can set some param here.// paramètrage de la socket pour réutiliser le N° ce port sans délai
	if(setsockopt(sockServ, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(int)) == -1) { perror("setsockopt"); return -1; }

	// bind
	if(bind(sockServ, (struct sockaddr *)(&adrServ), sizeof(adrServ)) == -1) { perror("bind"); return -1; }

	// place la socket en écoute
	if(listen(sockServ, 1) == -1) { perror("listen"); return -1; }
	

	// wait for a connection from a client
	if((sockClient = accept(sockServ, (struct sockaddr *)(&adrClient), &adrSize)) == -1) { perror("accept"); return -1; }
	printf("New socket client : %s\n", inet_ntoa(adrClient.sin_addr));

	
	do
	{
		if((lenMsg = recv(sockClient, message, 256, 0)) == -1)
			{ perror("recv"); return -1; }
		else if (lenMsg == 0)
		{
			close(sockClient);
			return 0;
		}
		message[lenMsg] = '\0';
		printf("New cmd received : %s\n", message);
		exeCmd(sockClient, message);
		
	}while(strcmp(message, overMsg) != 0);	
	// fermeture de la connexion
	close(sockClient);
	
	return 0;
}

執行結果： client：每條命令下顯示的結果其實是在server端執行的。你發現什麼變化沒有？當我們執行find / -name "socket.h" 這條耗時的命令後，server端並不能馬上返回結果，而我們仍可以馬上執行下一條命令：date，並且我們先得到了date的結果，之後才是find命令的搜尋結果。 
[email protected]:~/Bureau/POLYTECH/unix/TD UNIX2012/td6$ ./4_client 127.0.0.1 9999

ls
excute_cmd_in_distance$
12_client.c
12_server.c
3_client.c
3_server.c
4
4_client
4_client.c
4_poll_client.c
4_poll_client.c~
4_poll_server.c
4_poll_server.c~
4_server.c
4_server.c~
client4
clientPoll
doc
server4
td6.pdf

sudo find / -name "socket.h"
excute_cmd_in_distance$date

mercredi 26 décembre 2012, 17:53:30 (UTC+0100)

excute_cmd_in_distance$
/media/DONNEES/Polytech/Tutorial/Linux/linux-2.6.33.20/linux-2.6.33.20/arch/alpha/include/asm/socket.h
/media/DONNEES/Polytech/Tutorial/Linux/linux-2.6.33.20/linux-2.6.33.20/arch/arm/include/asm/socket.h
/media/DONNEES/Polytech/Tutorial/Linux/linux-2.6.33.20/linux-2.6.33.20/arch/avr32/include/asm/socket.h
/media/DONNEES/Polytech/Tutorial/Linux/linux-2.6.33.20/linux-2.6.33.20/arch/blackfin/include/asm/socket.h
/media/DONNEES/Polytech/Tutorial/Linux/linux-2.6.33.20/linux-2.6.33.20/arch/cris/include/asm/socket.h
/media/DONNEES/Polytech/Tutorial/Linux/linux-2.6.33.20/linux-2.6.33.20/arch/frv/include/asm/socket.h
/media/DONNEES/Polytech/Tutorial/Linux/linux-2.6.33.20/linux-2.6.33.20/arch/h8300/include/asm/socket.h
/media/DONNEES/Polytech/Tutorial/Linux/linux-2.6.33.20/linux-2.6.33.20/arch/ia64/include/asm/socket.h
/media/DONNEES/Polytech/Tutorial/Linux/linux-2.6.33.20/linux-2.6.33.20/arch/m32r/include/asm/socket.h
/media/DONNEES/Polytech/Tutorial/Linux/linux-2.6.33.20/linux-2.6.33.20/arch/m68k/include/asm/socket.h
excute_cmd_in_distance$

server： 
[email protected]:~/Bureau/POLYTECH/unix/TD UNIX2012/td6$ ./4
syntaxe : ./4 numPort
[email protected]:~/Bureau/POLYTECH/unix/TD UNIX2012/td6$ ./4 9999
New socket client : 127.0.0.1
New cmd received : ls
New cmd received : sudo find / -name "socket.h"
[sudo] password for administrateur: 
New cmd received : date

可以看出server先後收到的所有命令。另外，由於重定向是在子程序中做得，所以要求輸入密碼的那行並沒有傳送給客戶端而是在本地顯示了。



相關推薦

循序漸進學unix——上機記錄（七）,socket

本次的主題是基本網路程式設計：socket，涉及到的概念比較多，就不詳細展開了。從程式設計角度簡單的說，為了在客戶端和伺服器之間建立一個連線，伺服器端需要依次呼叫這些函式： socket，獲得一個socket bind，將獲得的socket繫結到指定的地址和埠 listen，

循序漸進學unix——上機記錄（八）,Thread

本次上機主題為執行緒。一個程式可以包含多個程序，而一個程序又可以建立多個執行緒，每個執行緒都共享此程序的上下文環境。 在unix下使用gcc編譯帶有執行緒操作的程式時需要加上 -pthread選項。 基本的執行緒函式： #include <pthread.h> 建立

循序漸進學unix——上機記錄（六）,exec

本次上機記錄的主題是如何執行外部程式。Unix下有一組名為execxx()的函式： #include <unistd.h> extern char **environ; int execl(const char *path, const char *arg, ...);

循序漸進學unix——上機記錄（五）,signal

本文的主題是unix中的基本訊號處理（signal）。 在Unix中，一個程序可以向另一個程序傳送訊號，接收程序再收到訊號後可以根據配置做出相應反應。這也是一種通訊機制。 涉及到的主要函式有： signal，配置當前程序，在收到什麼訊號時執行什麼函式。第一個引數為想要處理的訊

循序漸進學unix——上機記錄（四）

一連4周，每週兩門考試，好長時間沒能繼續把上機記錄完成。現在總算進入聖誕假期，爭取把這一系列寫完。 上回說到使用pipe在兩個程序之間做雙重重定向，下面我們繼續看下一練習： 5，一個管道“pipe”，能否被多個程序同時訪問？為了回答這一問題，建立一個父程序和兩個子程序，兩個

白盒測試實踐——每日例會記錄（七）

技術 png 引導 意見 情況 定義 嚴重 image 傾聽 2017.12.15例會內容 今天，完成階段二：代碼復審。 流程：主持人召開會議，會後提交評審報告，給出評審結論。講解員講解工作產品，引導評審員瀏覽工作產品。評審員聽取講解，發表意見，指出問題，與作者確定問題

從零開始學 Web 之 jQuery（七）事件冒泡，事件參數對象，鏈式編程原理

eval uri turn 定位 return 也會 否則 ont sele 大家好，這裏是「 從零開始學 Web 系列教程 」，並在下列地址同步更新...... github：https://github.com/Daotin/Web 微信公眾號：Web前端之巔 博客

python學習記錄（七）

時有 程序 不用 循環 callable 類名 定義函數 ber 之一 0904--https://www.cnblogs.com/fnng/archive/2013/04/24/3039335.html 0904--https://www.cnblogs.com/fnng

HTTP圖解學習記錄（七）

確保Web安全的HTTPS HTTP的缺點 HTTP主要有這些不足 * 通訊使用明文（不加密），內容可能會被竊聽 * 不驗證通訊方的身份，因此可能遭遇偽裝 * 無法證明報文的完整性，所以有可能已遭篡改 除此之外，HTTP 本身還有很多缺點。而且，還有像某些特定的 Web

java 核心技術卷I學習記錄（七）-異常處理

java 異常處理 1. 處理錯誤 異常處理的任務就是將控制權從錯誤產生的地方轉移給能夠處理這種情況的錯誤處理器 需要關注的錯誤種類有： 使用者輸入錯誤 裝置錯誤 物理限制 程式碼錯誤 1.1 異常分類 在java中，異常物件都是派生於

sql必知必會學習記錄（七）-建立計算欄位

sql必知必會學習記錄（七） 本次記錄內容主要包括sql 必知必會 第七章 建立計算欄位的相關內容 拼接欄位 在MySQL的SELECT語句中，可使用Concat()函式來拼接兩個列。 SELECT CONCAT(vend_name,'(',v

介面測試指令碼實踐記錄（七）

七 將所有與該專案介面相關的函式封裝成類   class ProjectApi: #3個數據源介面 def api_1(self,code): pass def api_2(self,code): p

接口測試腳本實踐記錄（七）

print isdigit pan 調試 lse tap == 開發 協助 七 將所有與該項目接口相關的函數封裝成類 class ProjectApi: #3個數據源接口 def api_1(self,code): pa

SpringBoot2學習記錄（七）——SpringDataJPA的使用

1、JPA        JPA(Java Persistence API)是Sun官方提出的，JPA本身並不是一種框架，是一種規範。它為Java開發人員提供了一種物件/關聯對映工具來管理Java應用中的關係資料。他的出現主要是為了簡化現有的持久化開發

Java還要再學一遍基礎（七）LinkedList詳解

LinkedList介紹 LinkedList與ArrayList一樣都是屬於AbstractList的子類。但是內部實現與ArrayList不同的是LinkedList是以連結串列的資料結構來實現的，通過引用來指向上一個或者下一個節點。在資料的插入和刪除上面

從零開始學 Web 之 DOM（七）事件冒泡

>大家好，這裡是「 從零開始學 Web 系列教程 」，並在下列地址同步更新...... > +------------------------------------------------------------ > github：https://github.com/Dao

從零開始學 Web 之 jQuery（七）事件冒泡，事件引數物件，鏈式程式設計原理

一、事件冒泡與阻止事件冒泡 事件冒泡：當一個元素觸發某個事件的時候，會把這個事件傳播到其父元素，一直到頂層元素。 阻止事件冒泡：在被觸發事件的子元素中新增 return false; 即可。 二、事件的觸發 之前講的繫結事件是事件觸發後的事件處理過程，並且上面的事件觸發是被動的事件觸發，怎麼可以主動觸發事

從零開始學 Web 之 CSS3（七）多列布局，伸縮佈局

一、多列布局 CSS3中新出現的多列布局 (multi-column) 是傳統 HTML 網頁中塊狀佈局模式的有力擴充。 這種新語法能夠讓 WEB 開發人員輕鬆的讓文字呈現多列顯示。 我們知道，當一行文字太長時，讀者讀起來就比較費勁，有可能讀錯行或讀序列；人們的視點從文字的一端移到另一端、然後換到下一行的

從零開始學 Web 之 Ajax（七）跨域

一、跨域 跨域這個概念來自一個叫 “同源策略” 的東西。同源策略是瀏覽器上為了安全考慮實施的非常重要的安全機制。 Ajax 預設只能獲取到同源的資料，對於非同源的資料，Ajax是獲取不到的。 什麼是同源？ 協議、域名、埠全部相同。 如果使用 Ajax 獲取非同源的資料，會報錯，報錯資訊如下： Fail

Activiti——流程執行歷史記錄（七）

之前的幾篇文章，為大家簡單的介紹了部署流程定義、啟動流程例項、檢視和辦理個人任務以及如何設定和獲取流程變數，這一系列的活動組成了一個完整的執行流程，那麼一個執行完的流程我們如何檢視相關的定義呢，這篇博文就為大家簡單的介紹一下流程執行的歷史記錄查詢。 一、查詢歷史流程