client客户端处理器
#include #include #include #include #include #include #include #include
int sockfd;/* 客户端socket /
char IPADDR = “10.0.0.7”;/* 服务器的IP地址 /
short PORT = 6025;/ 服务器服务端口 */
typedef struct sockaddr SA;
char name[30];
void init()
{
sockfd = socket(AF_INET,SOCK_STREAM,0);
struct sockaddr_in addr;
bzero(&addr,sizeof(struct sockaddr_in));
addr.sin_family = AF_INET;
addr.sin_port = htons(PORT);
addr.sin_addr.s_addr = inet_addr(IPADDR);
if (connect(sockfd,(SA*)&addr,sizeof(addr)) == -1)
{
perror("无法连接到服务器");
exit(-1);
}
printf("客户端启动成功\n");
}
void start()
{
pthread_t id;
void* recv_thread(void*);
pthread_create(&id,0,recv_thread,0);
char buf2[100] = {};
sprintf(buf2,"%s进入了聊天室",name);
send(sockfd,buf2,strlen(buf2),0);
while(1)
{
char buf[100] = {};
scanf("%s",buf);
char msg[131] = {};
sprintf(msg,"%s:%s",name,buf);
send(sockfd,msg,strlen(msg),0);
if (strcmp(buf,"bye") == 0)
{
memset(buf2,0,sizeof(buf2));
sprintf(buf2,"%s退出了聊天室",name);
send(sockfd,buf2,strlen(buf2),0);
break;
}
}
close(sockfd);
}
void* recv_thread(void* p)
{
while(1)
{
char buf[100] = {};
if (recv(sockfd,buf,sizeof(buf),0) <= 0)
{
return;
}
printf("%s\n",buf);
}
}
int main()
{
init();
printf(“请输入您的名字：”);
scanf("%s",name);
start();
return 0;
}
service服务端
#include #include #include #include #include #include
#define IPADDR “10.0.0.7”
#define PORT 6025
int listenfd; /* 服务器socket */
int sockfd = 0;
int main(int argc ,char **argv)
{
listenfd = socket(AF_INET,SOCK_STREAM,0);
if (listenfd == -1)
{
perror(“创建socket失败!!!”);
return -1;
}
struct sockaddr_in s_add, c_add;
bzero(&s_add,sizeof(struct sockaddr_in));
s_add.sin_family = AF_INET;
s_add.sin_port = htons(PORT);
s_add.sin_addr.s_addr = inet_addr(IPADDR);
int len = sizeof(s_add);
if (bind(listenfd,(struct sockaddr*)&s_add,sizeof(struct sockaddr)) == -1)
{
perror("绑定失败");
return -1;
}
if (listen(listenfd,10) == -1)
{
perror("设置监听失败");
return -1;
}
if(-1 == (sockfd = accept(listenfd, (struct sockaddr*)&c_add, &sizeof(c_add) )))
{
perror("accept error 1");
return -1;
}
printf("IP: %s connected !\n", inet_ntoa(c_add.sin_addr) );
printf("服务器启动成功\n");
while(1)
{
fd_set readfds;
FD_ZERO(&readfds);
FD_SET(0, &readfds);
FD_SET(sockfd, &readfds);
select(sockfd+1, &readfds, NULL, NULL, NULL);
char buf[1024];
if(FD_ISSET(0, &readfds))
{
printf("input> ");fflush(stdout);
gets(buf);
write(sockfd, buf, sizeof buf);
}
if(FD_ISSET(sockfd, &readfds))
{
read(sockfd, buf, sizeof buf);
printf("%s\n", buf);
}
}
close(sockfd);
}
