通过套接字在Java中从代码中的不同位置发送数据

Question

这是我第一次在任何编程语言中使用套接字（我对这个主题一点都不熟悉），我很难理解如何从不同的代码位置发送数据。

我想把数据从一个socket类发送到另一个serverplace，而不是socket类。我该怎么做？

这是我的代码：

服务器JAVA

package socket;

import database.models.PersoanaEntity;

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

public class Server {
    public static final int PORT = 27015;

    public void start() {
        new Thread(() -> {
            try {
                ServerSocket serverSocket = new ServerSocket(PORT);
                Socket clientSocket = null;
                PersoanaEntity loggedInPerson = new PersoanaEntity();
                boolean isClose = false;

                System.out.println("Server is running");
                while (!isClose) {
                    clientSocket = serverSocket.accept();
                    new Thread(new ServerThread(clientSocket)).start();
                }
                serverSocket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }).start();
    }
}

服务器线程。JAVA

package socket;

import org.json.JSONObject;

import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;

public class ServerThread extends Thread{
    private Socket socket = null;
    private ObjectInputStream in = null;
    private ObjectOutputStream out = null;

    public ServerThread(Socket socket) {
        this.socket = socket;
        try {
            //For receiving and sending data
            this.in = new ObjectInputStream(socket.getInputStream());
            this.out = new ObjectOutputStream(socket.getOutputStream());
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    public void run() {
        try {
            String recievedData = this.in.readObject().toString();
            JSONObject jsonObject = new JSONObject(recievedData);
        } catch (IOException e) {
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }

    private void sendMessage(String message) {
        try {
            this.out.writeObject(message);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

假设我想从项目中的其他类调用sendMessage。有办法吗？

谢谢

Answer 1

保留对ServerThread对象的引用，并将sendMessage的可见性更改为public。然后可以从任何地方调用它。

旁白：因为ServerThread扩展了Thread，所以您不需要将其包装成一个新的Thread，比如这个new Thread（new ServerThread（clientSocket））。