[java] 유닉스/리눅스 시스템 호출을 사용하여 프로세스 간 통신하는 방법에 대해 알려주세요.

14 Dec 2023

java

파이프 (Pipe)

파이프는 한 방향으로만 데이터를 전송할 수 있는 단순한 IPC 방법입니다. 부모 프로세스는 자식 프로세스에게 데이터를 전달할 수 있으며, 이는 부모-자식 프로세스 사이의 통신에 유용합니다.

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;

public class PipeExample {
    public static void main(String[] args) throws IOException {
        ProcessBuilder builder = new ProcessBuilder("childProcess");
        Process process = builder.start();

        InputStream inputStream = process.getInputStream();
        OutputStream outputStream = process.getOutputStream();

        // Use inputStream and outputStream for communication
    }
}

메시지 큐 (Message Queue)

메시지 큐는 메시지를 비동기적으로 전달하는 방식으로, 여러 프로세스가 동일한 큐에 메시지를 보낼 수 있습니다. 이를 통해 프로세스 간 통신이 가능해집니다.

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;

public class MessageQueueExample {
    public static void main(String[] args) {
        BlockingQueue<String> queue = new ArrayBlockingQueue<>(1024);

        // Use the queue for inter-process communication
    }
}

공유 메모리 (Shared Memory)

공유 메모리는 여러 프로세스가 공유할 수 있는 메모리 공간을 생성합니다. 이를 통해 데이터를 효율적으로 전달하고, 메모리에 직접 접근할 수 있습니다.

import java.nio.MappedByteBuffer;
import java.nio.channels.FileChannel;
import java.nio.file.Paths;
import java.nio.file.StandardOpenOption;
import java.io.IOException;

public class SharedMemoryExample {
    public static void main(String[] args) throws IOException {
        FileChannel channel = FileChannel.open(Paths.get("sharedMemory"), StandardOpenOption.CREATE, StandardOpenOption.READ, StandardOpenOption.WRITE);
        MappedByteBuffer buffer = channel.map(FileChannel.MapMode.READ_WRITE, 0, 1024);

        // Use the buffer for inter-process communication
    }
}

소켓 (Socket)

소켓을 사용하여 서로 다른 시스템 간에 통신할 수 있습니다. TCP 또는 UDP를 통해 데이터를 안전하게 전송할 수 있으며, 클라이언트-서버 모델을 구현할 수 있습니다.

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class SocketExample {
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = new ServerSocket(8080);
        Socket clientSocket = serverSocket.accept();

        // Use clientSocket for communication
    }
}

위에 언급된 각각의 방법은 프로세스 간에 데이터를 안전하게 전달하고 효과적으로 통신할 수 있는 방법들입니다. 추가로 이에 대한 자세한 내용은 관련 문서 및 레퍼런스를 통해 더 알아볼 수 있습니다.