Linux下的c历程和java历程的通信-UnixSocket

1、开发c代码

引用的库

/usr/include
c代码

1. #include <stdio.h>
2. #include <stdlib.h>
3. #include <string.h>
4. #include <sys/socket.h>
5. #include <sys/un.h>
6. #include <unistd.h>
9. #define SOCKET_PATH "/tmp/my_socket"
11. int main() {
12.         int server_fd, new_socket;
13.         struct sockaddr_un address;
14.         int opt = 1;
15.         int addrlen = sizeof(address);
16.         char buffer[1024] = { 0 };
17.         const char *hello = "Hello from C server!";
19.         // 创建套接字文件描述符
20.         if ((server_fd = socket(AF_UNIX, SOCK_STREAM, 0)) == 0) {
21.                 perror("socket failed");
22.                 exit(EXIT_FAILURE);
23.         }
25.         // 设置套接字地址结构
26.         address.sun_family = AF_UNIX;
27.         strcpy(address.sun_path, SOCKET_PATH);
29.         // 绑定套接字到指定路径
30.         if (bind(server_fd, (struct sockaddr *)&address, sizeof(address)) < 0) {
31.                 perror("bind failed");
32.                 exit(EXIT_FAILURE);
33.         }
35.         // 监听连接
36.         if (listen(server_fd, 3) < 0) {
37.                 perror("listen");
38.                 exit(EXIT_FAILURE);
39.         }
41.         printf("Server listening on %s...\n", SOCKET_PATH);
43.         // 接受客户端连接
44.         if ((new_socket = accept(server_fd, (struct sockaddr *)&address, (socklen_t*)&addrlen)) < 0) {
45.                 perror("accept");
46.                 exit(EXIT_FAILURE);
47.         }
49.         // 读取客户端发送的数据
50.         int valread = read(new_socket, buffer, 1024);
51.         if (valread < 0) {
52.                 perror("read");
53.                 exit(EXIT_FAILURE);
54.         }
55.         printf("Received from client: %s\n", buffer);
57.         // 发送响应给客户端
58.         send(new_socket, hello, strlen(hello), 0);
59.         printf("Message sent to client\n");
61.         // 关闭套接字
62.         close(new_socket);
63.         close(server_fd);
64.         unlink(SOCKET_PATH);
66.         return 0;
67. }

复制代码

编译

gcc -o myserver server.c
执行

2、开发java代码

引入第三方库junixsocket ，注意这里的type是pom

GitCode - 全球开发者的开源社区,开源代码托管平台

1. https://gitcode.com/gh_mirrors/ju/junixsocket/blob/main/junixsocket-demo/src/main/java/org/newsclub/net/unix/demo/SimpleTestClient.java

复制代码

1.         <dependency>
2.             <groupId>com.kohlschutter.junixsocket</groupId>
3.             <artifactId>junixsocket-core</artifactId>
4.             <version>2.10.1</version>
5.             <type>pom</type>
6.         </dependency>

复制代码

代码

1. package com.example.service;
3. import java.io.DataInputStream;
4. import java.io.DataOutputStream;
5. import java.io.File;
6. import java.io.IOException;
7. import java.io.InputStream;
8. import java.io.OutputStream;
9. import java.net.SocketException;
10. import java.nio.charset.StandardCharsets;
12. import org.newsclub.net.unix.AFUNIXSocket;
13. import org.newsclub.net.unix.AFUNIXSocketAddress;
15. public class SimpleTestClient {
16.     public static void main(String[] args) throws IOException {
17. //        final File socketFile = new File(new File(System.getProperty("java.io.tmpdir")),
18. //                "junixsocket-test.sock");
19.         final File socketFile = new File("/tmp/my_socket");
20.         boolean connected = false;
21.         try (AFUNIXSocket sock = AFUNIXSocket.connectTo(AFUNIXSocketAddress.of(socketFile));
22.              InputStream is = sock.getInputStream(); //
23.              OutputStream os = sock.getOutputStream();
24.              DataInputStream din = new DataInputStream(is);
25.              DataOutputStream dout = new DataOutputStream(os);) {
26.             System.out.println("Connected");
27.             connected = true;
29.             byte[] buf = new byte[128];
31.             int read = is.read(buf);
32.             System.out.println("Server says: " + new String(buf, 0, read, StandardCharsets.UTF_8));
34.             System.out.println("Replying to server...");
35.             os.write("Hello Server".getBytes(StandardCharsets.UTF_8));
36.             os.flush();
38.             System.out.println("Now reading numbers from the server...");
39.             while (!Thread.interrupted()) {
40.                 int number = din.readInt();
41.                 if (number == -123) {
42.                     // by convention of this demo, if the number is -123, we stop.
43.                     // If we don't do this, we'll get an EOFException upon the next unsuccessful read.
44.                     break;
45.                 }
46.                 System.out.println(number);
48.                 int ourNumber = number * 2;
50.                 System.out.println("Sending back " + ourNumber);
51.                 dout.writeInt(ourNumber);
52.             }
53.         } catch (SocketException e) {
54.             if (!connected) {
55.                 System.out.println("Cannot connect to server. Have you started it?");
56.                 System.out.println();
57.             }
58.             throw e;
59.         }
61.         System.out.println("End of communication.");
62.     }
63. }

复制代码

打包

利用idea，创建Artifacts

Build Artifacts

执行

java -jar nearWeb.jar

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。