美文网首页
[java]17、网络编程

[java]17、网络编程

作者: 史记_d5da | 来源:发表于2021-10-20 16:19 被阅读0次

    1、软件结构

    1、C/S结构 :全称为Client/Server结构,是指客户端和服务器结构。常见程序有QQ、迅雷等软件。
    2、B/S结构 :全称为Browser/Server结构,是指浏览器和服务器结构。常见浏览器有谷歌、火狐等。

    2、Socket请求

    1、Client

    public class TCPClient {
        public static void main(String[] args)  throws IOException {
            Socket socket = new Socket("127.0.0.1", 8888);
            OutputStream os = socket.getOutputStream();
            os.write("你好服务器".getBytes());
            System.out.println("向服务器发送请求");
            // 接收服务器发送的请求
            InputStream is = socket.getInputStream();
            byte[] bytes = new byte[1024];
            int len = is.read(bytes);
            System.out.println(new String(bytes, 0, len));
            socket.close();
        }
    }
    

    2、Server

    public class TCPServer {
        public static void main(String[] args) throws IOException {
            ServerSocket server = new ServerSocket(8888);
            System.out.println("开始监听客户端socket");
            Socket socket = server.accept(); // 获取到请求对象的socket
            System.out.println("监听到客户端socket");
            // 输出客户端的请求信息
            InputStream is = socket.getInputStream();
            byte[] bytes = new byte[1024];
            int len = is.read(bytes);
            System.out.println(new String(bytes, 0, len));
            // 回复客户端的请求信息
            OutputStream os = socket.getOutputStream();
            os.write("收到谢谢".getBytes());
            socket.close();
        }
    }
    

    3、文件上传

    1、server

    public class TCPServer {
        public static void main(String[] args) throws IOException {
            //1.创建一个服务器ServerSocket对象,和系统要指定的端口号
            ServerSocket server = new ServerSocket(8888);
            //2.使用ServerSocket对象中的方法accept,获取到请求的客户端Socket对象
    
            /*
                让服务器一直处于监听状态(死循环accept方法)
                有一个客户端上传文件,就保存一个文件
             */
            while(true){
                Socket socket = server.accept();
    
                /*
                    使用多线程技术,提高程序的效率
                    有一个客户端上传文件,就开启一个线程,完成文件的上传
                 */
                new Thread(new Runnable() {
                    //完成文件的上传
                    @Override
                    public void run() {
                       try {
                           //3.使用Socket对象中的方法getInputStream,获取到网络字节输入流InputStream对象
                           InputStream is = socket.getInputStream();
                           //4.判断d:\\upload文件夹是否存在,不存在则创建
                           File file =  new File("d:\\upload");
                           if(!file.exists()){
                               file.mkdirs();
                           }
    
                        /*
                            自定义一个文件的命名规则:防止同名的文件被覆盖
                            规则:域名+毫秒值+随机数
                         */
                           String fileName = "itcast"+System.currentTimeMillis()+new Random().nextInt(999999)+".jpg";
    
                           //5.创建一个本地字节输出流FileOutputStream对象,构造方法中绑定要输出的目的地
                           //FileOutputStream fos = new FileOutputStream(file+"\\1.jpg");
                           FileOutputStream fos = new FileOutputStream(file+"\\"+fileName);
                           //6.使用网络字节输入流InputStream对象中的方法read,读取客户端上传的文件
    
                           int len =0;
                           byte[] bytes = new byte[1024];
                           while((len = is.read(bytes))!=-1){
                               //7.使用本地字节输出流FileOutputStream对象中的方法write,把读取到的文件保存到服务器的硬盘上
                               fos.write(bytes,0,len);
                           }
    
                           //8.使用Socket对象中的方法getOutputStream,获取到网络字节输出流OutputStream对象
                           //9.使用网络字节输出流OutputStream对象中的方法write,给客户端回写"上传成功"
                           socket.getOutputStream().write("上传成功".getBytes());
                           //10.释放资源(FileOutputStream,Socket,ServerSocket)
                           fos.close();
                           socket.close();
                       }catch (IOException e){
                           System.out.println(e);
                       }
                    }
                }).start();
            }
    
            //服务器就不用关闭
            //server.close();
        }
    }
    

    2、client

    public class TCPClient {
        public static void main(String[] args) throws IOException {
            //1.创建一个本地字节输入流FileInputStream对象,构造方法中绑定要读取的数据源
            FileInputStream fis = new FileInputStream("c:\\1.jpg");
            //2.创建一个客户端Socket对象,构造方法中绑定服务器的IP地址和端口号
            Socket socket = new Socket("127.0.0.1",8888);
            //3.使用Socket中的方法getOutputStream,获取网络字节输出流OutputStream对象
            OutputStream os = socket.getOutputStream();
            //4.使用本地字节输入流FileInputStream对象中的方法read,读取本地文件
            int len = 0;
            byte[] bytes = new byte[1024];
            while((len = fis.read(bytes))!=-1){
                //5.使用网络字节输出流OutputStream对象中的方法write,把读取到的文件上传到服务器
                os.write(bytes,0,len);
            }
    
            /*
                解决:上传完文件,给服务器写一个结束标记
                void shutdownOutput() 禁用此套接字的输出流。
                对于 TCP 套接字,任何以前写入的数据都将被发送,并且后跟 TCP 的正常连接终止序列。
             */
            socket.shutdownOutput();
    
            //6.使用Socket中的方法getInputStream,获取网络字节输入流InputStream对象
            InputStream is = socket.getInputStream();
    
            //7.使用网络字节输入流InputStream对象中的方法read读取服务回写的数据
            while((len = is.read(bytes))!=-1){
                System.out.println(new String(bytes,0,len));
            }
            //8.释放资源(FileInputStream,Socket)
            fis.close();
            socket.close();
        }
    }
    

    4、BS请求

    1、客户端

    /*
        创建BS版本TCP服务器
     */
    public class TCPServer {
        public static void main(String[] args) throws IOException {
            //创建一个服务器ServerSocket,和系统要指定的端口号
            ServerSocket server = new ServerSocket(8080);
            //使用accept方法获取到请求的客户端对象(浏览器)
            Socket socket = server.accept();
            //使用Socket对象中的方法getInputStream,获取到网络字节输入流InputStream对象
            InputStream is = socket.getInputStream();
            //使用网络字节输入流InputStream对象中的方法read读取客户端的请求信息
            /*byte[] bytes = new byte[1024];
            int len = 0;
            while((len = is.read(bytes))!=-1){
                System.out.println(new String(bytes,0,len));
            }*/
    
            //把is网络字节输入流对象,转换为字符缓冲输入流
            BufferedReader br = new BufferedReader(new InputStreamReader(is));
            //把客户端请求信息的第一行读取出来 GET /11_Net/web/index.html HTTP/1.1
            String line = br.readLine();
            //把读取的信息进行切割,只要中间部分 /11_Net/web/index.html
            String[] arr = line.split(" ");
            //把路径前边的/去掉,进行截取 11_Net/web/index.html
            String htmlpath = arr[1].substring(1);
    
            //创建一个本地字节输入流,构造方法中绑定要读取的html路径
            FileInputStream fis = new FileInputStream(htmlpath);
            //使用Socket中的方法getOutputStream获取网络字节输出流OutputStream对象
            OutputStream os = socket.getOutputStream();
    
            // 写入HTTP协议响应头,固定写法
            os.write("HTTP/1.1 200 OK\r\n".getBytes());
            os.write("Content-Type:text/html\r\n".getBytes());
            // 必须要写入空行,否则浏览器不解析
            os.write("\r\n".getBytes());
    
            //一读一写复制文件,把服务读取的html文件回写到客户端
            int len = 0;
            byte[] bytes = new byte[1024];
            while((len = fis.read(bytes))!=-1){
                os.write(bytes,0,len);
            }
    
            //释放资源
            fis.close();
            socket.close();
            server.close();
        }
    }
    

    2、服务端

    /*
        创建BS版本TCP服务器
     */
    public class TCPServerThread {
        public static void main(String[] args) throws IOException {
            //创建一个服务器ServerSocket,和系统要指定的端口号
            ServerSocket server = new ServerSocket(8080);
    
            /*
                浏览器解析服务器回写的html页面,页面中如果有图片,那么浏览器就会单独的开启一个线程,读取服务器的图片
                我们就的让服务器一直处于监听状态,客户端请求一次,服务器就回写一次
             */
            while(true){
                //使用accept方法获取到请求的客户端对象(浏览器)
                Socket socket = server.accept();
    
                new Thread(new Runnable() {
                    @Override
                    public void run() {
                        try {
                            //使用Socket对象中的方法getInputStream,获取到网络字节输入流InputStream对象
                            InputStream is = socket.getInputStream();
                            //使用网络字节输入流InputStream对象中的方法read读取客户端的请求信息
                            /*byte[] bytes = new byte[1024];
                            int len = 0;
                            while((len = is.read(bytes))!=-1){
                                System.out.println(new String(bytes,0,len));
                            }*/
    
                            //把is网络字节输入流对象,转换为字符缓冲输入流
                            BufferedReader br = new BufferedReader(new InputStreamReader(is));
                            //把客户端请求信息的第一行读取出来 GET /11_Net/web/index.html HTTP/1.1
                            String line = br.readLine();
                            System.out.println(line);
                            //把读取的信息进行切割,只要中间部分 /11_Net/web/index.html
                            String[] arr = line.split(" ");
                            //把路径前边的/去掉,进行截取 11_Net/web/index.html
                            String htmlpath = arr[1].substring(1);
    
                            //创建一个本地字节输入流,构造方法中绑定要读取的html路径
                            FileInputStream fis = new FileInputStream(htmlpath);
                            //使用Socket中的方法getOutputStream获取网络字节输出流OutputStream对象
                            OutputStream os = socket.getOutputStream();
    
                            // 写入HTTP协议响应头,固定写法
                            os.write("HTTP/1.1 200 OK\r\n".getBytes());
                            os.write("Content-Type:text/html\r\n".getBytes());
                            // 必须要写入空行,否则浏览器不解析
                            os.write("\r\n".getBytes());
    
                            //一读一写复制文件,把服务读取的html文件回写到客户端
                            int len = 0;
                            byte[] bytes = new byte[1024];
                            while((len = fis.read(bytes))!=-1){
                                os.write(bytes,0,len);
                            }
    
                            //释放资源
                            fis.close();
                            socket.close();
                        }catch (IOException e){
                            e.printStackTrace();
                        }
                    }
                }).start();
            }
            //server.close();
        }
    }
    

    相关文章

      网友评论

          本文标题:[java]17、网络编程

          本文链接:https://www.haomeiwen.com/subject/nbuboltx.html