netchat1.c

通过TCP方式,进程文字聊天.一个作为服务器,一个作为客户端

/*
 * server
 * tcp
 * 文字聊天
 */
#include <stdio.h>
#include <stdlib.h>
#include <errno.h>
#include <string.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <sys/socket.h>
#include <sys/wait.h>
#include <unistd.h>
#include <arpa/inet.h>

#define MAXBUF 1024

int main(int argc, char **argv)
{
	int sockfd, new_fd;
	socklen_t len;
	struct sockaddr_in my_addr, their_addr;
	unsigned int myport, lisnum;
	char buf[MAXBUF + 1];
	
	//设端口号
	if (argv[1])
		myport = atoi(argv[1]);
	else
		myport = 7838;
	
	//设最大连接个数
	if (argv[2])
		lisnum = atoi(argv[2]);
	else
		lisnum = 2;
	
	if ((sockfd = socket(PF_INET, SOCK_STREAM, 0)) == -1) {
		perror("socket");
		exit(1);
	}
	
	bzero(&my_addr, sizeof(my_addr));
	my_addr.sin_family = PF_INET;
	my_addr.sin_port = htons(myport);
	if (argv[3])
		my_addr.sin_addr.s_addr = inet_addr(argv[3]);
	else
		my_addr.sin_addr.s_addr = INADDR_ANY;	
	
	if (bind(sockfd, (struct sockaddr *) &my_addr, sizeof(struct sockaddr))== -1) {
		perror("bind");
		exit(1);
	}
	
	if (listen(sockfd, lisnum) == -1) {
		perror("listen");
		exit(1);
	}
	
	while (1) {
		printf("\n----等待新的连接到来开始新一轮聊天……\n");
		len = sizeof(struct sockaddr);
		if ((new_fd =	accept(sockfd, (struct sockaddr *) &their_addr,&len)) == -1) {
			perror("accept");
			exit(errno);
		} 
		else
			printf("server: got connection from %s, port %d, socket %d\n",
					inet_ntoa(their_addr.sin_addr),
					ntohs(their_addr.sin_port), new_fd);
	
		/* 开始处理每个新连接上的数据收发 */
		while (1) {
			/* 发消息给客户端 */
			bzero(buf, MAXBUF + 1);
			printf("请输入要发送给对方的消息：");
			fgets(buf, MAXBUF, stdin);	//输入
			if (!strncasecmp(buf, "quit", 4)) {//quit
				printf("自己请求终止聊天！\n");
				break;
			}
			len = send(new_fd, buf, strlen(buf) - 1, 0);//发送
			if (len > 0)
				printf("消息:%s\t发送成功，共发送了%d个字节！\n",buf, len);
			else {
				printf("消息'%s'发送失败！错误代码是%d，错误信息是'%s'\n",buf, errno, strerror(errno));
				break;
			}
			bzero(buf, MAXBUF + 1);
			/* 接收客户端的消息 */
			len = recv(new_fd, buf, MAXBUF, 0);
			if (len > 0)
				printf("接收消息成功:'%s'，共%d个字节的数据\n",buf, len);
			else {
				if (len < 0)
					printf("消息接收失败！错误代码是%d，错误信息是'%s'\n",errno, strerror(errno));
				else
					printf("对方退出了，聊天终止\n");
				break;
			}
		}//while
		close(new_fd);
		/* 处理每个新连接上的数据收发结束 */
	}//while
	
	close(sockfd);
	
	return 0;
}

/*
 * fgets(buf, MAXSIZE, stdin);
 * strncasecmp(buf, "quit", 4);
 */