标签:常用方法 传输 网络 绑定 scan input 建立 soc bubuko
1 TCP协议
TCP协议是面向连接的通信协议,即在传输数据前先在发送端和接收端建立逻辑连接,然后再传输数据,它提供了两台计算机之间可靠无差错的数据传输。
在TCP连接中必须要明确客户端与服务器端,由客户端向服务端发出连接请求,每次连接的创建都需要经过“三次握手”。
第一次握手,客户端向服务器端发出连接请求,等待服务器确认
第二次握手,服务器端向客户端回送一个响应,通知客户端收到了连接请求
第三次握手,客户端再次向服务器端发送确认信息,确认连接
下载文件时必须采用TCP协议。
2 TCP通信
TCP通信同UDP通信一样,都能实现两台计算机之间的通信,通信的两端都需要创建socket对象。
在JDK中提供了两个类用于实现TCP程序,一个是ServerSocket类,用于表示服务器端,一个是Socket类,用于表示客户端。
2.1 ServerSocket
ServerSocket的构造方法:
ServerSocket的常用方法:
ServerSocket对象负责监听某台计算机的某个端口号,在创建ServerSocket对象后,需要继续调用该对象的accept()方法,接收来自客户端的请求。当执行了accept()方法之后,服务器端程序会发生阻塞,直到客户端发出连接请求,accept()方法才会返回一个Scoket对象用于和客户端实现通信,程序才能继续向下执行。
2.2 Socket
在Socket类的常用方法中,getInputStream()和getOutStream()方法分别用于获取输入流和输出流。当客户端和服务端建立连接后,数据是以IO流的形式进行交互的,从而实现通信。
2.3 简单的TCP网络程序
要实现TCP通信需要创建一个服务器端程序和一个客户端程序,为了保证数据传输的安全性,首先需要实现服务器端程序。
服务器端:
//TCP服务器端 public class TCPServer { public static void main(String[] args) throws IOException { //1.创建服务器套接字对象 ServerSocket server=new ServerSocket(8888); //2.调用accept方法,创建连接,获取客户端的套接字对象Socket Socket socket=server.accept(); //3.从客户端套接字对象中获取字节输入流 InputStream in=socket.getInputStream(); byte[] bytes=new byte[1024]; int len=in.read(bytes); System.out.println(new String(bytes,0,len)); String ip=socket.getInetAddress().getHostAddress(); System.out.println("来自此ip地址:"+ip); //发送给客户端一个响应(回复) //获取字节输出流 OutputStream out=socket.getOutputStream(); Scanner sc=new Scanner(System.in); String str=sc.next(); out.write(str.getBytes()); //4.释放资源 server.close(); } }
客户端:
//TCP客户端 public class TCPClient { public static void main(String[] args) throws UnknownHostException, IOException { //1.创建Socket对象,连接服务器 Socket socket=new Socket("192.168.1.147",8888); //2.通过客户端Socket对象中的方法,获取字节输出流,将数据写向服务器 OutputStream out=socket.getOutputStream(); //3.写数据 Scanner sc=new Scanner(System.in); String str=sc.next(); out.write(str.getBytes()); //接收服务器端的响应 //获取字节输入流 InputStream in=socket.getInputStream(); byte[] bytes=new byte[1024]; int len=in.read(bytes); System.out.println(new String(bytes,0,len)); //4.释放资源 socket.close(); } }
2.4 文件的上传案例
服务器端:
//服务器端 public class TCPServer { public static void main(String[] args) throws IOException { //1.创建服务器套接字,绑定端口号 ServerSocket server=new ServerSocket(8888); //2.调用accept方法,与客户端创建连接,获取客户端套接字对象 Socket socket=server.accept(); //3.获取字节输入流,明确数据源 InputStream in=socket.getInputStream(); //4.明确目的地 File file=new File("D:\\upload"); //判定该文件夹是否存在,不存在则创建 if(!file.exists()){ file.mkdirs(); } //域名+毫秒值+六位随机数 String filename="oracle"+System.currentTimeMillis()+new Random().nextInt(999999)+".png"; FileOutputStream fos=new FileOutputStream(file+File.separator+filename); //开始复制 byte[] bytes=new byte[1024]; int len=0; while((len=in.read(bytes))!=-1){ fos.write(bytes,0,len); } //给客户端响应(回复) //获取字节输出流 OutputStream out=socket.getOutputStream(); out.write("上传成功".getBytes()); //释放资源 server.close(); fos.close(); } }
客户端:
//客户端 public class TCPClient { public static void main(String[] args) throws UnknownHostException, IOException { //1.创建客户端套接字Socket对象,连接服务器 Socket socket=new Socket("192.168.1.147",8888); //2.通过Socket获取字节输出流 OutputStream out=socket.getOutputStream(); //明确数据源 FileInputStream fis=new FileInputStream("E:\\java\\pp.png"); //开始复制 int len=0; byte[] bytes=new byte[1024]; while((len=fis.read(bytes))!=-1){ out.write(bytes,0,len); } //告诉服务器端当前字节已经读完,不用等了 socket.shutdownOutput(); //接收服务器端的回复 //获取字节输入流 InputStream in=socket.getInputStream(); len=in.read(bytes); System.out.println(new String(bytes,0,len)); //释放资源 socket.close(); fis.close(); } }
标签:常用方法 传输 网络 绑定 scan input 建立 soc bubuko
原文地址:https://www.cnblogs.com/zzq123/p/10249864.html