1.TCP通信原理
2.客户端代码
import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.Socket; /* TCP协议客户端 java.net.Socket类: 表示 TCP协议客户端 常用方法: public OutputStream getOutputStream(): 获取客户端Socket对象的字节输出流对象,向服务器发送请求信息的 public InputStream getInputStream(): 获取客户端Socket对象的字节输入流对象,读取服务器端发送回来的响应信息的 构造方法: public Socket(String host, int port) 参数: String host: 要连接的服务器的ip地址 int port: 要连接的服务器的端口号 只要使用new创建Socket对象,就会进行3次握手,建立到服务器的连接 使用步骤: 1.创建客户端Socket对象,指定要连接的服务器的ip地址和端口号 2.客户端Socket对象调用getOutputStream方法,获取客户端的字节输出流对象 3.客户端的字节输出流对象调用write方法,给服务器发送请求信息 4.客户端Socket对象调用getInputStream方法,获取客户端的字节输入流对象 5.客户端的字节输入流对象调用read方法,读取服务器端发送回来的响应信息 6.关闭流,释放资源 */ public class Demo01Client { public static void main(String[] args) throws IOException { //1.创建客户端Socket对象,指定要连接的服务器的ip地址和端口号 Socket client = new Socket("127.0.0.1", 6666); //2.客户端Socket对象调用getOutputStream方法,获取客户端的字节输出流对象 OutputStream netOs = client.getOutputStream(); //3.客户端的字节输出流对象调用write方法,给服务器发送请求信息 netOs.write("你好,服务器".getBytes()); //4.客户端Socket对象调用getInputStream方法,获取客户端的字节输入流对象 InputStream netIs = client.getInputStream(); //5.客户端的字节输入流对象调用read方法,读取服务器端发送回来的响应信息 int len = 0; byte[] bs = new byte[1024]; len = netIs.read(bs); System.out.println("客户端收到服务器端的响应信息: "+new String(bs,0,len)); //6.关闭流,释放资源 netIs.close(); netOs.close(); client.close(); } }
服务器端代码
import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.ServerSocket; import java.net.Socket; /* TCP协议服务端 java.net.ServerSocket类: 代表TCP协议服务器端 常用方法: public Socket accept(): 服务器端获取到连接服务器的客户端Socket对象 返回值类型: java.net.Socket类 代表客户端 public OutputStream getOutputStream(): 获取服务器端的字节输出流对象,给客户端发送响应信息的 public InputStream getInputStream(): 获取服务器端的字节输入流对象,读取服读取客户端发送过来的请求数据的 构造方法: ServerSocket(int port) 参数: int port: 代表端口号,要和客户端请求的端口号保持一致 注意: 服务器端不需要指定ip地址,使用本机ip 使用步骤: 1.创建服务器端的ServerSocket对象,指定端口号 2.服务器端的ServerSocket对象调用accept方法,获取连接到服务器的客户端Socket对象 3.服务器的客户端Socket对象调用getInputStream方法,获取服务器端的字节输入流对象 4.服务器端的字节输入流对象调用read方法,读取客户端发送的请求信息 5.服务器的客户端Socket对象调用getOutputStream方法,获取服务器端的字节输出流对象 6.服务器端的字节输出流对象调用write方法,给客户端发送响应信息 7.关闭流释放资源 */ public class Demo02Server { public static void main(String[] args) throws IOException { //1.创建服务器端的ServerSocket对象,指定端口号 ServerSocket server = new ServerSocket(6666); //2.服务器端的ServerSocket对象调用accept方法,获取连接到服务器的客户端Socket对象 Socket client = server.accept(); //3.服务器的客户端Socket对象调用getInputStream方法,获取服务器端的字节输入流对象 InputStream netIs = client.getInputStream(); //4.服务器端的字节输入流对象调用read方法,读取客户端发送的请求信息 int len = 0; byte[] bs = new byte[1024]; len = netIs.read(bs); System.out.println("服务器端收到客户端的请求信息: "+new String(bs,0,len)); //5.服务器的客户端Socket对象调用getOutputStream方法,获取服务器端的字节输出流对象 OutputStream netOs = client.getOutputStream(); //6.服务器端的字节输出流对象调用write方法,给客户端发送响应信息 netOs.write("我很好,老弟~~~".getBytes()); //7.关闭流释放资源 netIs.close(); netOs.close(); client.close(); server.close(); } }