TCP传输
1、TCP分客户端和服务端。
2、客户端对应的对象是Socket;服务端对应的对象是ServerSocket;
3、建立客户端和服务器端
4、建立连接后,通过Socket中的IO流进行数据的传输
5、关闭socket
同样,客户端与服务器端是两个独立的应用程序。
客户端:
通过查阅socket对象,发现在该对象建立时,就可以连接指定主机。因为tcp是面向连接的,所以在建立socket服务时,就要有服务端存在,并连接成功。形成通路后,在该通道进行数据的传输。
需求:给服务器端发送一个文本数据
步骤:
1、创建Socket服务,并指定要连接的主机和端口;
2、为了发送数据,应该获取socket流中的输出流;
类Socket:此类实现客户端套接字(也可以就叫“套接字”)。套接字是两台机器间通信的端点。
import java.io.IOException; import java.io.OutputStream; import java.net.Socket; import java.net.UnknownHostException; public class TCPClient { public static void main(String[] args) throws UnknownHostException, IOException { //1、创建客户端的socket的服务,指定目的主机和端口; Socket s=new Socket("10.1.9.34",20000); //2、为了发送数据,应该获取socket流中的输出流; OutputStream out=s.getOutputStream(); out.write("tcp datas come".getBytes());//把输出流写出去,并发送到对应的主机的。 s.close(); } }
服务端:
需求:定义端点接收数据并打印在控制台上。
步骤:
1、建立服务端的socket服务,通过ServerSocket()创建,并监听一个端口;
2、获取连接过来的客户端对象,通过ServerSocket的accept方法,没有连接就会等,所以这个方法是阻塞式的。
3、客户端如果发过来数据,那么服务端要使用对应的客户端对象,并获取到该客户端对象的读取流来读取发过来的数据。并打印在控制台。
4、关闭服务端。(可选)
import java.io.IOException; import java.io.InputStream; import java.net.ServerSocket; import java.net.Socket; public class TCPServer { public static void main(String[] args) throws IOException { //1、建立服务端socket服务,并监听一个端口。 ServerSocket serverSocket=new ServerSocket(20000); //2、通过accept方法获取连接过来的客户端对象 Socket socket=serverSocket.accept(); String ip=socket.getInetAddress().getHostAddress(); System.out.println(ip+"......connected"); //3、获取客户端发送过来的数据,那么要使用客户端对象的读取流来读取数据 InputStream in=socket.getInputStream(); byte[] buf=new byte[1024]; int len=in.read(buf); System.out.println(new String(buf,0,len)); //4、关闭客户端 socket.close(); serverSocket.close(); } }先运行服务端,在运行客户端,运行结果如下:
TCP的传输端和服务端的互访
需求:客户端给服务端发送数据,服务端收到后,给客户端反馈信息;
客户端:
1、建立socket服务,指定要连接的主机和端口。
2、获取socket流中的输出流,将数据写的该流中,通过网络发送给服务端。
3、获取socket流中的输入流,将服务器端反馈的数据获取到,并打印。
4、关闭客户端资源。
import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.Socket; import java.net.UnknownHostException; public class TCPClient2 { public static void main(String[] args) throws UnknownHostException, IOException { Socket socket=new Socket("10.1.9.34",20000); OutputStream out=socket.getOutputStream(); out.write("服务端,你好!".getBytes()); InputStream in=socket.getInputStream(); byte[] buff=new byte[1024]; int len=in.read(buff); System.out.println(new String(buff,0,len)); socket.close(); } }
服务端:
1、建立服务端的socket服务,通过ServerSocket()创建,并监听一个端口;
2、获取连接过来的客户端对象,通过ServerSocket的accept方法,没有连接就会等,所以这个方法是阻塞式的。
3、客户端如果发过来数据,那么服务端要使用对应的客户端对象,并获取到该客户端对象的读取流来读取发过来的数据。并打印在控制台。
4、 获取socket流中的输出流,将数据写的该流中,通过网络发送给客户端。
4、关闭服务端。(可选)
import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.ServerSocket; import java.net.Socket; public class TCPServer2 { public static void main(String[] args) throws IOException { ServerSocket serverSocket=new ServerSocket(20000); Socket socket=serverSocket.accept(); String ip=socket.getInetAddress().getHostAddress(); System.out.println(ip+"......connected!"); InputStream in=socket.getInputStream(); byte[] buff=new byte[1024]; int len=in.read(buff); System.out.println(new String(buff,0,len)); OutputStream out=socket.getOutputStream(); out.write("服务端收到".getBytes()); socket.close(); serverSocket.close(); } }