我需要构建一个应用程序,其中有四台服务器在运行,一台客户机向这些服务器发送一些软件包,但这些服务器必须始终保持运行,以便从客户端(发件人)接收一些内容。 所以我创建了两个类,客户端和服务器:如何使用套接字创建服务器和客户端?
public class Server {
public Event receive(int port) {
Evento event = null;
try {
ServerSocket ss = new ServerSocket(port);
Socket s = ss.accept();
InputStream is = s.getInputStream();
ObjectInputStream ois = new ObjectInputStream(is);
evento = (Evento) ois.readObject();
is.close();
s.close();
ss.close();
}catch(Exception e){
System.out.println(e);
}
return event;
}
}
public class Client {
public void send(Event event, int port) {
try {
Socket s = new Socket("localhost", 2002);
OutputStream os = s.getOutputStream();
ObjectOutputStream oos = new ObjectOutputStream(os);
oos.writeObject(event);
oos.close();
os.close();
s.close();
} catch (Exception e) {
System.out.println(e);
}
}
}
但正如我所说,我需要这些服务器保持运行的时间,如果我考过一次,这是确定的,但两次或两次以上,不。 我怎么能这样做?
你的意思了一会儿一个线程? –
用于读取阻塞连接的线程。它可以包含while循环。 –