tcp/ip只是一个协议族的称号,就是说一个家族的意思。它里面有各种协议,比如 ip协议、ftp协议、udp协议。Java中为使用TCP协议提供了二个类 Socket和ServerSocket,一般的socket模式中,Serversocket只有一个,Socket而有
多个。
TCP连接建立步骤
客户端和服务端建立连接后,就被动的等待服务器的响应。典型的TCP客户端要经过以下步骤。
客户端
- 创建一个Socket实例,构造函数指定远程主机的IP地址和端口号。
- 通过Socket的I/O流来和服务器进行通信
- 使用Socket的close来关闭连接。
服务端
- 创建一个ServerSocket实例指定本地端口,监听客户端在该端口发起的TCP请求
- 重新执行accept方法来获取客户端的连接
- 为获取的客户端开启一个新线程,利用I/O流和客户端进行通信。通信完成调用客户端的close方法关闭流。
下面通过代码来体现上面说的步骤
Socket
Socket就是一个客户端,可以和ServerSocket建立起连接,建立连接后就可以和Server进行通信了。创建一个Socket要指定IP地址和端口号。每个Socket都会关联一个InputStream和OutPutSteram,我们通过 把字节写入套接字的OutOutStream来发送数据,并且通过InputSrteam来接收数据。
public static void main(String[] args) throws IOException {
//客户端请求与本机在20006端口建立TCP连接
Socket client = new Socket("127.0.0.1", 1217);
client.setSoTimeout(10000);
//获取键盘输入
BufferedReader input = new BufferedReader(new InputStreamReader(System.in));
//获取Socket的输出流,用来发送数据到服务端
PrintStream out = new PrintStream(client.getOutputStream());
//获取Socket的输入流,用来接收从服务端发送过来的数据
BufferedReader buf = new BufferedReader(new InputStreamReader(client.getInputStream()));
boolean flag = true;
while(flag){
System.out.print("输入信息:");
String str = input.readLine();
//发送数据到服务端
out.println(str);
if("bye".equals(str)){
flag = false;
}else{
try{
//从服务器端接收数据有个时间限制(系统自设,也可以自己设置),超过了这个时间,便会抛出该异常
String echo = buf.readLine();
System.out.println(echo);
}catch(SocketTimeoutException e){
System.out.println("Time out, No response");
}
}
}
input.close();
if(client != null){
//如果构造函数建立起了连接,则关闭套接字,如果没有建立起连接,自然不用关闭
client.close(); //只关闭socket,其关联的输入输出流也会被关闭
}
}
ServerSocket
服务端的工作就是建立一个通信端,被动等待客户端的连接请求。
public static void main(String[] args) throws Exception{
//开启一个服务端,端口号1217
ServerSocket server = new ServerSocket(1217);
Socket client = null;
boolean f = true;
while(f){
System.out.println("服务开启成功!");
//等待客户端的连接,会一直等待。
client = server.accept();
System.out.println("与客户端连接成功!");
//为每个客户端连接开启一个线程
new Thread(new ServerThread(client)).start();
}
server.close();
}
public static class ServerThread implements Runnable {
private Socket client = null;
public ServerThread(Socket client){
this.client = client;
}
@Override
public void run() {
try{
//获取Socket的输出流,用来向客户端发送数据
PrintStream out = new PrintStream(client.getOutputStream());
//获取Socket的输入流,通过它来获取客户端发送的信息。
BufferedReader buf = new BufferedReader(new InputStreamReader(client.getInputStream()));
boolean flag =true;
while(flag){
//接收从客户端发送过来的数据
String str = buf.readLine();
System.out.println(str);
if(str == null || "".equals(str)){
flag = false;
}else{
if("bye".equals(str)){
flag = false;
}else{
//将接收到的字符串前面加上echo,发送到对应的客户端
out.println("服务器收到了信息:" + str);
}
}
}
out.close();
client.close();
}catch(Exception e){
e.printStackTrace();
}
}
}