我正在尝试使用 AF_INET 系列的套接字在同一进程的线程之间创建本地连接。
服务器应该通过与线程的多路复用来处理客户端并服务他们的请求。
所以在服务器的主线程我有这个用于外部连接:( 为了保持帖子的长度合理,省略了检查错误)
struct sockaddr_in server_addr;
struct sockaddr *serverptr=(struct sockaddr *)&server_addr;
listening_sock = socket(AF_INET, SOCK_STREAM, 0);
fds[0].fd = listening_sock;
fds[0].events = POLLIN;
// Setting listening socket
server_addr.sin_addr.s_addr = htonl(INADDR_ANY);
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(port);
int one = 1;
setsockopt(listening_sock, SOL_SOCKET, SO_REUSEADDR, (void *)&one, sizeof(one));
setsockopt(listening_sock, IPPROTO_TCP, TCP_NODELAY, (void *)&one, sizeof(one));
bind(listening_sock, serverptr, sizeof(server_addr));
listen(listening_sock, 5);
然后使用 poll 我在侦听套接字上成功轮询(与客户端通信)。
现在我想通过 TCP 创建一个内部套接字,用于主线程和我将创建的新线程之间的通信。
我已经添加了这些:
struct sockaddr_in loopback_addr;
struct sockaddr *loopbackptr=(struct sockaddr *)&loopback_addr;
loopback_sock = socket(AF_INET, SOCK_STREAM, 0); //checking for errors is omitted
fds[1].fd = loopback_sock;
fds[1].events = POLLIN;
// Setting loopback socket
loopback_addr.sin_addr.s_addr = htonl(IN_LOOPBACKNET);
loopback_addr.sin_family = AF_INET;
loopback_addr.sin_port = htons(18000);
int one = 1;
setsockopt(loopback_sock, SOL_SOCKET, SO_REUSEADDR, (void *)&one, sizeof(one));
setsockopt(loopback_sock, IPPROTO_TCP, TCP_NODELAY, (void *)&one, sizeof(one));
bind(loopback_sock, loopback_ptr, sizeof(loopback_addr));
listen(loopback_sock, 5);
并且还将 nfds 计数器增加到 2。
现在线程在 poll 循环之前启动并尝试与此代码进行通信:
struct sockaddr_in server;
struct sockaddr *serverptr = (struct sockaddr*)&server;
int sock;
if ((sock = socket(AF_INET, SOCK_STREAM, 0)) < 0)
{
perror("thread: socket");
pthread_exit((void*)-1);
}
int port = 18000;
server.sin_family = AF_INET;
server.sin_addr.s_addr = IN_LOOPBACKNET;
server.sin_port = htons(port);
if (connect(sock, serverptr, sizeof (server)) < 0)
{
perror("thread: connect");
pthread_exit((void*)-1);
}
发生的事情是 connect 系统调用返回thread: connect: Network is unreachable
。
在服务器的主循环中,我有这个:
if (fd[1].revents)
printf("Loopback socket\n");
检查此套接字是否有任何交互,但这从不打印任何内容。
我不知道如何设置内部套接字,如果有我可以阅读的教程,一个链接将非常受欢迎!
这可能很简单,但是由于我是套接字编程的新手,所以我找不到它。
编辑:
在将 IN_LOOPBACKNET 更改为 htonl(INADDR_LOOPBACK) 后,连接仍然失败,但有一条新消息,connection refused
.
但仍然没有来自 fds[2] 的回复。