rt
我想要用一个进程监听端口，如果有请求过来，则让另一个进程去处理，请问能否做到？ ?
xiafeng 回复于：2007-04-17 09:32:12
进程？
isnowran 回复于：2007-04-17 09:37:00
可以
ken1984 回复于：2007-04-17 09:42:04
共享内存？
bleem1998 回复于：2007-04-17 09:42:29
'传递文件描述符'
没搞过
但可以肯定是传递的
kylints 回复于：2007-04-17 10:02:21
传说中的代理？
converse 回复于：2007-04-17 10:16:57
LZ的意思是A,B两个进程,A收到一个连接,把这个连接的socket传递给B处理么?
converse 回复于：2007-04-17 10:27:40
如果是我上面说的那个意思,那么我认为是不行的.因为在unix中socket属于文件描述符的一种,独立于进程的(父子进程间可以复制),一个进程退出的时候系统会自动关闭这个进程打开的所有文件描述符,所以对一个进程而言的socket 3123可能到了另一个不相干的进程中就不是同一个东西了.
当然,如果收到了连接之后fork一个进程进行处理那么是可以的.
alazer 回复于：2007-04-17 10:43:01
引用：原帖由 converse 于 2007-4-17 10:16 发表
LZ的意思是A,B两个进程,A收到一个连接,把这个连接的socket传递给B处理么?
如果是这个意思的话,windows下的线程(!!)倒是可以传递的
比如一个线程,把连接的socket传给另外一个线程,另外一个线程读写此socket.
但是windows有时候会出问题,就是lisnSock在刚刚连接上时创建的AcptSock,这时候把AcptSock传给另外一个线程,如果此时本地的监听线程停掉的话,会导致AcptSock可能也会停掉,查了很久的,哎
converse 回复于：2007-04-17 10:44:07
引用：原帖由 alazer 于 2007-4-17 10:43 发表
如果是这个意思的话,windows下的线程(!!)倒是可以传递的
比如一个线程,把连接的socket传给另外一个线程,另外一个线程读写此socket.
但是windows有时候会出问题,就是lisnSock在刚刚连接上时创建的AcptSock,这时 ...
线程当然可以,线程都在同一个进程内共享所有的进程资源.
思一克 回复于：2007-04-17 10:48:03
有亲属关系的进程可以。否则不可以。
converse 回复于：2007-04-17 10:49:59
引用：原帖由 思一克 于 2007-4-17 10:48 发表
有亲属关系的进程可以。否则不可以。
如果是先fork一个子进程,然后接收连接,再传递给子进程处理,那也还是不行的吧,因为后来的连接不在子进程的空间内了.
思一克 回复于：2007-04-17 10:52:48
必须先有sock fd, 然后fork.
converse 说的对。先fork了，两个独立的
bleem1998 回复于：2007-04-17 10:53:35
mq110以前问过一个传递文件描述符的问题
用sendmsg可以做到
转一个网上的文章
我们知道父进程在子进程被fork出来之前打开的文件描述符是能被子进程继承下来的，但是一旦子进程已经创建后，父进程打开的文件描述符要怎样才能传递给子进程呢？Unix提供相应的技术来满足这一需求，这就是同一台主机上进程间的文件描述符传递，很美妙而且强大的技术。
想象一下我们试图实现一个服务器，接收多个客户端的连接，我们欲采用多个子进程并发的形式来处理多客户端的同时连接，这时候我们可能有两种想法：
1、客户端每建立一条连接，我们fork出一个子进程负责处理该连接；
2、预先创建一个进程池，客户端每建立一条链接，服务器就从该池中选出一个空闲(Idle)子进程来处理该连接。
后者显然更高效，因为减少了子进程创建的性能损耗，反应的及时性大大增强。这里恰恰就出现了我们前面提到的问题，所有子进程都是在服务器Listen到一条连接以前就已经fork出来了，也就是说新的连接描述符子进程是不知道的，需要父进程传递给它，它接收到相应的连接描述符后，才能与相应的客户端进行通信处理。这里我们就可以使用'传递文件描述符'的方式来实现。
在'UNIX网络编程第1卷'的14.7小节中对这种技术有详细的阐述，实际上这种技术就是利用sendmsg和recvmsg在一定的UNIX域套接口(或者是某种管道)上发送和接收一种特殊的消息，这种消息可以承载'文件描述符'罢了，当然操作系统内核对这种消息作了特殊的处理。在具体一点儿'文件描述符'是作为辅助数据(Ancillary Data)通过msghdr结构中的成员msg_control(老版本中称为msg_accrights)发送和接收的。值得一提的是发送进程在将'文件描述符'发送出去后，即使立即关闭该文件描述符，该文件描述符对应的文件设备也没有被真正的关闭，其引用计数仍然大于一，直到接收进程成功接收后，再关闭该文件描述符，如果这时文件设备的引用计数为0，那么才真正关闭该文件设备。
OK，下面是一个简单的文件描述符传递的例子，该例子实现这样一个功能：即子进程负责在父进程传递给它的文件描述符对应的文件尾加上特定的'LOGO'字符串。例子环境为Solaris 9 + GCC 3.2
/* test_fdpass.c */
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/wait.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <errno.h>
#include <sys/socket.h> /* for socketpair */
#define MY_LOGO "-- Tony Bai"
static int send_fd(int fd, int fd_to_send)
{
struct iovec iov[1];
struct msghdr msg;
char buf[1];
if (fd_to_send >= 0) {
msg.msg_accrights = (caddr_t)&fd_to_send;
msg.msg_accrightslen = sizeof(int);
} else {
msg.msg_accrights = (caddr_t)NULL;
msg.msg_accrightslen = 0;
}
msg.msg_name = NULL;
msg.msg_namelen = 0;
iov[0].iov_base = buf;
iov[0].iov_len = 1;
msg.msg_iov = iov;
msg.msg_iovlen = 1;
if(sendmsg(fd, &msg, 0) < 0) {
printf("sendmsg error, errno is %d\n", errno);
return errno;
}
return 0;
}
static int recv_fd(int fd, int *fd_to_recv)
{
struct iovec iov[1];
struct msghdr msg;
char buf[1];
msg.msg_accrights = (caddr_t)fd_to_recv;
msg.msg_accrightslen = sizeof(int);
msg.msg_name = NULL;
msg.msg_namelen = 0;
iov[0].iov_base = buf;
iov[0].iov_len = 1;
msg.msg_iov = iov;
msg.msg_iovlen = 1;
if (recvmsg(fd, &msg, 0) < 0) {
return errno;
}
if(msg.msg_accrightslen != sizeof(int)) {
*fd_to_recv = -1;
}
return 0;
}
int x_sock_set_block(int sock, int on)
{
int val;
int rv;
val = fcntl(sock, F_GETFL, 0);
if (on) {
rv = fcntl(sock, F_SETFL, ~O_NONBLOCK&val);
} else {
rv = fcntl(sock, F_SETFL, O_NONBLOCK|val);
}
if (rv) {
return errno;
}
return 0;
}
int main() {
pid_t pid;
int sockpair[2];
int rv;
char fname[256];
int fd;
rv = socketpair(AF_UNIX, SOCK_STREAM, 0, sockpair);
if (rv < 0) {
printf("Call socketpair error, errno is %d\n", errno);
return errno;
}
pid = fork();
if (pid == 0) {
/* in child */
close(sockpair[1]);
for ( ; ; ) {
rv = x_sock_set_block(sockpair[0], 1);
if (rv != 0) {
printf("[CHILD]: x_sock_set_block error, errno is %d\n", rv);
break;
}
rv = recv_fd(sockpair[0], &fd);
if (rv < 0) {
printf("[CHILD]: recv_fd error, errno is %d\n", rv);
break;
}
if (fd < 0) {
printf("[CHILD]: child process exit normally!\n");
break;
}
/* 处理fd描述符对应的文件 */
rv = write(fd, MY_LOGO, strlen(MY_LOGO));
if (rv < 0) {
printf("[CHILD]: write error, errno is %d\n", rv);
} else {
printf("[CHILD]: append logo successfully\n");
}
close(fd);
}
exit(0);
}
/* in parent */
for ( ; ; ) {
memset(fname, 0, sizeof(fname));
printf("[PARENT]: please enter filename:\n");
scanf("%s", fname);
if (strcmp(fname, "exit") == 0) {
rv = send_fd(sockpair[1], -1);
if (rv < 0) {
printf("[PARENT]: send_fd error, errno is %d\n", rv);
}
break;
}
fd = open(fname, O_RDWR | O_APPEND);
if (fd < 0) {
if (errno == ENOENT) {
printf("[PARENT]: can't find file '%s'\n", fname);
continue;
}
printf("[PARENT]: open file error, errno is %d\n", errno);
}
rv = send_fd(sockpair[1], fd);
if (rv != 0) {
printf("[PARENT]: send_fd error, errno is %d\n", rv);
}
close(fd);
}
wait(NULL);
return 0;
}
编译：gcc -o test_fdpass -lsocket -lnsl test_fdpass.c
执行：test_fdpass(事先在同一目录下创建一个文件kk.log)
[PARENT]: please enter filename:
kk.log
[CHILD]: append logo successfully
[PARENT]: please enter filename:
cc.log
[PARENT]: can't find file 'cc.log'
exit
[CHILD]: child process exit normally!
你可以发现kk.log内容的末尾已经加上了我的独特LOGO '-- Tony Bai'。^_^
关于文件描述符传递的更多细节， W. Richard Stevens的'UNIX网络编程第1卷'和'UNIX环境高级编程'两本书中都有详细说明，参读即可。
yg 回复于：2007-04-17 10:54:54
无知者无畏啊，UNPV12e中有现成的例子
isnowran 回复于：2007-04-17 11:45:59
这是我平时用的描述符传递的库，可以参考一下
注: 进程间必须用流来传递，比如socketpair，不能用管道( 不是所有，但很多linux的实现管道并非基于流的 )
[ 本帖最后由 isnowran 于 2007-4-17 11:49 编辑 ]
transfd.tar.gz
converse 回复于：2007-04-17 12:41:34
to 1998 and 市长:
受教了,我回头看看,UNP第14章还没有看过~~
思一克 回复于：2007-04-17 13:22:38
原来根本不知道可以这样使用。学习了。谢谢
cugb_cat 回复于：2007-04-17 13:27:22
引用：原帖由 converse 于 2007-4-17 12:41 发表
to 1998 and 市长:
受教了,我回头看看,UNP第14章还没有看过~~
第三版的UNP是15章，15.7节
netvermin 回复于：2007-04-29 15:22:28
你如果使用fork的話，socket會復制一份到子進程中，這樣就有兩個socket了，它們是各自獨立工作的，關掉其中一個，另一個并不會被關掉
...
sock_client = accept(sock_listen, NULL, NULL);
if (fork() == 0)
{
close(sock_listen); //子進程中不用監聽的話就關掉子進程中的監聽套接字
... //在子進程中操作客戶連接
exit(0);
}
close(sock_client); //在父進程中不用處理客戶連接就關閉客戶連接套接字
...
trulyliu 回复于：2007-05-18 12:43:18
参考一下inet.d
wuxiangzhi 回复于：2007-05-18 15:32:14
sendmsg可以满足
A把自己拥有的SOCK,通过sendmsg发送给B,B就会自动获得这个SOCK的引用
|
