Сокеты

[Stalkert]

Здравствуйте! Помогите, пожалуйста со следующей проблемой. У меня есть готовый код, описывающий взаимодействие клиент-сервер. Но он работает как общий чат.То есть при отправке сообщения на сервер это сообщение видят все клиенты. Этот код нужно доработать, так чтобы клиент мог выбирать адресата из списка всех клиентов и общаться только с ним. Можете подсказать как это организовать? Или какие ошибки исправить в коде?

Код сервера:

include <unistd.h>
#include <netinet/in.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>

#include <strings.h>

#include <poll.h>
#define IPADDRESS "127.0.0.1"
#define PORT 6666
#define MAXLINE 1024
#define LISTENQ 5
#define OPEN_MAX 1000
#define INFTIM -1

int bind_and_listen()
{
	int serverfd;
	struct sockaddr_in my_addr;
	unsigned int sin_size;
	if((serverfd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
	{
		printf ("error socket";
		return -1;
	}
	printf("socket ok\n";
	my_addr.sin_family = AF_INET;
	my_addr.sin_port = htons(PORT);
	my_addr.sin_addr.s_addr = INADDR_ANY;
	bzero(&(my_addr.sin_zero), 0);
	if(bind(serverfd, (struct sockaddr*)&my_addr, sizeof(struct sockaddr)) == -1)
	{
		printf("error bind";
		return -2;
	}
	printf("bind ok\n";
	if(listen(serverfd, LISTENQ) == -1)
	{
		printf("error listen";
		return -3;
	}
	printf("listen ok\n";
	return serverfd;
}

void do_poll(int listenfd)
{
	int connfd, sockfd;
	struct sockaddr_in cliaddr;
	socklen_t cliaddrlen;
	struct pollfd clientfds[OPEN_MAX];      
	int maxi;
	int sin_port2[5];
	int i,j;
	int nready;
	clientfds[0].fd = listenfd;
	clientfds[0].events = POLLIN;
	for(i = 1; i<OPEN_MAX; i++)
		clientfds[i].fd = -1;
	maxi = 0;

	while(1)
	{
		nready = poll(clientfds, maxi+1, INFTIM);
		if(nready == -1)
		{
			printf("poll error";
			exit(1);
		}
		if(clientfds[0].revents & POLLIN)
		{
			cliaddrlen = sizeof(cliaddr);
			if((connfd = accept(listenfd, (struct sockaddr*)&cliaddr, &cliaddrlen)) <0)
			{
				
					printf("accept error";
					exit(1);
				
			}
			fprintf(stdout, "accept a new client:%s:%d\n", inet_ntoa(cliaddr.sin_addr), cliaddr.sin_port);
			for(i = 1; i<OPEN_MAX; i++)
			{
				if(clientfds[i].fd<0)
				{
					clientfds[i].fd = connfd;
					break;
				}
			}
			if(i == OPEN_MAX)
			{
				fprintf(stderr, "too many clients.\n";
				exit(1);
			}
			sin_port2[i]=cliaddr.sin_port;
			clientfds[i].events = POLLIN;
			maxi = (i>maxi?i:maxi);
			if(--nready<=0)  
				continue;
		}
		
		char buf[MAXLINE];
                char BUF[80];
		
		memset(buf, 0, MAXLINE);
		int readlen = 0;
		for(i = 1; i<maxi; i++)    
		{
			if(clientfds[i].fd<0) continue;
				
			if(clientfds[i].revents & POLLIN)
			{
				readlen = read(clientfds[i].fd, buf, MAXLINE);
				if(readlen == 0)
				{
					close(clientfds[i].fd);
					clientfds[i].fd = -1;
					continue;
				}
				printf("msg is:";
				
				memset(BUF,0,sizeof(BUF));
				sprintf(BUF,"%d :%s",sin_port2[i],buf);
				printf("%s",BUF);
				
                                for(j=1;j<maxi;j++)
				{
				if(i!=j){
				write(clientfds[j].fd, BUF, sizeof(BUF));
				}
				}
	                                
			}
		}
	}
}
int main(int argc, char* argv[])
{
	int listenfd = bind_and_listen();
	if(listenfd<0)
	{
		return 0;
	}
	do_poll(listenfd);
	return 0;
}

Код клиента:

#include<sys/types.h>
#include<sys/socket.h>
#include<unistd.h>
#include<netinet/in.h>

#include<stdio.h>
#include<stdlib.h>
#include<string.h>

#include<poll.h>
#define IPADDRESS "127.0.0.1"
#define PORT 20113
#define MAXLINE 1024
#define max(a, b) (a>b)?a:b
static void handle_connection(int sockfd);
int main(int argc, char* argv[])
{
	int connfd = 0;
	int clen = 0;
	struct sockaddr_in client;
	if(argc<2)
	{
		printf("Usage: clientent[server IP address]\n";
		return -1;
	}
	client.sin_family = AF_INET;
	client.sin_port = htons(PORT);
	client.sin_addr.s_addr = inet_addr(argv[1]);
	connfd = socket(AF_INET, SOCK_STREAM, 0);
	if(connfd<0)
	{
		printf("error socket";
		return -1;
	}
	if(connect(connfd, (struct sockaddr*)&client, sizeof(client))<0)
	{
		printf("error connect";
		return -1;
	}
	handle_connection(connfd);
	return 0;
}

static void handle_connection(int sockfd)
{
	char sendline[MAXLINE], recvline[MAXLINE];
	int maxfdp, stdineof;
	struct pollfd pfds[2];
	int n;
	pfds[0].fd = sockfd;
	pfds[0].events = POLLIN;
	pfds[1].fd = STDIN_FILENO;
	pfds[1].events = POLLIN;
	while(1)
	{
		poll(pfds, 2, -1);
		if(pfds[0].revents & POLLIN)
		{
			n = read(sockfd, recvline, MAXLINE);
			if(n == 0)
			{
				fprintf(stderr, "client: server is closed.\n";
				close(sockfd);
			}
			write(STDOUT_FILENO, recvline, n);
		}
		if(pfds[1].revents & POLLIN)
		{
			n = read(STDIN_FILENO, sendline, MAXLINE);
			if(n == 0)
			{
				shutdown(sockfd, SHUT_WR);
				continue;
			}
			write(sockfd, sendline, n);
		}
	}
}

[code = C]

 sockets, клиент, сервер, сокеты