总结：(C和Java混合)UNIXDomainSocketIPC.doc

总结：（C和Java混合）UNIX Domain Socket IPCC语言和Java语言的混合其实是一样的，都是分客户端和服务端；1、C语言的客户端和Java的服务器端 Java服务端代码：import .LocalServerSocket; import .LocalSocket; import .LocalSocketAddress; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; LocalServerSocket mlss = new LocalServerSocket(/dev/socket/mysocket); while(true) LocalSocket mServerSocket = mlss.accept(); if(mServerSocket != null) InputStream is = mServerSocket.getInputStream(); outputStream out = mServerSokcet.getOutputStream(); is.read(buff); out.write(buff); out.flush(); mlss.close(); C语言客户端代码结构如下： int mSocketFd = socket(PF_UNIX, SOCK_STREAM, 0); CHCEK(mSocketFd); struct sockaddr_un mRemoteSocket; mRemoteSocket.sun_family = AF_UNIX; /指定协议 strcpy(mRemoteSocket.sun_path, SOCK_PATH); /指定文件 int len = offsetof(struct sockaddr_un*),sun_path) + strlen(mRemoteSocket.sun_path); int io_fd = connect(mSocketFd, (struct sockaddr *)mRemoteSocket, len); CHECK(io_fd); send(io_fd, buff, sizeof(buff), 0); recev(io_fd, buff, len, 0); close(io_fd);2、C语言版服务器和Java语言客户端 int mSocketFd = socket(PF_UNIX, SOCK_STREAM, 0); CHCEK(mSocketFd);struct sockaddr_un mServerAddr; mServerAddr.sun_family = AF_UNIX; /指定协议 strcpy( mServerAddr.sun_path, SOCK_PATH); /指定文件 int len = offsetof(struct sockaddr_un*),sun_path) + strlen( mServerAddr.sun_path); int res = bind(mSocketFd , (struct sockaddr *)&mServerAddr, len); listen(mSocketFd, 16);int mIOfd ; struct sockaddr_un mClientAddr; intmClientAddrSockLen = sizeof(mClientAddr);if (mIOfd= accept(fd, (struct sockaddr *) &mClientAddr, &mClientAddrSockLen) 0) /在这个地方等待客户端的sendlog(Failed to accept socket. return:%d err:%sn, s, strerror(errno);free(qlog_nodes);exit(ERR_UNSPEC);/mIOfd是一个fd，可以直接用来读写的 /从socket中得到消息 ret = TEMP_FAILURE_RETRY(recv(mIOfd, &message, sizeof(message), 0);/读取消息，关于TEMP_FAILURE_RETRY，有专门的介绍 if (ret 0) close(s);SLOGE(Failed to recv message from socket. return: %d err: %sn, ret, strerror(errno);return; /向socket中写入数据ret = TEMP_FAILURE_RETRY(send(mIOfd, buffer, sizeof(buffer), 0); /写入消息if (ret 0) log(Failed to send message from socket. return: %d err: %sn, ret, strerror(errno);return; log(Send %d bytes out, ret); /最后要关闭socket close(mIOfd); unlink(bind的文件); Java客户端代码结构 /打开一个Socket mSocket = new LocalSocket(); /与服务器建立连接 mSocket.connect(new LocalSocketAddress(DEBUG_CONTROL_SOCKET_PATH,LocalSocketAddress.Namespace.FILESYSTEM); /读 try OutputStreamm_Send = mSocket.getOutputStream(); /得到当前byte buf = new byte2;buf0 = FATAL_ERR_FEATURE;buf1 = 1; / uselessmSocket.setSendBufferSize(buf.length); m_Send.write(buf);/写入m_Send.flush(); catch (Exception e) Log.e(LOG_TAG, write socket error); ret = false; /写