cln.c

在Linux环境下运行

#include <stdio.h>
#include <stdlib.h>
#include <errno.h>
#include <string.h>
#include <netdb.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <sys/socket.h>

#define SERVPORT 3000
#define BUFFER_SIZE 128


struct MSG
{
uint32_t dest_addr;
uint32_t head_addr;
char buf[BUFFER_SIZE];
int imsglen;
};

        /*接收*/
void * msg_rcv(void * Parm)
{
	int rcvBytes;
	struct MSG msg_buf;
	int sck_fd = *((int*)Parm);
	while(1)
	{
		if ((rcvBytes = recv(sck_fd,(char *)&msg_buf,sizeof(struct MSG),0)) ==-1)
		{
			perror("recv error！");
			return NULL;
		}else if(rcvBytes==0)
		{
			printf("recv error！\n");
			return NULL;
		}
		msg_buf.buf[msg_buf.imsglen] = '\0';
		printf("Received Msg from %s: %s\n",inet_ntoa(msg_buf.head_addr),msg_buf.buf);
	}
	return NULL;
}

           /*发送*/
void * msg_send(void * Parm)
{
	char addr[16];
	int sck_fd = *((int*)Parm);
	struct MSG msg_buf;
	int len;

	while(1)
	{
		memset(&msg_buf,0,sizeof(struct MSG));
		scanf("%s",addr);
		scanf("%s",msg_buf.buf);
		
		len=strlen(addr);
		addr[len]=0;
		msg_buf.dest_addr=inet_addr(addr);
		msg_buf.head_addr=htonl(INADDR_ANY);
		msg_buf.imsglen= strlen(msg_buf.buf);

		if(msg_buf.imsglen<=0)
		{
			printf("[host addr] [msg]\n");
			continue;
		}
		send(sck_fd,(char *)&msg_buf,sizeof(struct MSG),0);
	}
}

int main(int argc, char *argv[])
{
	int sck_fd, recvbytes;
	char buf[BUFFER_SIZE];
	struct hostent *host;
	struct sockaddr_in serv_addr;
	int iRet;
	pthread_t pThreadID;

	if (argc < 2) 
	{
		fprintf(stderr,"Please enter the server's hostname!\n");
		exit(1);
	}
	if((host=gethostbyname(argv[1]))==NULL) 
	{
		herror("gethostbyname error！");
		exit(1);
	}
	if ((sck_fd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
	{
		perror("socket error！");
		exit(1);
	}

	serv_addr.sin_family=AF_INET;
	serv_addr.sin_port=htons(SERVPORT);
	serv_addr.sin_addr = *((struct in_addr *)host->h_addr);
	bzero(&(serv_addr.sin_zero),8);
               /*建立连接*/
	if (connect(sck_fd, (struct sockaddr *)&serv_addr, sizeof(struct sockaddr)) == -1) 
	{
		perror("connect error！");
		exit(1);
	}
	printf("Connect to %s succeed\n",argv[1]);
	iRet = pthread_create(&pThreadID,NULL,msg_rcv,(void *)&sck_fd);

	msg_send(&sck_fd);

	return 0;
}