Server \u7aef<\/h5>\nint main(int argc, char *argv[])\n{\n int server_fd ,ret, client_fd;\n struct sockaddr_un serv, client;\n socklen_t len = sizeof(client);\n char buf[1024] = {0};\n int recvlen;\n\n \/\/ \u521b\u5efa socket\n server_fd = socket(AF_LOCAL, SOCK_STREAM, 0);\n\n \/\/ \u521d\u59cb\u5316 server \u4fe1\u606f\n serv.sun_family = AF_LOCAL;\n strcpy(serv.sun_path, "server.sock");\n\n \/\/ \u7ed1\u5b9a\n ret = bind(server_fd, (struct sockaddr *)&serv, sizeof(serv));\n\n \/\/\u8bbe\u7f6e\u76d1\u542c\uff0c\u8bbe\u7f6e\u80fd\u591f\u540c\u65f6\u548c\u670d\u52a1\u7aef\u8fde\u63a5\u7684\u5ba2\u6237\u7aef\u6570\u91cf\n ret = listen(server_fd, 36);\n\n \/\/\u7b49\u5f85\u5ba2\u6237\u7aef\u8fde\u63a5\n client_fd = accept(server_fd, (struct sockaddr *)&client, &len);\n printf("=====client bind file:%s\/n", client.sun_path);\n\n while (1) {\n recvlen = recv(client_fd, buf, sizeof(buf), 0);\n if (recvlen == -1) {\n perror("recv error");\n return -1;\n } else if (recvlen == 0) {\n printf("client disconnet...\/n");\n close(client_fd);\n break;\n } else {\n printf("recv buf %s\/n", buf);\n send(client_fd, buf, recvlen, 0);\n }\n }\n\n close(client_fd);\n close(server_fd);\n return 0;\n}<\/code><\/pre>\nClient \u7aef<\/h5>\nint main(int argc, char *argv[])\n{\n int client_fd ,ret;\n struct sockaddr_un serv, client;\n socklen_t len = sizeof(client);\n char buf[1024] = {0};\n int recvlen;\n\n \/\/\u521b\u5efasocket\n client_fd = socket(AF_LOCAL, SOCK_STREAM, 0);\n\n \/\/\u7ed9\u5ba2\u6237\u7aef\u7ed1\u5b9a\u4e00\u4e2a\u5957\u63a5\u5b57\u6587\u4ef6\n client.sun_family = AF_LOCAL;\n strcpy(client.sun_path, "client.sock");\n ret = bind(client_fd, (struct sockaddr *)&client, sizeof(client));\n\n \/\/\u521d\u59cb\u5316server\u4fe1\u606f\n serv.sun_family = AF_LOCAL;\n strcpy(serv.sun_path, "server.sock");\n \/\/\u8fde\u63a5\n connect(client_fd, (struct sockaddr *)&serv, sizeof(serv));\n\n while (1) {\n fgets(buf, sizeof(buf), stdin);\n send(client_fd, buf, strlen(buf)+1, 0);\n\n recv(client_fd, buf, sizeof(buf), 0);\n printf("recv buf %s\/n", buf);\n }\n\n close(client_fd);\n return 0;\n}<\/code><\/pre>\n\u547d\u540d\u7ba1\u9053(Named Pipe)<\/h3>\n\u662f\u4ec0\u4e48<\/h4>\n
\u547d\u540d\u7ba1\u9053\u662f\u53ef\u4ee5\u5728\u540c\u4e00\u53f0\u8ba1\u7b97\u673a\u7684\u4e0d\u540c\u8fdb\u7a0b\u4e4b\u95f4\uff0c\u6216\u8005\u8de8\u8d8a\u4e00\u4e2a\u7f51\u7edc\u7684\u4e0d\u540c\u8ba1\u7b97\u673a\u7684\u4e0d\u540c\u8fdb\u7a0b\u4e4b\u95f4\u7684\u53ef\u9760\u7684\u5355\u5411\u6216\u8005\u53cc\u5411\u7684\u6570\u636e\u901a\u4fe1\u3002
\u521b\u5efa\u547d\u540d\u7ba1\u9053\u7684\u8fdb\u7a0b\u88ab\u79f0\u4e3a\u7ba1\u9053\u670d\u52a1\u7aef(Pipe Server)\uff0c\u8fde\u63a5\u5230\u8fd9\u4e2a\u7ba1\u9053\u7684\u8fdb\u7a0b\u79f0\u4e3a\u7ba1\u9053\u5ba2\u6237\u7aef(Pipe Client)\u3002<\/p>\n
\u547d\u540d\u7ba1\u9053\u7684\u547d\u540d\u89c4\u8303\uff1a\/server\/pipe[\/path]\/name<\/p>\n
\n- \u5176\u4e2d server \u6307\u5b9a\u4e00\u4e2a\u670d\u52a1\u5668\u7684\u540d\u5b57\uff0c\u672c\u673a\u9002\u7528 . \u8868\u793a\uff0c\/192.10.10.1 \u8868\u793a\u7f51\u7edc\u4e0a\u7684\u670d\u52a1\u5668<\/li>\n
- \/pipe \u662f\u4e00\u4e2a\u4e0d\u53ef\u53d8\u5316\u7684\u5b57\u4e32\uff0c\u7528\u4e8e\u6307\u5b9a\u8be5\u6587\u4ef6\u5c5e\u4e8e NPFS(Named Pipe File System)<\/li>\n
- [\/path]\/name \u662f\u552f\u4e00\u547d\u540d\u7ba1\u9053\u540d\u79f0\u7684\u6807\u8bc6<\/li>\n<\/ul>\n
\u600e\u4e48\u5b9e\u73b0<\/h4>\n\u6d41\u7a0b\u56fe<\/h5>\n
![\"image\"](\"https:\/\/segmentfault.com\/img\/remote\/1460000042754893\" "\\"image\\"")
<\/p>\n
Pipe Server<\/h5>\nvoid ServerTest()\n{\n HANDLE serverNamePipe;\n char pipeName[MAX_PATH] = {0};\n char szReadBuf[MAX_BUFFER] = {0};\n char szWriteBuf[MAX_BUFFER] = {0};\n DWORD dwNumRead = 0;\n DWORD dwNumWrite = 0;\n\n strcpy(pipeName, "\/\/\/\/.\/\/pipe\/\/shuangxuPipeTest");\n \/\/ \u521b\u5efa\u7ba1\u9053\u5b9e\u4f8b\n serverNamePipe = CreateNamedPipeA(pipeName,\n PIPE_ACCESS_DUPLEX|FILE_FLAG_WRITE_THROUGH,\n PIPE_TYPE_BYTE|PIPE_READMODE_BYTE|PIPE_WAIT,\n PIPE_UNLIMITED_INSTANCES, 0, 0, 0, NULL);\n WriteLog("\u521b\u5efa\u7ba1\u9053\u6210\u529f...");\n \/\/ \u7b49\u5f85\u5ba2\u6237\u7aef\u8fde\u63a5\n BOOL bRt= ConnectNamedPipe(serverNamePipe, NULL );\n WriteLog( "\u6536\u5230\u5ba2\u6237\u7aef\u7684\u8fde\u63a5\u6210\u529f...");\n \/\/ \u63a5\u6536\u6570\u636e\n memset( szReadBuf, 0, MAX_BUFFER );\n bRt = ReadFile(serverNamePipe, szReadBuf, MAX_BUFFER-1, &dwNumRead, NULL );\n \/\/ \u4e1a\u52a1\u903b\u8f91\u5904\u7406 \uff08\u53ea\u4e3a\u6d4b\u8bd5\u7528\u8fd4\u56de\u539f\u6765\u7684\u6570\u636e\uff09\n WriteLog( "\u6536\u5230\u5ba2\u6237\u6570\u636e:[%s]", szReadBuf);\n \/\/ \u53d1\u9001\u6570\u636e\n if( !WriteFile(serverNamePipe, szWriteBuf, dwNumRead, &dwNumWrite, NULL ) )\n {\n WriteLog("\u5411\u5ba2\u6237\u5199\u5165\u6570\u636e\u5931\u8d25:[%#x]", GetLastError());\n return ;\n }\n WriteLog("\u5199\u5165\u6570\u636e\u6210\u529f...");\n}<\/code><\/pre>\nPipe Client<\/h5>\nvoid ClientTest()\n{\n char pipeName[MAX_PATH] = {0};\n HANDLE clientNamePipe;\n DWORD dwRet;\n char szReadBuf[MAX_BUFFER] = {0};\n char szWriteBuf[MAX_BUFFER] = {0};\n DWORD dwNumRead = 0;\n DWORD dwNumWrite = 0;\n\n strcpy(pipeName, "\/\/\/\/.\/\/pipe\/\/shuangxuPipeTest");\n \/\/ \u68c0\u6d4b\u7ba1\u9053\u662f\u5426\u53ef\u7528\n if(!WaitNamedPipeA(pipeName, 10000)){\n WriteLog("\u7ba1\u9053[%s]\u65e0\u6cd5\u6253\u5f00", pipeName);\n return ;\n }\n \/\/ \u8fde\u63a5\u7ba1\u9053\n clientNamePipe = CreateFileA(pipeName,\n GENERIC_READ|GENERIC_WRITE,\n 0,\n NULL,\n OPEN_EXISTING,\n FILE_ATTRIBUTE_NORMAL,\n NULL);\n WriteLog("\u7ba1\u9053\u8fde\u63a5\u6210\u529f...");\n scanf( "%s", szWritebuf );\n \/\/ \u53d1\u9001\u6570\u636e\n if( !WriteFile(clientNamePipe, szWriteBuf, strlen(szWriteBuf), &dwNumWrite, NULL)){\n WriteLog("\u53d1\u9001\u6570\u636e\u5931\u8d25,GetLastError=[%#x]", GetLastError());\n return ;\n }\n printf("\u53d1\u9001\u6570\u636e\u6210\u529f:%s\/n", szWritebuf );\n \/\/ \u63a5\u6536\u6570\u636e\n if( !ReadFile(clientNamePipe, szReadBuf, MAX_BUFFER-1, &dwNumRead, NULL)){\n WriteLog("\u63a5\u6536\u6570\u636e\u5931\u8d25,GetLastError=[%#x]", GetLastError() );\n return ;\n }\n WriteLog( "\u63a5\u6536\u5230\u670d\u52a1\u5668\u8fd4\u56de:%s", szReadBuf );\n \/\/ \u5173\u95ed\u7ba1\u9053\n CloseHandle(clientNamePipe);\n}<\/code><\/pre>\nNode \u521b\u5efa\u5b50\u8fdb\u7a0b\u7684\u6d41\u7a0b<\/h2>\nUnix<\/h3>\n
![\"image\"](\"https:\/\/segmentfault.com\/img\/remote\/1460000042754894\" "\\"image\\"")
<\/p>\n
\u5bf9\u4e8e\u521b\u5efa\u5b50\u8fdb\u7a0b\u3001\u521b\u5efa\u7ba1\u9053\u3001\u91cd\u5b9a\u5411\u7ba1\u9053\u5747\u662f\u5728 c++ \u5c42\u5b9e\u73b0\u7684<\/p>\n
\u521b\u5efa\u5b50\u8fdb\u7a0b<\/h4>\nint main(int argc,char *argv[]){\n pid_t pid = fork();\n if (pid < 0) {\n \/\/ \u9519\u8bef\n } else if(pid == 0) {\n \/\/ \u5b50\u8fdb\u7a0b\n } else {\n \/\/ \u7236\u8fdb\u7a0b\n }\n}<\/code><\/pre>\n\u521b\u5efa\u7ba1\u9053<\/h4>\n
\u4f7f\u7528 socketpair \u521b\u5efa\u7ba1\u9053\uff0c\u5176\u521b\u5efa\u51fa\u6765\u7684\u7ba1\u9053\u662f\u5168\u53cc\u5de5\u7684\uff0c\u8fd4\u56de\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26\u4e2d\u7684\u4efb\u4f55\u4e00\u4e2a\u90fd\u53ef\u8bfb\u548c\u53ef\u5199<\/p>\n
int main ()\n{\n int fd[2];\n int r = socketpair(AF_UNIX, SOCK_STREAM, 0, fd);\n\n if (fork()){ \/* \u7236\u8fdb\u7a0b *\/\n int val = 0;\n close(fd[1]);\n while (1){\n sleep(1);\n ++val;\n printf("\u53d1\u9001\u6570\u636e: %d\/n", val);\n write(fd[0], &val, sizeof(val));\n read(fd[0], &val, sizeof(val));\n printf("\u63a5\u6536\u6570\u636e: %d\/n", val);\n }\n } else { \/*\u5b50\u8fdb\u7a0b*\/\n int val;\n close(fd[0]);\n while(1){\n read(fd[1], &val, sizeof(val));\n ++val;\n write(fd[1], &val, sizeof(val));\n }\n }\n}<\/code><\/pre>\n\u5f53\u6211\u4eec\u4f7f\u7528 socketpair \u521b\u5efa\u4e86\u7ba1\u9053\u4e4b\u540e\uff0c\u7236\u8fdb\u7a0b\u5173\u95ed\u4e86 fd[1]\uff0c\u5b50\u8fdb\u7a0b\u5173\u95ed\u4e86 fd[0]\u3002\u5b50\u8fdb\u7a0b\u53ef\u4ee5\u901a\u8fc7 fd[1] \u8bfb\u5199\u6570\u636e\uff1b\u540c\u7406\u4e3b\u8fdb\u7a0b\u901a\u8fc7 fd[0]\u8bfb\u5199\u6570\u636e\u5b8c\u6210\u901a\u4fe1\u3002<\/p>\n
child_process.fork \u7684\u8be6\u7ec6\u8c03\u7528<\/h2>\n
fork \u51fd\u6570\u5f00\u542f\u4e00\u4e2a\u5b50\u8fdb\u7a0b\u7684\u6d41\u7a0b<\/p>\n
![\"image\"](\"https:\/\/segmentfault.com\/img\/remote\/1460000042754896\" "\\"image\\"")
<\/p>\n
\n- \n
\u521d\u59cb\u5316\u53c2\u6570\u4e2d\u7684 options.stdio\uff0c\u5e76\u4e14\u8c03\u7528 spawn \u51fd\u6570<\/p>\n
function spawn(file, args, options) {\n const child = new ChildProcess();\n\n child.spawn(options);\n}<\/code><\/pre>\n<\/li>\n- \n
\u521b\u5efa ChildProcess \u5b9e\u4f8b\uff0c\u521b\u5efa\u5b50\u8fdb\u7a0b\u4e5f\u662f\u8c03\u7528 C++ \u5c42 this._handle.spawn \u65b9\u6cd5<\/p>\n
function ChildProcess() {\n \/\/ C++\u5c42\u5b9a\u4e49\n this._handle = new Process();\n}<\/code><\/pre>\n<\/li>\n- \n
\u901a\u8fc7 child.spawn \u8c03\u7528\u5230 ChildProcess.prototype.spawn \u65b9\u6cd5\u4e2d\u3002\u5176\u4e2d getValidStdio \u65b9\u6cd5\u4f1a\u6839\u636e options.stdio \u521b\u5efa\u548c C++ \u4ea4\u4e92\u7684 Pipe \u5bf9\u8c61\uff0c\u5e76\u83b7\u5f97\u5bf9\u5e94\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26\uff0c\u5c06\u6587\u4ef6\u63cf\u8ff0\u7b26\u5199\u5165\u5230\u73af\u5883\u53d8\u91cf NODE_CHANNEL_FD \u4e2d\uff0c\u8c03\u7528 C++ \u5c42\u521b\u5efa\u5b50\u8fdb\u7a0b\uff0c\u5728\u8c03\u7528 setupChannel \u65b9\u6cd5<\/p>\n
ChildProcess.prototype.spawn = function(options) {\n \/\/ \u9884\u5904\u7406\u8fdb\u7a0b\u95f4\u901a\u4fe1\u7684\u6570\u636e\u7ed3\u6784\n stdio = getValidStdio(stdio, false);\n const ipc = stdio.ipc;\n const ipcFd = stdio.ipcFd;\n \/\/\u5c06\u6587\u4ef6\u63cf\u8ff0\u7b26\u5199\u5165\u73af\u5883\u53d8\u91cf\u4e2d\n if (ipc !== undefined) {\n ArrayPrototypePush(options.envPairs, `NODE_CHANNEL_FD=${ipcFd}`);\n }\n \/\/ \u521b\u5efa\u8fdb\u7a0b\n const err = this._handle.spawn(options);\n \/\/ \u6dfb\u52a0send\u65b9\u6cd5\u548c\u76d1\u542cIPC\u4e2d\u6570\u636e\n if (ipc !== undefined) setupChannel(this, ipc, serialization);\n}<\/code><\/pre>\n<\/li>\n- \n
\u5b50\u8fdb\u7a0b\u542f\u52a8\u65f6\uff0c\u4f1a\u6839\u636e\u73af\u5883\u53d8\u91cf\u4e2d\u662f\u5426\u5b58\u5728 NODE_CHANNEL_FD \u5224\u65ad\u662f\u5426\u8c03\u7528 _forkChild \u65b9\u6cd5\uff0c\u521b\u5efa\u4e00\u4e2a Pipe \u5bf9\u8c61, \u540c\u65f6\u8c03\u7528 open \u65b9\u6cd5\u6253\u5f00\u5bf9\u5e94\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26\uff0c\u5728\u8c03\u7528setupChannel<\/p>\n
function _forkChild(fd, serializationMode) {\n const p = new Pipe(PipeConstants.IPC);\n p.open(fd);\n p.unref();\n const control = setupChannel(process, p, serializationMode);\n}<\/code><\/pre>\n<\/li>\n<\/ul>\n\u53e5\u67c4\u4f20\u9012<\/h2>\n
setupChannel
\u4e3b\u8981\u662f\u5b8c\u6210\u4e86\u5904\u7406\u63a5\u6536\u7684\u6d88\u606f\u3001\u53d1\u9001\u6d88\u606f\u3001\u5904\u7406\u6587\u4ef6\u63cf\u8ff0\u7b26\u4f20\u9012\u7b49<\/p>\n
function setipChannel(){\n channel.onread = function(arrayBuffer){\n \/\/...\n }\n target.on('internalMessage', function(message, handle){\n \/\/...\n })\n target.send = function(message, handle, options, callback){\n \/\/...\n }\n target._send = function(message, handle, options, callback){\n \/\/...\n }\n function handleMessage(message, handle, internal){\n \/\/...\n }\n}<\/code><\/pre>\n