用C进行多线程客户端服务器套接字编程
|
我正在同一台具有相同IP地址但具有不同客户端和服务器端口的计算机上用C实现多线程客户端-服务器套接字编程。我已经在C环境中使用pthread概念实现了它。但是我只能看到我的客户线程正在运行，而我的服务器线程一旦到达\'accept（）\'例程就已停止。
我想知道可能是什么问题。如果有人可以找出我在哪里犯错，那将真的很有帮助
我的客户端代码如下所示：
void *client_connect(void *arg)
{
int client_socket;
struct sockaddr_in Serv_Addr;
struct sockaddr_in Client_Addr;
int addrlen=sizeof(Client_Addr);
char send_buffer_client[] = {\"server message\"};
char recv_buffer_client[1024];
int nbytes;
client_socket = lwip_socket(AF_INET, SOCK_STREAM, 0);
if (client_socket < 0) ;
memset((char *)&Serv_Addr, 0, sizeof(Serv_Addr));
Serv_Addr.sin_family = AF_INET;
Serv_Addr.sin_len = sizeof(Serv_Addr);
Serv_Addr.sin_addr.s_addr = inet_addr(\"1.2.3.4\");
Serv_Addr.sin_port = 9999;
memset((char *)&Client_Addr, 0, sizeof(Client_Addr));
Client_Addr.sin_family = AF_INET;
Client_Addr.sin_len = sizeof(Client_Addr);
Client_Addr.sin_addr.s_addr = inet_addr(\"1.2.3.4\");
Client_Addr.sin_port = 5555;
lwip_connect(client_socket, (struct sockaddr *)&Serv_Addr, sizeof(Serv_Addr));
while (1) {
do{
nbytes = lwip_recv(client_socket, recv_buffer_client, sizeof(recv_buffer_client),0);
if (nbytes>0) lwip_send(client_socket, send_buffer_client, sizeof(send_buffer_client), 0);
printf(\"server message = %s\\n\", recv_buffer_client);
} while (nbytes>0);
sleep(10);
}
lwip_close(client_socket);
}
void *server_connect(void *arg)
{
int server_socket;
struct sockaddr_in Serv_Addr;
struct sockaddr_in Client_Addr;
int addrlen=sizeof(Client_Addr);
int clientfd;
char send_buffer[] = {\"Server message\"};
char recv_buffer[1024];
int nbytes_server, client_length;
server_socket = lwip_socket(AF_INET, SOCK_STREAM, 0);
if (server_socket < 0)
printf(\"could not create server socket\");
else
printf(\"created SERVER socket\");
memset((char *)&Serv_Addr, 0, sizeof(Serv_Addr));
Serv_Addr.sin_family = AF_INET;
Serv_Addr.sin_len = sizeof(Serv_Addr);
Serv_Addr.sin_addr.s_addr = inet_addr(\"1.2.3.4\");
Serv_Addr.sin_port = 9999;
client_length = sizeof(Client_Addr);
if (lwip_bind(server_socket, (struct sockaddr *)&Serv_Addr, sizeof(Serv_Addr)) < 0) {
printf(\"could not BIND\");
}
if ( lwip_listen(server_socket, 20) != 0 ){
printf(\"could not BIND\");
}
while (1) {
lwip_accept(server_socket, (struct sockaddr*)&Client_Addr, &client_length);
do{
nbytes_server = lwip_recv(server_socket, recv_buffer, sizeof(recv_buffer),0);
if (nbytes_server>0){lwip_send(server_socket, send_buffer, sizeof(send_buffer), 0);}
printf(\"client message = %s\\n\", recv_buffer);
}while(nbytes_server>0);
sleepms(10);
}
lwip_close(server_socket);
}
void main(void)
{
pthread_t client_thread;
pthread_t server_thread;
pthread_create(&server_thread, NULL, server_connect, NULL);
pthread_create(&client_thread, NULL, client_connect, NULL);
while(1){
sleepms(1);
}
}
没有找到相关结果
已邀请:
3 个回复
才改隘瘁
和客户端端口相同-htons将短字节从主机字节序转换为网络字节序 您没有发送任何数据！您的客户端等待服务器向它发送东西。但是您的服务器不发送任何东西，它等待客户端发送东西。什么都不会发生。 检查lwip_connect是否也失败，并检查errno（如果您的环境提供了它），因为它可能会提供问题的线索场竟矩喘崩
中的常量，它将常量绑定到系统上的任何接口。在客户端，尽管您仍然需要正确的IP地址，但是同样，如果它是本地主机，则可以只使用127.0.0.1。信藉乒
while (1) { lwip_accept(server_socket, (struct sockaddr*)&Client_Addr, &client_length); do { nbytes_server = lwip_recv(server_socket, recv_buffer, sizeof(recv_buffer), 0); if (nbytes_server > 0) { lwip_send(server_socket, send_buffer, sizeof(send_buffer), 0); } printf(\"client message = %s\\n\", recv_buffer); } while (nbytes_server > 0); sleepms(10); }