Java 类

  1. 客户端: java.net.Socket类表示，创建Socket对象，向服务端发送请求连接，服务端响应请求，两者建立
  2. 连接成功，就可以使用IO流进行通信。
  3. 构造方法:
  4. 1.Socket(String host, int port)    //指定IP和端口号
  5. 成员方法:
  6. 1.getInputStream()    //获取网络字节输入流
  7. 2.getOutputStream()    //获取网络字节输出流
  8. 3.close()                //关闭套接字
  10. 服务端: java.net.ServerSocket类表示，创建ServerSocket对象，开启服务等待客户端连接。使用accept
  11. 获取到请求的客户端Socket对象，服务器使用客户端的字节输入流读取客户端发送的数据再用客户端的字节
  12. 输出流给客户端回写数据。
  13. 构造方法:
  14. 1.ServerSocket(int port)  //指定端口号
  15. 成员方法:
  16. 1.Socket accept()          //侦听套接字的连接，获取客户端的套接字对象

客户端

  1. public static void main(String[] args) throws IOException {
  2.     //创建客户端套接字对象，指定主机和端口号
  3.     Socket cs = new Socket("127.0.0.1",8192);
  4.     //创建字节输入流，向服务端写数据
  5.     OutputStream os = cs.getOutputStream();
  6.     os.write("hello server".getBytes());
  7.     //获取到服务端推送的数据并进行读取
  8.     InputStream is = cs.getInputStream();
  9.     byte[] bs = new byte[1024];
  10.     int len = is.read(bs);
  11.     System.out.println(new String(bs,0,len));
  12.     cs.close();//关闭客户端套接字
  13. }

服务端

  1. public static void main(String[] args) throws IOException {
  2.     //创建服务端套接字
  3.     ServerSocket ss = new ServerSocket(8192);
  4.     //监听请求的客户端套接字对象
  5.     Socket cs = ss.accept();
  6.     //获取客户端输入流，进行读取
  7.     InputStream is = cs.getInputStream();
  8.     byte[] bs = new byte[1024];
  9.     int len = is.read(bs);
  10.     System.out.println(new String(bs,0,len));
  11.     //通过客户端输出流向客户端推送消息
  12.     OutputStream os = cs.getOutputStream();
  13.     os.write("Hi Client".getBytes());
  14.     cs.close();//关闭与客户端的连接
  15.     ss.close();//关闭服务端套接字
  16. }

阻塞问题

  1. read()方法从输入流中读取一个字节，如果没有输入可用，此方法将一直阻塞。
  2. //对于TCP套接字，任何以前写入的数据都将被发送，并且后跟TCP的正常连接终止序列
  3. fc.shutdownOutput();  //禁用此套接字的输出流。

文件上传案例

客户端

  1. public static void main(String[] args) throws IOException {
  2.     //创建客户端套接字对象，指定IP地址和端口
  3.     Socket fc = new Socket("127.0.0.1",8192);
  4.     OutputStream os = fc.getOutputStream();//获取网络输出流
  5.     //利用本地输入流读取本地文件，再使用网络输出流传输文件
  6.     String filePath = "D:\\Project\\Net\\Basic\\tcp\\img\\source.png";
  7.     FileInputStream localIS = new FileInputStream(filePath);
  8.     int len;
  9.     byte[] bs = new byte[1024];
  10.     while ((len = localIS.read(bs)) != -1) {
  11.         os.write(bs,0,len);
  12.     }
  13.     //对于TCP套接字，任何以前写入的数据都将被发送，并且后跟TCP的正常连接终止序列
  14.     fc.shutdownOutput();//禁用此套接字的输出流
  15.     //读取服务段返回的响应数据
  16.     InputStream is = fc.getInputStream();
  17.     while ((len = is.read(bs)) != -1) {
  18.         System.out.println(new String(bs,0,len));
  19.     }
  20.     localIS.close();//关闭本地输入流
  21.     fc.close();//关闭客户端套接字
  22. }

服务端

  1. public static void main(String[] args) throws IOException {
  2.     //创建服务端套接字，设置端口号
  3.     ServerSocket fs = new ServerSocket(8192);
  4.     //监听客户端请求，获取客户端套接字对象
  5.     Socket fc = fs.accept();
  6.     //创建本地字节输出流
  7.     String filePath = "D:\\Project\\Net\\Basic\\tcp\\img\\copy.png";
  8.     FileOutputStream localOS = new FileOutputStream(new File(filePath));
  9.     //通过客户端套接字读取网络字节输入流并利用本地字节输出流写入本地
  10.     InputStream is = fc.getInputStream();
  11.     int len;
  12.     byte[] bs = new byte[1024];
  13.     while ((len = is.read(bs)) != -1) {
  14.         localOS.write(bs,0,len);
  15.     }
  16.     //通过客户端套接字利用网络字节输出流给客户端回传数据
  17.     OutputStream os = fc.getOutputStream();
  18.     os.write("上传成功".getBytes());
  19.     localOS.close();//关闭本地字节输入流
  20.     fc.close();//断开客户端连接
  21.     fs.close();//关闭服务端套接字
  22. }