JAVA自学教程之TCP协议实例介绍。
TCP传输
Socket和ServerSocket
建立客户端和服务器端(两个独立的应用程序)
建立连接后,通过Socket中的IO流进行数据的传输
关闭Socket
TCP和UDP原理差不多,只是涉及的对象不一样
TCP客户端
Socket(String host, int port) 创建一个流套接字并将其连接到指定主机上的指定端口号。 |
- public static void TCPDemo() throws UnknownHostException, IOException {
- /*
- * TCP传输,客户端建立
- * 1.建立TCP客户端socket服务,使用SOCKET对象(建议一创建就明确目的地,要连接的主机)
- * 2.如果连接建立成功,就说明数据传输通道已建立
- * 该通道就是SOCKET流,是底层建立好的,因为是流,所以有输入输出,其输入输出流对象,在SOCKET获取
- * 通过getInputStream()和getOutputStream()来获取两个字节流
- * 3.使用输出流,将数据写出(网络)
- * 4.关闭
- */
- //建立客户端SOCKET服务
- Socket socket = new Socket(“127.0.0.1″,6534);//地址和端口号
- //获取SOCKET流中的输出流
- OutputStream os = socket.getOutputStream();
- //使用输出流将指定的数据写出
- os.write(“tcp客户端发送信息”.getBytes());
- socket.close();
- }
TCP服务端
- public static void TEPserveDeno() throws IOException {
- //服务端接收客户端发来的数据,并打印在控制台
- /*
- * 建立TCP服务端
- * 1.建立TCP服务端Socket服务,通过ServerSocket对象
- * 2.服务端必须对外提供端口,否则客户端无法连接
- * 3.获取连接过来的客户端对象(重点)
- * (比如拨打10086人工,一个客户,一个服务人员,客户的数据,客户自己最清楚)
- * 4.通过客户端对象获取Socket流兑取客户端发来的数据并打印
- * 5.关闭资源:关闭客户端,关闭服务端
- */
- //常见服务端对象
- ServerSocket ss = new ServerSocket(6534);
- //获取连接过来的客户端对象
- Socket so = ss.accept();//此方法用来获取客户端对象
- String ip = so.getInetAddress().getHostAddress();
- //通过Socket对象获取输入流,读取客户端发来的数据
- InputStream in = so.getInputStream();
- byte[] buf = new byte[1024];
- int len = in.read(buf);
- String str = new String(buf,0,len);
- System.out.println(“ip : ”+ip+”server : ”+str);
- so.close();//服务端一般是不关闭的
- }
注意:TCP和UDP不一样的是,必须先开启服务端,服务端不打开,客户端就无法访问,而UDP随意
服务端和客户端交互
客户端发送数据过去,服务端返回信息,表示收到
- import java.io.IOException;
- import java.io.InputStream;
- import java.io.OutputStream;
- import java.net.ServerSocket;
- import java.net.Socket;
- import java.net.UnknownHostException;
- public class Main {
- public static void main(String[] args) throws IOException{
- TCPDemo();
- TCPserveDeno();
- }
- public static void TCPserveDeno() throws IOException {
- ServerSocket ss = new ServerSocket(6534);
- Socket so = ss.accept();//阻塞式的
- String ip = so.getInetAddress().getHostAddress();
- InputStream in = so.getInputStream();
- byte[] buf = new byte[1024];
- int len = in.read(buf);
- String str = new String(buf,0,len);
- System.out.println(“ip : ”+ip+”server : ”+str);
- //使用客户端Socket对象输出流返回数据
- OutputStream out = so.getOutputStream();
- out.write(“收到信息”.getBytes());
- so.close();
- }
- public static void TCPDemo() throws UnknownHostException, IOException {
- Socket socket = new Socket(“127.0.0.1″,6534);
- OutputStream os = socket.getOutputStream();
- os.write(“tcp客户端发送信息”.getBytes());
- //读取服务端返回的数据,使用Socket读取流
- InputStream in = socket.getInputStream();
- byte[] buf = new byte[1024];
- int len = in.read(buf);
- String text = new String(buf,0,len);
- System.out.println(text);
- socket.close();
- }
- }