提供3000多款全球软件/控件产品
针对软件研发的各个阶段提供专业培训与技术咨询
根据客户需求提供定制化的软件开发服务
全球知名设计软件,显著提升设计质量
打造以经营为中心,实现生产过程透明化管理
帮助企业合理产能分配,提高资源利用率
快速打造数字化生产线,实现全流程追溯
生产过程精准追溯,满足企业合规要求
以六西格玛为理论基础,实现产品质量全数字化管理
通过大屏电子看板,实现车间透明化管理
对设备进行全生命周期管理,提高设备综合利用率
实现设备数据的实时采集与监控
利用数字化技术提升油气勘探的效率和成功率
钻井计划优化、实时监控和风险评估
提供业务洞察与决策支持实现数据驱动决策
转帖|其它|编辑:郝浩|2010-05-31 11:39:31.000|阅读 630 次
概述:这里我们将讨论 handleConnection() 方法的结构,这个方法生成一个新的 Thread 来处理每个连接。我们将分两部分讨论这个问题。这一屏我们将着重该方法本身,然后在下一屏研究该方法所使用的 ConnectionHandler 助手类的结构。
# 慧都年终大促·界面/图表报表/文档/IDE等千款热门软控件火热促销中 >>
Java while循环语句会有很多重要的环节都使用到。下面我们就来看看相关的问题解决方案和相关的代码。希望大家在之后的学习和生活中能更好的使用Java while循环语句。
这里我们将讨论 handleConnection() 方法的结构,这个方法生成一个新的 Thread 来处理每个连接。我们将分两部分讨论这个问题。这一屏我们将着重该方法本身,然后在下一屏研究该方法所使用的 ConnectionHandler 助手类的结构。
Java代码
1.public void handleConnection(Socket connectionToHandle) { 2.new Thread(new ConnectionHandler(connectionToHandle)). start(); 3.} 4.public void handleConnection(Socket connectionToHandle) { 5.new Thread(new ConnectionHandler(connectionToHandle)). start(); 6.} |
我们对 RemoteFileServer 所做的大改动就体现在这个方法上。我们仍然在服务器接受一个连接之后调用 handleConnection() ,但现在我们把该 Socket 传递给 ConnectionHandler 的一个实例,它是 Runnable 的。我们用 ConnectionHandler 创建一个新 Thread 并启动它。ConnectionHandler 的 run() 方法包含Socket 读/写和读 File 的代码,这些代码原来在 RemoteFileServer 的 handleConnection() 中。
4. 处理连接:第 2 部分
这里是 ConnectionHandler 类的结构:
Java代码
7.import java.io.*; 8.import java.net.*; 9.public class ConnectionHandler implements Runnable{ 10.Socket socketToHandle; 11.public ConnectionHandler(Socket aSocketToHandle) { 12.socketToHandle = aSocketToHandle; 13.} 14.public void run() { 15.} 16.} 17.import java.io.*; 18.import java.net.*; 19.public class ConnectionHandler implements Runnable{ 20.Socket socketToHandle; 21.public ConnectionHandler(Socket aSocketToHandle) { 22.socketToHandle = aSocketToHandle; 23.} 24.public void run() { 25.} |
这个助手类相当简单。跟我们到目前为止的其它类一样,我们导入 java.net 和 java.io 。该类只有一个实例变量 socketToHandle ,它保存由该实例处理的 Socket 。类的构造器用一个 Socket 实例作参数并将它赋给 socketToHandle 。
请注意该类实现了 Runnable 接口。实现这个接口的类都必须实现 run() 方法,我们的类就是这样做的。稍后我们将探究 run() 的细节。现在只需知道它将实际处理连接,所用的代码跟我们先前在 RemoteFileServer 类中看到的是一样的。
实现 run()
这里我们实现 run() 方法,它将攫取我们的连接的流,用它来读写该连接,并在任务完成之后关闭它:
Java代码
26.public void run() { 27.try { 28.PrintWriter streamWriter = new PrintWriter(socketToHandle.getOutputStream()); 29.BufferedReader streamReader = 30.new BufferedReader(new InputStreamReader(socketToHandle.getInputStream())); 31.String fileToRead = streamReader.readLine(); 32.BufferedReader fileReader = new BufferedReader(new FileReader(fileToRead)); 33.String line = null; 34.while ((line = fileReader.readLine()) != null) 35.streamWriter.println(line); 36.fileReader.close(); 37.streamWriter.close(); 38.streamReader.close(); 39.} catch (Exception e) { 40.System.out.println("Error handling a client: " + e); 41.} 42.} 43.public void run() { 44.try { 45.PrintWriter streamWriter = new PrintWriter(socketToHandle.getOutputStream()); 46.BufferedReader streamReader = 47.new BufferedReader(new InputStreamReader(socketToHandle.getInputStream())); 48.String fileToRead = streamReader.readLine(); 49.BufferedReader fileReader = new BufferedReader(new FileReader(fileToRead)); 50.String line = null; 51.while ((line = fileReader.readLine()) != null) 52.streamWriter.println(line); 53.fileReader.close(); 54.streamWriter.close(); 55.streamReader.close(); 56.} catch (Exception e) { 57.System.out.println("Error handling a client: " + e); 58.} 59.} |
ConnectionHandler的 run() 方法所做的事情就是 RemoteFileServer 上的 handleConnection() 所做的事情。首先,我们把 InputStream 和 OutputStream 分别包装(用 Socket 的 getOutputStream() 和 getInputStream() )进 BufferedReader 和 PrintWriter 。然后我们用这些代码逐行地读目标文件:
Java代码
60.FileReader fileReader = new FileReader(new File(streamReader.readLine())); 61.BufferedReader bufferedFileReader = new BufferedReader(fileReader); 62.String line = null; 63.while ((line = bufferedFileReader.readLine()) != null) { 64.streamWriter.println(line); 65.} 66.FileReader fileReader = new FileReader(new File(streamReader.readLine())); 67.BufferedReader bufferedFileReader = new BufferedReader(fileReader); 68.String line = null; 69.while ((line = bufferedFileReader.readLine()) != null) { 70.streamWriter.println(line); 71.} |
请记住我们应该从客户机获取一条有效的文件路径,这样用该路径名构造一个新 File ,把它包装进 FileReader 以处理读文件的操作,然后把它包装进 BufferedReader 以让我们逐行地读该文件。我们在 Java while循环语句中调用 BufferedReader 上的 readLine() 直到不再有要读的行。请记注,对 readLine() 的调用将造成阻塞,直到有字节来到为止。我们获取一些字节之后就把它们放到本地的 line 变量中,然后写出到客户机上。完成读写操作之后,我们关闭打开的流。
本站文章除注明转载外,均为本站原创或翻译。欢迎任何形式的转载,但请务必注明出处、不得修改原文相关链接,如果存在内容上的异议请邮件反馈至chenjj@pclwef.cn
文章转载自:网络转载面对“数字中国”建设和中国制造2025战略实施的机遇期,中车信息公司紧跟时代的步伐,以“集约化、专业化、标准化、精益化、一体化、平台化”为工作目标,大力推进信息服务、工业软件等核心产品及业务的发展。在慧都3D解决方案的实施下,清软英泰建成了多模型来源的综合轻量化显示平台、实现文件不失真的百倍压缩比、针对模型中的大模型文件,在展示平台上进行流畅展示,提升工作效率,优化了使用体验。
本站的模型资源均免费下载,登录后即可下载。模型仅供学习交流,勿做商业用途。
本站的模型资源均免费下载,登录后即可下载。模型仅供学习交流,勿做商业用途。
本站的模型资源均免费下载,登录后即可下载。模型仅供学习交流,勿做商业用途。
服务电话
重庆/ 023-68661681
华东/ 13452821722
华南/ 18100878085
华北/ 17347785263
客户支持
技术支持咨询服务
服务热线:400-700-1020
邮箱:sales@pclwef.cn
关注我们
地址 : 重庆市九龙坡区火炬大道69号6幢