软件设计模式|软件体系结构性能战术实验多线程|设计模式|算法|java

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

服务器端，创建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(); } } }

服务器端处理接受参数与对客户端作出响应；接受客户端的请求，并建立专线连接；底层是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(); } } }

四、实验结果