软件体系结构性能战术实验

ゞ浴缸里的玫瑰 2022-11-29 11:22 44阅读 0赞

## 软件体系结构性能战术实验 ##

**一、实验目的**

掌握软件体系结构性能战术的实际应用，重点掌握资源管理类战术中的并发战术。

**二、实验内容与要求**

内容：请采用一种程序设计语言，实现客户端和服务器端通信的功能。为了提高服务器端的性能，请采用资源管理类战术中的并发战术，以多线程的形式处理客户端的请求。  
要求：需要用“文字+代码+截图”的形式对实验的主要代码和运行结果进行展示和描述。

**三、实验方法**

1.  服务器端，创建ServerSocket对象，使用死循环调用accept()方法等待客户端请求建立连接；服务器端增加计数功能，实现累计客户端请求次数。

package com.commucntion.java;
    
    import java.io.IOException;
    import java.net.InetAddress;
    import java.net.ServerSocket;
    import java.net.Socket;
    import java.util.concurrent.atomic.AtomicInteger;
     
    /*
     * 基于TCP协议的Socket通信，实现用户登陆
     * 服务器端
     */
    public class Server {
        
        public static void main(String[] args) {
        
            try {
        
                //1.创建一个服务器端Socket，即ServerSocket，指定绑定的端口，并监听此端口
                ServerSocket serverSocket = new ServerSocket(8901);
                Socket socket = null;
     
                //记录客户端的数量
                AtomicInteger count = new AtomicInteger();
                System.out.println("***服务器即将启动，等待客户端的连接***");
     
                //循环监听等待客户端的连接
                while (true) {
        
                    //调用accept()方法开始监听，等待客户端的连接
                    socket = serverSocket.accept();
                    //创建一个新的线程
                    ServerThread serverThread = new ServerThread(socket);
                    //启动线程
                    serverThread.start();
     
                    count.incrementAndGet();//统计客户端的数量
                    System.out.println("客户端的数量：" + count.get());
                    InetAddress address = socket.getInetAddress();
                    System.out.println("当前客户端的IP：" + address.getHostAddress());
                }
            } catch (IOException e) {
        
                e.printStackTrace();
            }
        }
    }

1.  服务器端处理接受参数与对客户端作出响应；接受客户端的请求，并建立专线连接；底层是TCP的链接，即经历过三次握手；服务器端单独开启新的线程，专门实现接受客户端请求和对客户端作出响应；服务器端自动进入下一个循环，继续等待新的连接请求；

package com.commucntion.java;
    
    import java.io.*;
    import java.net.Socket;
     
    /*
     * 服务器线程处理类
     */
    public class ServerThread extends Thread {
        
        // 和本线程相关的Socket
        Socket socket = null;
     
        public ServerThread(Socket socket) {
        
            this.socket = socket;
        }
     
        //线程执行的操作，响应客户端的请求
        public void run() {
        
            InputStream is = null;
            InputStreamReader isr = null;
            BufferedReader br = null;
            OutputStream os = null;
            PrintWriter pw = null;
            try {
        
                //获取输入流，并读取客户端信息
                is = socket.getInputStream();
                isr = new InputStreamReader(is);
                br = new BufferedReader(isr);
                String info;
                while ((info = br.readLine()) != null) {
        //循环读取客户端的信息
                    System.out.println("我是服务器，客户端说：" + info);
                }
                socket.shutdownInput();//关闭输入流
     
                //获取输出流，响应客户端的请求
                os = socket.getOutputStream();
                pw = new PrintWriter(os);
                pw.write("欢迎您！");
                pw.flush();//调用flush()方法将缓冲输出
            } catch (IOException e) {
        
                // TODO Auto-generated catch block
                e.printStackTrace();
            } finally {
        
                //关闭资源
                try {
        
                    if (pw != null)
                        pw.close();
                    if (os != null)
                        os.close();
                    if (br != null)
                        br.close();
                    if (isr != null)
                        isr.close();
                    if (is != null)
                        is.close();
                    if (socket != null)
                        socket.close();
                } catch (IOException e) {
        
                    e.printStackTrace();
                }
            }
        }
    }

3.客户端；创建Socket对象，请求与服务器建立连接；

package com.commucntion.java;
    
    import java.io.BufferedReader;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.InputStreamReader;
    import java.io.OutputStream;
    import java.io.PrintWriter;
    import java.net.Socket;
    import java.net.UnknownHostException;
     
    /*
     * 客户端
     */
    public class Client {
        
        public static void main(String[] args) {
        
            try {
        
                //1.创建客户端Socket，指定服务器地址和端口
                Socket socket = new Socket("127.0.0.1", 8901);
     
                //2.获取输出流，向服务器端发送信息
                OutputStream os = socket.getOutputStream();//字节输出流
                PrintWriter pw = new PrintWriter(os);//将输出流包装为打印流
                pw.write("用户名：alice;密码：789");
                pw.flush();
                socket.shutdownOutput();//关闭输出流
     
                //3.获取输入流，并读取服务器端的响应信息
                InputStream is = socket.getInputStream();
                BufferedReader br = new BufferedReader(new InputStreamReader(is));
                String info = null;
                while ((info = br.readLine()) != null) {
        
                    System.out.println("我是客户端，服务器说：" + info);
                }
     
                //4.关闭资源
                br.close();
                is.close();
                pw.close();
                os.close();
                socket.close();
            } catch (UnknownHostException e) {
        
                e.printStackTrace();
            } catch (IOException e) {
        
                e.printStackTrace();
            }
        }
    }

四 、实验结果

1.  ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2VzY0ZBSg_size_16_color_FFFFFF_t_70_pic_center]

2.先启动服务端，再启动客户端，原因：客户端主动与服务器端建立连接。  
3.服务器端的 ServerSocket 对象示例，不能执行.close();原因：要一直等待客户端请求建立连接。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2VzY0ZBSg_size_16_color_FFFFFF_t_70_pic_center]: /images/20221124/b462c8f775344eee8f04e4e0e3c1b072.png