public static void main(String[] args) {
(, args);
try {
ServerSocket serverSocket = new ServerSocket(9300);
("启动服务器....");
Socket socket = ();
("客户端："+().getHostAddress()+"已连接到服务器");
BufferedReader br = new BufferedReader((new InputStreamReader(())));
CountDownLatch countDownLatch = new CountDownLatch(1);
(()->{
try{
String msg;
while (true){
msg= ();
if((msg)){
("客户端:"+msg);
}
}
}catch (Exception e){
();
}
});
(()->{
try{
while (true){
Scanner scanner = new Scanner();
String msg =();
if((msg)){
if(msg=="exit"){
();
}else{
BufferedWriter bw = new BufferedWriter(new
OutputStreamWriter(()));
(msg+"\n");
();
}
}
}
}catch (Exception e){
}
});
();
} catch (Exception e) {
();
}
}