61 lines
1.6 KiB
Java
61 lines
1.6 KiB
Java
|
package cn.citycraft.CTZLoginServer.Socket;
|
||
|
|
|
||
|
|
import java.io.BufferedReader;
|
||
|
|
import java.io.BufferedWriter;
|
||
|
|
import java.io.InputStreamReader;
|
||
|
|
import java.io.OutputStreamWriter;
|
||
|
|
import java.io.PrintWriter;
|
||
|
|
import java.net.ServerSocket;
|
||
|
|
import java.net.Socket;
|
||
|
|
|
||
|
|
public class CTZLoginServerSocket {
|
||
|
|
|
||
|
|
public static int PORT = 8080;
|
||
|
|
public static void main(String[] agrs) {
|
||
|
|
ServerSocket s = null;
|
||
|
|
Socket socket = null;
|
||
|
|
BufferedReader br = null;
|
||
|
|
PrintWriter pw = null;
|
||
|
|
try {
|
||
|
|
//设定服务端的端口号
|
||
|
|
s = new ServerSocket(PORT);
|
||
|
|
System.out.println("ServerSocket Start:"+s);
|
||
|
|
//等待请求,此方法会一直阻塞,直到获得请求才往下走
|
||
|
|
socket = s.accept();
|
||
|
|
System.out.println("Connection accept socket:"+socket);
|
||
|
|
//用于接收客户端发来的请求
|
||
|
|
br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
|
||
|
|
//用于发送返回信息,可以不需要装饰这么多io流使用缓冲流时发送数据要注意调用.flush()方法
|
||
|
|
pw = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);
|
||
|
|
while(true){
|
||
|
|
String str = br.readLine();
|
||
|
|
if(str.equals("END")){
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
System.out.println("Client Socket Message:"+str);
|
||
|
|
Thread.sleep(1000);
|
||
|
|
pw.println("Message Received");
|
||
|
|
pw.flush();
|
||
|
|
}
|
||
|
|
|
||
|
|
} catch (Exception e) {
|
||
|
|
// TODO Auto-generated catch block
|
||
|
|
e.printStackTrace();
|
||
|
|
}finally{
|
||
|
|
System.out.println("Close.....");
|
||
|
|
try {
|
||
|
|
br.close();
|
||
|
|
pw.close();
|
||
|
|
socket.close();
|
||
|
|
s.close();
|
||
|
|
} catch (Exception e2) {
|
||
|
|
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
|