是否可以同时读取和写入java.net.Socket？

Question

是否可以同时从套接字读取和写入？我有一个连续读取套接字的线程。由于只有一个线程从套接字读取，因此读取操作是线程安全的。现在我有很多线程（比如 100 个）写入套接字。因此，很明显，我必须通过做这样的事情来使写入操作线程安全，

package com.mysocketapp.socketmanagement;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;

public class SocketManager {

    private Socket socket = null;

    private InputStream inputStream = null;

    private OutputStream outputStream = null;

    public SocketManager() {
        socket = new Socket("localhost", 5555);
        //server's running on same machine on port 5555
        inputStream = socket.getInputStream();

        outputStream = socket.getOutputStream();
    }

    public void writeMessage(byte[] message) throws IOException {

        synchronized (SocketManager.class) {

            if (message != null) {
                outputStream.write(message);
            }
        }
    }

    public byte[] readMessage() throws IOException {
        byte[] message = new byte[10]; //messages are of fixed size 10 bytes
        inputStream.read(message);
    }
}

现在我有一个线程不断调用readMessage()函数(在while循环中)。据我所知，如果套接字上没有要读取的消息，语句< code > inputstream . read(message)将等待消息。

想知道执行< code > output stream . write(message)是否安全； while < code > inputstream . read(message)；正在执行中

Answer 1

是的，套接字是双向的，可以实现全双工通信，（在不同的线程上）同时读取和写入没有问题。

拥有多个写入线程没有问题。您可以在套接字实例而不是 SocketManager 类上进行同步。