#include <stdio.h>
#include <sys\/types.h>
#include <sys\/socket.h>
#include <strings.h>
#include <arpa\/inet.h>
#include <unistd.h>
#include <string.h><\/p>\n
#define SERV_PORT 9000<\/p>\n
#define BUFF_SIZE 1024<\/p>\n
struct user
{
int socketfd;
char name[20];
char toName[20];
int result; \/\/ 0 \u4ee3\u8868\u5931\u8d25 1\u4ee3\u8868\u6210\u529f 2 \u4ee3\u8868\u522b\u4eba\u7ed9\u4f60\u53d1\u7684\u4fe1\u606f 3\u4ee3\u8868\u6ca1\u6ce8\u518c 4\u9519\u8bef\u7684\u6307\u4ee4
char msg[100];
int cmd; \/\/ 5 \u4ee3\u8868\u6ce8\u518c\u7528\u6237 10 \/\/ \u4ee3\u8868\u53d1\u9001\u4fe1\u606f
};<\/p>\n
struct userManage
{
int flag[20]; \/\/ \u8868\u660e\u54ea\u4e2a\u7a7a\u7f3a
struct user users[20];
};<\/p>\n
pthread_mutex_t mutex;<\/p>\n
struct userManage uMge;
void save_user(int socket_fd, struct user * userInfo)
{
pthread_mutex_lock(&mutex);
int i = 0;
for (i = 0; i < 20; i )
{
if (uMge.flag[i] == 1)
{
continue;
}
uMge.users[i].socketfd = socket_fd;
strcpy(uMge.users[i].name, userInfo->name);
userInfo->result = 1;
uMge.flag[i] = 1;
printf ("%s register success!n", uMge.users[i].name);
break;
}
pthread_mutex_unlock(&mutex);
}<\/p>\n
int server_request(int cfd)
{
int readSize, writeSize;
int ret = 0;
int i;
struct user userInfo;
int toname_fd = -1;
int isRegister = -1;
while (readSize = read(cfd, &userInfo, sizeof(userInfo)))
{
if (readSize == -1)
{
perror("read");
return -1;
}
if (userInfo.cmd == 5) \/\/ \u6ce8\u518c\u7528\u6237
{
save_user(cfd, &userInfo); \/\/ \u5c06\u7528\u6237\u4fe1\u606f\u8fdb\u884c\u4fdd\u5b58
}<\/p>\n
else if (userInfo.cmd == 10) \/\/ \u53d1\u9001\u4fe1\u606f
{
\/\/ \u68c0\u6d4b\u8be5\u7528\u6237\u662f\u5426\u6ce8\u518c
for (i = 0; i < 20; i )
{
if (uMge.flag[i] == 1)
{
if (uMge.users[i].socketfd == cfd)
{
if (strcmp(uMge.users[i].name, userInfo.name) == 0)
{
isRegister = 1;
}
}
}
}
if(isRegister == 1)
{
\/\/ \u5bfb\u627e\u8981\u53d1\u9001\u7684\u7528\u6237
for (i = 0; i < 20; i )
{
if (uMge.flag[i] == 1)
{
\/\/ \u627e\u5230\u4e86\u8981\u53d1\u9001\u7684\u7528\u6237\uff0c\u5c06\u5176socket\u4fdd\u5b58\u8d77\u6765
if (strcmp(uMge.users[i].name, userInfo.toName) == 0)
{
toname_fd = uMge.users[i].socketfd;
}
}
}
if(toname_fd != -1) \/\/ \u6ca1\u627e\u5230\u8981\u53d1\u9001\u7684\u7528\u6237
{
userInfo.result = 2; \/\/ \u627e\u5230\u7528\u6237\u5c06\u5176\u8fd4\u56de\u72b6\u6001\u6807\u4e3a1
writeSize = write(toname_fd, &userInfo, sizeof(userInfo));
if (writeSize == -1)
{
perror("write");
return -1;
}<\/p>\n
printf ("%s send msg to %s : %sn", userInfo.name, userInfo.toName, userInfo.msg);
userInfo.result = 1; \/\/ \u53d1\u9001\u6210\u529f
}
}
else
{
userInfo.result = 3; \/\/ \u6ca1\u6709\u6ce8\u518c
}
}
else
{
userInfo.result = 4; \/\/ \u9519\u8bef\u7684\u6307\u4ee4
}<\/p>\n
writeSize = write(cfd, &userInfo, sizeof(userInfo));
if (writeSize == -1)
{
perror("write");
return -1;
}
memset(userInfo.msg, 0, sizeof(userInfo.msg));
}<\/p>\n
}<\/p>\n
int main()
{
int listen_sockfd;
int ret;
struct sockaddr_in server_addr; \/\/ \u670d\u52a1\u5668\u5730\u5740\u7ed3\u6784
struct sockaddr_in client_addr; \/\/ \u5ba2\u6237\u7aef\u7684\u5730\u5740<\/p>\n
pthread_mutex_init(&mutex, NULL);<\/p>\n
\/\/ \u521b\u5efa\u76d1\u542c\u5957\u63a5\u5b57
listen_sockfd = socket(AF_INET, SOCK_STREAM, 0);
if (listen_sockfd == -1)
{
perror("create socket error");
return -1;
}<\/p>\n
\/\/ \u521d\u59cb\u5316\u670d\u52a1\u5668\u5730\u5740\u7ed3\u6784
bzero(&server_addr, sizeof(server_addr)); \/\/ \u5c06\u5730\u5740\u7ed3\u6784\u53d8\u91cf\u6e05\u96f6
server_addr.sin_family = AF_INET; \/\/ \u9009\u62e9IPV4\u5730\u5740
server_addr.sin_addr.s_addr = htonl(INADDR_ANY); \/\/ \u76d1\u542c\u672c\u5730\u4efb\u610fIP\u5730\u5740
server_addr.sin_port = htons(SERV_PORT); \/\/ \u5c06\u672c\u5730\u7aef\u53e3\u53f7\u8f6c\u5316\u4e3a\u7f51\u7edc\u7aef\u53e3\u53f7<\/p>\n
\/\/ \u7ed1\u5b9a\u672c\u5730\u5730\u5740\u548c\u7aef\u53e3\u53f7
ret = bind(listen_sockfd, (struct sockaddr *)&server_addr, sizeof (server_addr));
if (ret == -1)
{
perror ("bind error");
return -1;
}<\/p>\n
\/\/ \u76d1\u542c\u5957\u63a5\u5b57
ret = listen(listen_sockfd, 20);
if (ret == -1)
{
perror("listen error");
return -1;
}<\/p>\n
while(1)
{
int clientfd;
socklen_t client_len = sizeof(client_addr);<\/p>\n
clientfd = accept(listen_sockfd, (struct sockaddr *)&client_addr, &client_len);
if (clientfd == -1)
{
perror("accept error");
return -1;
} <\/p>\n
pthread_t tid;
\/\/ \u521b\u5efa\u7ebf\u7a0b\u5904\u7406\u5ba2\u6237\u7aef\u8bf7\u6c42
int ret = pthread_create(&tid, NULL, server_request, (void *)clientfd);
if (ret != 0)
{
printf ("create pthread error!n");
return -1;
}
pthread_detach(tid); \/\/ \u7ebf\u7a0b\u5206\u79bb
}<\/p>\n
pthread_mutex_destroy(&mutex);<\/p>\n
return 0; #include <stdio.h>#include <sys\/types.h>#include <sys\/socket.<\/p>\n","protected":false},"author":2,"featured_media":4350,"comment_status":"","ping_status":"","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[3322],"tags":[3949],"class_list":["post-5079","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-ktougao","tag--server"],"_links":{"self":[{"href":"https:\/\/www.kenpai.com\/cms\/wp-json\/wp\/v2\/posts\/5079","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.kenpai.com\/cms\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.kenpai.com\/cms\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.kenpai.com\/cms\/wp-json\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/www.kenpai.com\/cms\/wp-json\/wp\/v2\/comments?post=5079"}],"version-history":[{"count":0,"href":"https:\/\/www.kenpai.com\/cms\/wp-json\/wp\/v2\/posts\/5079\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.kenpai.com\/cms\/wp-json\/wp\/v2\/media\/4350"}],"wp:attachment":[{"href":"https:\/\/www.kenpai.com\/cms\/wp-json\/wp\/v2\/media?parent=5079"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.kenpai.com\/cms\/wp-json\/wp\/v2\/categories?post=5079"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.kenpai.com\/cms\/wp-json\/wp\/v2\/tags?post=5079"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}
}\u66f4\u591a\u5173\u4e8e\u4e91\u670d\u52a1\u5668\uff0c\u57df\u540d<\/a><\/span>\u6ce8\u518c\uff0c\u865a\u62df\u4e3b\u673a\u7684\u95ee\u9898\uff0c\u8bf7\u8bbf\u95ee\u57a6\u6d3e\u79d1\u6280<\/a><\/span>\u5b98\u7f51\uff1awww.kenpai.com<\/a><\/span><\/p>\n","protected":false},"excerpt":{"rendered":"