×

socketpair socket c

socketpair(进程间通讯 使用socket len长度)

admin admin 发表于2022-09-02 22:38:49 浏览129 评论0

抢沙发发表评论

本文目录

进程间通讯 使用socket len长度


使用socket实现进程间通信:(UNIX domain中面向连接通信)
使用套接字除了可以实现网络间不同主机间的通信外,还可以实现同一主机的不同进程间的通信,且建立的通信是双向的通信。
man unix内容如下:
NAME( 名称)
unix, PF_UNIX, AF_UNIX, PF_LOCAL, AF_LOCAL ? 用于本地内部进程通讯的套接 字。
SYNOPSIS( 总览 )
#include 《sys/socket.h》
#include 《sys/un.h》
unix_socket = socket(PF_UNIX, type, 0);
error = socketpair(PF_UNIX, type, 0, int *sv);
DESCRIPTION( 描述 )
PF_UNIX (也称作 PF_LOCAL ) 套接字族用来在同一机器上的提供有效的进程间通讯.Unix 套接字可以是匿名的(由 socketpair(2)创建), 也可以与套接字类型文件相关联. Linux 还支持一种抽象名字空间, 它是独立于文件系统的.
有效的类型有: SOCK_STREAM 用于面向流的套接字, SOCK_DGRAM 用于面向数据报的套接字,其可以保存消息界限. Unix 套接字总是可靠的,而且不会重组数据报.
Unix 套接字支持把文件描述符或者进程的信用证明作为数据报的辅助数据传递给 其它进程.
ADDRESS FORMAT( 地址格式 )
unix 地址定义为文件系统中的一个文件名或者抽象名字空间中的一个单独的字符串. 由 socketpair(2) 创建的套接字是匿名的.对于非匿名的套接字,目标地址 可使用 connect(2) 设置. 本地地址可使用 bind(2) 设置. 当套接字连接上而且它没有一个本地地址时, 会自动在抽象名字空间中生成一个唯一的地址.
#define UNIX_PATH_MAX 108
struct sockaddr_un {
sa_family_t sun_family; /* AF_UNIX */
char sun_path[UNIX_PATH_MAX]; /* 路径名 */
};
sun_family 总是包含 AF_UNIX. sun_path 包含空零结尾的套接字在文件系统中的路径名. 如果 sun_path 以空零字节开头,它指向由 Unix 协议模块维护的抽象名字空间. 该套接字在此名字空间中的地址由 sun_path 中的剩余字节给定. 注意抽象名字空间的名字都不是空零终止的.
SOCKET OPTIONS( 套接字选项 )
由 于 历 史 原 因, 这些套接字选项通过 SOL_SOCKET 类型确定, 即使它们是 PF_UNIX 指定的. 它们可以由 setsockopt(2) 设置. 通过指定 SOL_SOCKET 作 为套接字族用 getsockopt(2) 来读取.
SO_PASSCRED 允许接收进程辅助信息发送的信用证明. 当设置了该选项且套接字 尚未连接时, 则会自动生成一个抽象名字空间的唯一名字. 值为一个整数布尔标 识.
ANCILLARY MESSAGES( 辅助信息 )
由 于 历 史 原 因, 这些辅助信息类型通过 SOL_SOCKET 类型确定, 即使它们是 PF_UNIX 指定的. 要发送它们, 可设置结构 cmsghdr 的 cmsg_level 字 段 为 SOL_SOCKET, 并 设 置 cmsg_type 字段为其类型. 要获得更多信息, 请参看 cmsg(3).
SCM_RIGHTS
为其他进程发送或接收一套打开文件描述符. 其数据部分包含一个文件 描述符的整型数组. 已传文件描述符的效果就如它们已由 dup(2) 创建 过一样.
SCM_CREDENTIALS
发送或者接收 unix 信用证明. 可用作认证.信用证明传送 以 struct ucred 辅助信息的形式传送.
struct ucred {
pid_t pid; /* 发送进程的进程标识 */
uid_t uid; /* 发送进程的用户标识 */
gid_t gid; /* 发送进程的组标识 */
};
发 送者确定的信用证明由内核检查. 一个带有有效用户标识 0 的进程允许指定 不与其自身值相匹配的值.发送者必须确定其自身的进程 标 识( 除非它带 有 CAP_SYS_ADMIN), 其 用 户 标识,有效用户标识或者设置用户标识(除非它带有CAP_SETUID), 以及其组标识,有效组标识或者 设 置 组 标 识( 除非它带有CAP_SETGID). 为 了 接 收 一 条 struct ucred 消息,必须在套接字上激活 SO_PASSCRED 选项.
ERRORS( 错误 )
ENOMEM
内存溢出.

ECONNREFUSED
connect(2) 调用了一个未在监听的套接字对象. 这可能发生在远程套 接字不存在或者文件名不是套接字的时候.
EINVAL
传递了无效参数. 通常的产生原因是已传地址的 sun_type 字 段的 AF_UNIX 设置丢失, 或者套接字对应用的操作处于无效状态.
EOPNOTSUPP
在非面向流的套接字上调用了流操作,或者试图使用出界的数据选项.
EPROTONOSUPPORT
传递的协议是非 PF_UNIX 的.
ESOCKTNOSUPPORT
未知的套接字类型.
EPROTOTYPE
远程套接字与本地套接字类型不匹配 (SOCK_DGRAM 对SOCK_STREAM).
EADDRINUSE
选择的本地地址已经占用,或者文件系统套接字对象已经存在.
EISCONN
在 一个已经连接的套接字上调用 connect(2) 或者指定的目标地址在一 个已连接的套接字上.
ENOTCONN
套接字操作需要一个目的地址,但是套接字尚未连接.
ECONNRESET
远程套接字意外关闭.
EPIPE
远程套接字在一个流套接字上关闭了.如果激活,会同时发送一个 SIGPIPE 标识.这可以通过传递 MSG_NOSIGNAL 标识给 sendmsg(2) 或者 recvmsg(2) 来避免.
EFAULT
用户内存地址无效.
EPERM
发送者在 struct ucred 中传递无效的信用证明.
当生成一个文件系统套接字对象时, 可能会由通用套接层或者文件系统产生其它错误. 要获得更多信息,可参见合适的手册页.

实践:
使用套接字在UNIX域内实现进程间通信的服务端程序。首先,程序通过调用socket函数,建立了监听连接的套接字,然后调用bind函数,将套接字与地址信息关联起来。调用listen函数实现对该端口的监听,当有连接请求时,通过调用accept函数建立与客户机的连接,最后,调用read函数来读取客户机发送过来的消息,当然也可以使用recv函数实现相同的功能。
server代码:s_unix.c
[c-sharp] view plain copy
//s_unix.c
#include 《stdio.h》
#include 《sys/types.h》
#include 《sys/socket.h》
#include 《sys/un.h》
#define UNIX_DOMAIN “/tmp/UNIX.domain“
int main(void)
{
socklen_t clt_addr_len;
int listen_fd;
int com_fd;
int ret;
int i;
static char recv_buf;
int len;
struct sockaddr_un clt_addr;
struct sockaddr_un srv_addr;
listen_fd=socket(PF_UNIX,SOCK_STREAM,0);
if(listen_fd《0)
{
perror(“cannot create communication socket“);
return 1;
}

//set server addr_param
srv_addr.sun_family=AF_UNIX;
strncpy(srv_addr.sun_path,UNIX_DOMAIN,sizeof(srv_addr.sun_path)-1);
unlink(UNIX_DOMAIN);
//bind sockfd & addr
ret=bind(listen_fd,(struct sockaddr*)&srv_addr,sizeof(srv_addr));
if(ret==-1)
{
perror(“cannot bind server socket“);
close(listen_fd);
unlink(UNIX_DOMAIN);
return 1;
}
//listen sockfd
ret=listen(listen_fd,1);
if(ret==-1)
{
perror(“cannot listen the client connect request“);
close(listen_fd);
unlink(UNIX_DOMAIN);
return 1;
}
//have connect request use accept
len=sizeof(clt_addr);
com_fd=accept(listen_fd,(struct sockaddr*)&clt_addr,&len);
if(com_fd《0)
{
perror(“cannot accept client connect request“);
close(listen_fd);
unlink(UNIX_DOMAIN);
return 1;
}
//read and printf sent client info
printf(“/n=====info=====/n“);
for(i=0;i《4;i++)
{
memset(recv_buf,0,1024);
int num=read(com_fd,recv_buf,sizeof(recv_buf));
printf(“Message from client (%d)) :%s/n“,num,recv_buf);
}
close(com_fd);
close(listen_fd);
unlink(UNIX_DOMAIN);
return 0;
}
使用套接字在UNIX域内实现进程间通信的客户端程序。相比服务端的程序,客户段较为简单。程序首先通过调用socket函数创建通信所需的套接字,然后,调用connect函数来连接服务器,在成功建立连接后,通过调用write函数向服务器发送指定的消息。
client代码:u_unix.c
[c-sharp] view plain copy
//c_unix.c
#include 《stdio.h》
#include 《sys/types.h》
#include 《sys/socket.h》
#include 《sys/un.h》
#define UNIX_DOMAIN “/tmp/UNIX.domain“
int main(void)
{
int connect_fd;
int ret;
char snd_buf;
int i;
static struct sockaddr_un srv_addr;
//creat unix socket
connect_fd=socket(PF_UNIX,SOCK_STREAM,0);
if(connect_fd《0)
{
perror(“cannot create communication socket“);
return 1;
}
srv_addr.sun_family=AF_UNIX;
strcpy(srv_addr.sun_path,UNIX_DOMAIN);
//connect server
ret=connect(connect_fd,(struct sockaddr*)&srv_addr,sizeof(srv_addr));
if(ret==-1)
{
perror(“cannot connect to the server“);
close(connect_fd);
return 1;
}
memset(snd_buf,0,1024);
strcpy(snd_buf,“message from client“);
//send info server
for(i=0;i《4;i++)
write(connect_fd,snd_buf,sizeof(snd_buf));
close(connect_fd);
return 0;
}
编译运行:
[root@localhost liuxltest]# ./s_unix &
11664
[root@localhost liuxltest]# ./c_unix &
=====info=====
Message from client (1024)) :message from client
Message from client (1024)) :message from client
Message from client (1024)) :message from client
Message from client (1024)) :message from client
11665
- Done ./s_unix
+ Done ./c_unix
[root@localhost liuxltest]#
当运行s_unix程序后,该程序将处于监听状态。这时,可以通过netstat命令查看程序运行情况,s_unix的套接字类型为流套接字,并处于监听状态。
[root@localhost liuxltest]#
[root@localhost liuxltest]# ./s_unix &
12056
[root@localhost liuxltest]# netstat -an |grep /tmp
unix 2 [ ACC ] STREAM LISTENING 64014 /tmp/ssh-CekOJ11069/agent.11069
unix 2 [ ACC ] STREAM LISTENING 6216 /tmp/.font-unix/fs7100
unix 2 [ ACC ] STREAM LISTENING 62042 /tmp/ssh-XOCgkr9439/agent.9439
unix 2 [ ACC ] STREAM LISTENING 62316 /tmp/ssh-mojoaQ9648/agent.9648
unix 2 [ ACC ] STREAM LISTENING 65267 /tmp/UNIX.domain
unix 2 [ ACC ] STREAM LISTENING 65210 /tmp/ssh-NlKtA12012/agent.12012
[root@localhost liuxltest]#

socket(PF_INET, SOCK_STREAM, 0);//socket编程,参数置AF_INET;与PF_INET区别是什么


AF 表示ADDRESS FAMILY 地址族
  PF 表示PROTOCOL FAMILY 协议族
  但这两个宏定义是一样的
  所以使用哪个都没有关系
  Winsock2.h中
  #define AF_INET 0
  #define PF_INET AF_INET
  所以在windows中AF_INET与PF_INET完全一样
  而在Unix/Linux系统中,在不同的版本中这两者有微小差别
  对于BSD,是AF,对于POSIX是PF
  UNIX系统支持AF_INET,AF_UNIX,AF_NS等,而DOS,Windows中仅支持AF_INET,它是网际网区域。
  在函数socketpair与socket的domain参数中有AF_UNIX,AF_LOCAL,AF_INET,PF_UNIX,PF_LOCAL,PF_INET.这几个参数有AF_UNIX=AF_LOCAL, PF_UNIX=PF_LOCAL, AF_LOCAL=PF_LOCAL, AF_INET=PF_INET.
  建议:对于socketpair与socket的domain参数,使用PF_LOCAL系列,而在初始化套接口地址结构时,则使用AF_LOCAL.
  例如: z = socket(PF_LOCAL, SOCK_STREAM, 0); adr_unix.sin_family = AF_LOCAL;

windows下有socketpair吗


1.头文件 windows下winsock.h或winsock2.h linux下netinet/in.h(大部分都在这儿),unistd.h(close函数在这儿),sys/socket.h(在in.h里已经包含了,可以省了) 2.初始化 windows下需要用WSAStartup启动Ws2_32.lib,并且要用#pragma comment(lib,“Ws2_32“)来告知编译器链接该lib. linux下不需要 3.关闭socket windows下closesocket() linux下close() 4.类型 windows下SOCKET linux下int(我喜欢用long,这样保证是4byte,因为-1我总喜欢写成0xFFFF) 5.获取错误码 windows下getlasterror()/WSAGetLastError() linux下,未能成功执行的socket操作会返回-1; 如果包含了errno.h,就会设置errno变量 6.设置非阻塞 windows下ioctlsocket() linux下fcntl(),需要头文件fcntl.h 7.send函数最后一个参数 windows下一般设置为0 linux下最好设置为MSG_NOSIGNAL,如果不设置,在发送出错后有可能会导致程序退出 8.毫秒级时间获取 windows下GetTickCount() linux下gettimeofday() 9.多线程 windows下包含process.h,使用_beginthread和_endthread linux下包含pthread.h,使用pthread_create和pthread_exit 10.用IP定义一个地址(sockaddr_in的结构的区别) windows下addr_var.sin_addr.S_un.S_addr linux下addr_var.sin_addr.s_addr 而且Winsock里最后那个32bit的S_addr也有几个以联合(Union)的形式与它共享内存空间的成员变量(便于以其他方式赋值),而Linux的Socket没有这个联合,就是一个32bit的s_addr.遇到那种得到了是4个char的IP的形式(比如127一个,0一个,0一个和1一个共四个char),WinSock可以直接用4个S_b来赋值到S_addr里,而在Linux下,可以用边向左移位(一下8bit,共四下)边相加的方法赋值. 11.异常处理 linux下当连接断开,还发数据的时候,不仅send()的返回值会有反映,而且还会像系统发送一个异常消息,如果不作处理,系统会出BrokePipe,程序会退出.为此,send()函数的最后一个参数可以设MSG_NOSIGNAL,禁止send()函数向系统发送异常消息.
-socket

socket(PF_INET,SOCK_STREAM,0);//socket编程,参数置AF_INET;与PF_INET区别是什么


AF表示ADDRESSFAMILY地址族
  PF表示PROTOCOLFAMILY协议族
  但这两个宏定义是一样的
  所以使用哪个都没有关系
  Winsock2.h中
  #defineAF_INET0
  #definePF_INETAF_INET
  所以在windows中AF_INET与PF_INET完全一样
  而在Unix/Linux系统中,在不同的版本中这两者有微小差别
  对于BSD,是AF,对于POSIX是PF
  UNIX系统支持AF_INET,AF_UNIX,AF_NS等,而DOS,Windows中仅支持AF_INET,它是网际网区域。
  在函数socketpair与socket的domain参数中有AF_UNIX,AF_LOCAL,AF_INET,PF_UNIX,PF_LOCAL,PF_INET.这几个参数有AF_UNIX=AF_LOCAL,PF_UNIX=PF_LOCAL,AF_LOCAL=PF_LOCAL,AF_INET=PF_INET.
  建议:对于socketpair与socket的domain参数,使用PF_LOCAL系列,而在初始化套接口地址结构时,则使用AF_LOCAL.
  例如:z=socket(PF_LOCAL,SOCK_STREAM,0);adr_unix.sin_family=AF_LOCAL;
-c

什么是猴子补丁


你好,很高兴为你解答。
猴子补丁的由来
首先说个我自己的笑话,话说Python算是我接触的稍微深点儿的第一门动态语言,用Python没多久就知道了有个Gevent,学习Gevent没多久就知道有个“猴子补丁”的概念。最开始觉得这么名字挺乐呵,猴子补丁,为啥叫这么个名儿?是因为猴子的动作迅速灵敏,Gevent也有这个特点,所以叫猴子补丁么?
然后这几天在看《松本行弘的程序世界》这本书,里面专门有一章讲了猴子补丁的设计,我就笑了,原来猴子补丁不是我理解的这个意思,更不是Gevent最开始这么做的。所谓的猴子补丁的含义是指在动态语言中,不去改变源码而对功能进行追加和变更。猴子补丁的这个叫法起源于Zope框架,大家在修正Zope的Bug的时候经常在程序后面追加更新部分,这些被称作是“杂牌军补丁(guerilla patch)”,后来guerilla就渐渐的写成了gorllia(猩猩),再后来就写了monkey(猴子),所以猴子补丁的叫法是这么莫名其妙的得来的。
从Gevent学习猴子补丁的设计
猴子补丁这种东西充分利用了动态语言的灵活性,可以对现有的语言Api进行追加,替换,修改Bug,甚至性能优化等等。比如gevent的猴子补丁就可以对ssl、socket、os、time、select、thread、subprocess、sys等模块的功能进行了增强和替换。我们来看下gevent中的猴子补丁模块gevent.monkey的设计和实现,以后如果自己要设计实现猴子补丁,也可以按照这么个模式去做,我最近比较喜欢用ipython来阅读python模块的代码,执行import gevent.monkey之后,只需要输入??gevent.monkey就可以查看源码了。
这个模块核心的函数其实就这几个,这些函数都位于模块的上方,get_original、patch_item、remove_item、patch_module还有一个全局变量叫做saved,默认指向一个空的字典对象。
首先来看patch_item函数的实现:
def patch_item(module, attr, newitem):
NONE = object()
olditem = getattr(module, attr, NONE)
if olditem is not NONE:
saved.setdefault(module.__name__, {}).setdefault(attr, olditem)
setattr(module, attr, newitem)
这个函数的功能就是从指定模块中查找旧的项,并把旧的项保存到saved字典中,然后将旧项替换成新项。
这里没有使用None,而是构建了一个空的object()作为默认属性,是NullPointer模式么?
然后是patch_module的实现:
def patch_module(name, items=None):
gevent_module = getattr(__import__(’gevent.’ + name), name)
module_name = getattr(gevent_module, ’__target__’, name)
module = __import__(module_name)
if items is None:
items = getattr(gevent_module, ’__implements__’, None)
if items is None:
raise AttributeError(’%r does not have __implements__’ % gevent_module)
for attr in items:
patch_item(module, attr, getattr(gevent_module, attr))
gevent有个约定,作为补丁的gevent模块要包含这两个属性,__target__和__implements__,__target__是被补丁的默认模块名称,可以不指定,默认为gevent子模块的名称,比如gevent.socket是socket模块的补丁,__implements__是要进行补丁的属性,这是gevent.socket模块中__implements__的定义:
# standard functions and classes that this module re-implements in a gevent-aware way:
__implements__ = [’create_connection’,
’socket’,
’SocketType’,
’fromfd’,
’socketpair’]
patch_module的工作就是从gevent模块里面读取这两个属性,然后遍历调用patch_item进行替换。
可是有的时候我们不希望用补丁的东西,而是使用原先的模块去进行处理,该怎么办?前面提到过进行patch_item的时候会把旧的属性保存到名为saved的全局字典里面,如果要获得旧的模块属性,那么就要调用get_original函数从saved字典里面取出来。
In : sleep = gevent.monkey.get_original(“time“, “sleep“)
In : sleep
Out: 《function time.sleep》
In : import time
In : time.sleep
Out: 《function gevent.hub.sleep》
猴子补丁
猴子补丁的功能很强大,但是也带来了很多的风险,尤其是像gevent这种直接进行API替换的补丁,整个Python进程所使用的模块都会被替换,可能自己的代码能hold住,但是其它第三方库,有时候问题并不好排查,即使排查出来也是很棘手,所以,就像松本建议的那样,如果要使用猴子补丁,那么只是做功能追加,尽量避免大规模的API覆盖。
希望能帮到你,求采纳。
-socket

socket编程为什么要选择AF_INET


选择 AF_INET 的目的就是使用 IPv4 进行通信。因为 IPv4 使用 32 位地址,相比 IPv6 的 128 位来说,计算更快,便于用于局域网通信。

而且 AF_INET 相比 AF_UNIX 更具通用性,因为 Windows 上有 AF_INET 而没有 AF_UNIX。

注:AF_INET(又称 PF_INET)是 IPv4 网络协议的套接字类型,AF_INET6 则是 IPv6 的;而 AF_UNIX 则是 Unix 系统本地通信。

扩展资料:

AF_INET和PF_INET的区别

1、AF 表示ADDRESS FAMILY 地址族 

2、PF 表示PROTOCL FAMILY 协议族

3、Winsock2.h中

#define AF_INET 0

#define PF_INET AF_INET
所以在windows中AF_INET与PF_INET完全一样

4、而在Unix/Linux系统中,在不同的版本中这两者有微小差别,对于BSD,是AF,对于POSIX是PF

在函数socketpair与socket的domain参数中有:AF_UNIX,AF_LOCAL,AF_INET,PF_UNIX,PF_LOCAL,PF_INET.

这几个参数有:AF_UNIX=AF_LOCAL, PF_UNIX=PF_LOCAL, AF_LOCAL=PF_LOCAL, AF_INET=PF_INET. 

对于socketpair与socket的domain参数,使用PF_LOCAL系列,而在初始化套接口地址结构时,则使用AF_LOCAL.

例如: z = socket(PF_LOCAL, SOCK_STREAM, 0);     adr_unix.sin_family = AF_LOCAL;


socketpair要关掉一个文件描述符吗


非阻塞IO 和阻塞IO: 在网络编程中对于一个网络句柄会遇到阻塞IO 和非阻塞IO 的概念, 这里对于这两种socket 先做一下说明: 基本概念: 阻塞IO:: socket 的阻塞模式意味着必须要做完IO 操作(包括错误)才会 返回。 非阻塞IO:: 非阻塞模式下无论...
-c

socket和socketpair的区别


输出:
parent Sending data: 1
son Data received: 1
son send received: 2
parent Data received: 2
parent Sending data: 3
son Data received: 3
son send received: 4
parent Data received: 4
-socket

linux socketpair和pipe哪个效率高


ifconfig 查看你是否开启网卡 /etc/init.d/network restart 启动网卡 查看 cd /etc/sysconfig/network-scripts/ 是否有ifcfg-eth0这个文件 没有的话配置一个 内容 DEVICE=eth0 (哪张网卡) ONBOOT=yes BOOTPROTO=static
-c