信息检索与搜索引擎技术_实验1 多线程编程

由天下分享时间：2024/12/17 13:52:10 加入收藏我要投稿点赞

XXXX大学信息工程与自动化学院学生实验报告

课程名称：搜索引擎技术基础实验项目名称教师评多线程编程 A.了解□ A.强 □ A.达到□ A.规范□ A.详细□ 指导教师 B.基本了解□ B.中等 □ B.基本达到□ B.基本规范□ B.一般 □ C.不了解□ C.差 □ C.未达到□ C.不规范□ C.没有 □ 该同学是否了解实验原理：该同学的实验能力：该同学的实验是否达到要求：实验报告是否规范：实验过程是否详细记录：语教师签名：年月日一、上机目的和要求

1.掌握Socket通信原理； 2.掌握并实现多线程编程技术。

二、实验原理

1、通过Socket通信实现客户端与服务器端的通信。

Socket通信分为ServerSocket和Socket两部分，ServerSocket类提供TCP连接服务，Socket类提供进行通信的Socket对象。建立TCP连接的各个步骤：：

(1)服务器创建一个ServerSocket对象，指定端口号，ServerSocket 对象等待客户端的连接请求。

(2)客户端创建一个Socket对象，指定主机地址和端口号，向服务端发出连接请求。 (3)服务端接收到客户端的连接请求，建立一条TCP连接，再创建一个 Socket 对象与客户端的Socket对象进行通信。

(4)当一方决定结束通信，向对方发送结束信息；另一方接收到结束信息后，双方分别关闭各自的TCP连接。

(5)ServerSocket对象停止等待客户端的连接请求。作为服务器首先构造一个提供TCP

-1-

连接服务的ServerSocket对象，然后指定其端口号，如果接收到客户端的连接请求，则建立一条TCP连接，再创建一个Socket对象与客户端的Socket对象进行通信，然后将从文件中读入的数据传送给客户端。由于服务器需要一直等待连接，所以需要监听端口请求。

2、实现服务器端对客户端的多线程技术。

线程：程序中单个顺序的流控制，是最小的执行单位；同类的多个线程共享一块内存空间和一组系统资源；线程独享的资源只有：寄存器，系统堆栈。

多线程：程序中多个片断同时执行。

多线程实现方法：创建一个实现Runnable 接口的类，该接口中只有一个方法：public void run()；已实现的run方法称为线程体，而实现了Runnable接口的对象称为线程的目标对象。将实现了Runnable接口的类的实例作为Thread类构造函数的参数创建线程对象，调用该对象的start()方法启动线程

三、所用仪器、材料（设备名称、型号、规格等或使用软件） PC机一台、MyEclipse 四、实验过程截图

五、源代码

EchoThreadServer.java

import java.net.* ; import java.io.* ;

public class EchoThreadServer{ public static void main(String args[]) throws Exception { // 所有异常抛出 ServerSocket server = null ; // 定义ServerSocket类 Socket client = null ; // 表示客户端 server = new ServerSocket(8888) ; // 服务器在8888端口上监听 boolean f = true ; // 定义个标记位 while(f){ System.out.println(\服务器运行，等待客户端连接。\ client = server.accept() ; // 得到连接，程序进入到阻塞状态 new Thread(new EchoThread(client)).start() ; // 每一个客户端表示一个线程 } server.close() ;

-2-

} };

EchoClient.java

import java.net.* ; import java.io.* ;

public class EchoClient{ public static void main(String args[]) throws Exception { // 所有异常抛出 Socket client = null ; // 表示客户端 client = new Socket(\ BufferedReader buf = null ; // 一次性接收完成 PrintStream out = null ; // 发送数据 BufferedReader input = null ; // 接收键盘数据 input = new BufferedReader(new InputStreamReader(System.in)) ; buf = new BufferedReader(new InputStreamReader(client.getInputStream())) ; out = new PrintStream(client.getOutputStream()) ; boolean flag = true ; // 定义标志位 while(flag){ System.out.print(\输入文件名：\ String str = input.readLine() ; // 接收键盘的输入信息 // out.println(str) ; if(\ flag = false ; }else{ File file=new File(str); if(file.isFile()){ BufferedReader br=new BufferedReader(new FileReader(file) ); while(br!=null && ( str=br.readLine())!=null){ out.println(str); System.out.println(str); } // String echo = buf.readLine() ; // 接收返回结果 // System.out.println(echo) ;// 输出回应信息 br.close();//关闭文件 } else{ System.out.println(\文件不存在\ } } } buf.close() ; client.close() ; } };

EchoThread.java

-3-

import java.net.* ; import java.io.* ;

public class EchoThread implements Runnable{ private Socket client = null ; public EchoThread(Socket client){ this.client = client ; } public void run(){ BufferedReader buf = null ; // 接收输入流 PrintStream out = null ; // 打印流输出最方便 try{ out = new PrintStream(client.getOutputStream()) ; // 准备接收客户端的输入信息 buf = new BufferedReader(new InputStreamReader(client.getInputStream())) ; boolean flag = true ; // 标志位，表示可以一直接收并回应信息 while(flag){ String str = buf.readLine() ; // 接收客户端发送的内容 if(str==null){ // 表示没有内容||\ flag = false ; // 退出循环 }else{ if(\// 如果输入的内容为bye表示结束 flag = false ; }else{ System.out.println(str) ; } } } client.close() ; }catch(Exception e){} } };

六、总结

通过这次上机实验，我掌握并实现多线程编程技术,对Socket的通信原理也有了更深入的认识。

-4-