在执行信使计划时失败了

Question

我已经做了一段时间了，我遇到了一些困难。我试过在谷歌上搜索很多，但主题上的所有内容要么是基于服务器的，要么是关于使用API的。我想坚持java包的基本用途。

我的目标是让两个客户端能够来回发送消息，只需在Eclipse内部的控制台中即可。我知道我必须在服务器中实现线程来处理这两个连接，并且可能还必须为服务器编写一个协议。

有人能给我一些建议吗？非常感谢的帮助

以下是我目前拥有的

客户端

import java.io.*;
import java.net.*;
public class Client 
{
static Socket client;
static String input;
static DataInputStream in;
static DataOutputStream out;
static BufferedReader keyboard;

//constructor, instantiation.
static void Open()
{
    try 
    {
        client = new Socket("127.0.0.1", 6666);
        InputStream sin = client.getInputStream();
        OutputStream sout = client.getOutputStream();
        in = new DataInputStream(sin);
        out = new DataOutputStream(sout);
    } 
    catch (UnknownHostException e) {
        System.err.println("Don't know about host: taranis.");
        System.exit(1);
    } 
    catch (IOException e) {
        System.err.println("Couldn't get I/O for " + "the connection to: Host.");
        System.exit(1);
    }
    keyboard = new BufferedReader(new InputStreamReader(System.in));
}
//close
static void Close() throws IOException
{
    client.close();
    keyboard.close();
    in.close();
    out.close();
}

public static void main(String[] args) throws IOException 
{
    Open();
    while(true) 
    {
        // wait for the user to type in something and press enter.
        input = keyboard.readLine(); 

        // send the above line to the server.
        out.writeUTF(input); 
        out.flush(); 
        // wait for the server to send a line of text.
        input = in.readUTF(); 
        System.out.println("The server was very polite. It sent me this : " + input);
        System.out.println();
    }

 }
 }

主机

import java.net.*;
import java.io.*;
public class Host 
{
//static variables
static ServerSocket host;
static Socket client;
static HostProtocol hp;
static String input1, output2;
static InputStream sin;
static OutputStream sout;
static DataInputStream in;
static DataOutputStream out;
//constructor
public Host() throws IOException
{
    hp = new HostProtocol();
    Open();
     sin = client.getInputStream();
     sout = client.getOutputStream();
     in = new DataInputStream(sin);
     out = new DataOutputStream(sout);
}
//open sockets, instantiate variables
public static void Open()
{
    try 
    {
        host = new ServerSocket(6666);
    } 
    catch (IOException e) 
    {
        System.err.println("Could not listen on port: 6666.");
        System.exit(1);
    }
    try 
    {
      client = host.accept();
    } 
    catch (IOException e) 
    {
        System.err.println("Accept failed.");
        System.exit(1);
    }
}
//close method
public static void Close () throws IOException
{
    out.close();
    client.close();
    host.close();
}

//main method
public static void main(String[] args) throws IOException 
{
    Host serverhost = new Host();
    input1=in.readUTF();
}
} 

Answer 1

您的客户端还需要至少一个额外的线程，以便随时接收和发送聊天消息。

在服务器端，您需要将对accept的调用放入一个循环中，以便接受多个连接。然后，对于每个新连接的客户端，您可以生成一个新线程，并将从accept:获得的套接字对象传递给它

private class ClientThread implements Runnable {
    private Socket socket;
    public ClientThread(Socket socket) {
       this.socket = socket;
    }
    public void run() {
        // read messages from socket and send them to the other client.
    }
}
...
while(true) {
    try {
        client = host.accept();
        Thread t = new Thread(new ClientThread(client));
        t.start();
    } catch (IOException e) {
        System.err.println("Accept failed.");
        System.exit(1);
    }
}