设为首页 收藏本站
查看: 935|回复: 0

[经验分享] Socket -learning a little from IBM tutorial

[复制链接]

尚未签到

发表于 2017-5-26 07:19:21 | 显示全部楼层 |阅读模式
  There are three files to complete this example:
  RemoteFileClient.java
  RemoteFileServer.java
  ConnectionHandler.java
  the codes are:

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;

public class RemoteFileClient {
protected String hostIp;
protected int hostPort;
protected BufferedReader socketReader;
protected PrintWriter socketWriter;
public RemoteFileClient(String hostIp,int hostPort){
this.hostIp = hostIp;
this.hostPort = hostPort;
}
public void setUpConnection(){
try {
Socket client = new Socket(hostIp,hostPort);
socketReader = new BufferedReader(new InputStreamReader(client.getInputStream()));
socketWriter = new PrintWriter(client.getOutputStream());
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public String getFile(String fileNameToGet){
StringBuffer fileString = new StringBuffer();
String line = null;
socketWriter.println(fileNameToGet);
socketWriter.flush();
try {
while((line=socketReader.readLine())!=null)
fileString.append(line+"\n");
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return fileString.toString();
}
public void teardownConnection(){
try {
socketWriter.close();
socketReader.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public static void main(String args[]){
RemoteFileClient remoteFileClient = new RemoteFileClient("127.0.0.1",3000);
remoteFileClient.setUpConnection();
String documentContent = remoteFileClient.getFile("E:\\test.txt");
remoteFileClient.teardownConnection();
System.out.println("documentContent "+documentContent);
}
}


import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

public class RemoteFileServer {
protected int listenPort = 3000;
public void acceptConnections(){
try {
//ServerSocket server = new ServerSocket(listenPort);
ServerSocket server = new ServerSocket(listenPort,5);
Socket incommingConnection = null;
while(true){
incommingConnection = server.accept();
handleConnections(incommingConnection);
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public void handleConnections(Socket incommingConnection){
new Thread(new ConnectionHandler(incommingConnection)).start();
/*try {
OutputStream outputToSocket = incommingConnection.getOutputStream();
InputStream inputformSocket = incommingConnection.getInputStream();
BufferedReader steamReader = new BufferedReader(new InputStreamReader(inputformSocket));
FileReader fileReader = new FileReader(new File(steamReader.readLine()));
BufferedReader bufferedFileReader = new BufferedReader(fileReader);
PrintWriter streamWriter = new PrintWriter(outputToSocket);
String line = null;
while((line=bufferedFileReader.readLine())!=null)
streamWriter.println(line);
fileReader.close();
streamWriter.close();
steamReader.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}*/
}
public static void main(String args[]){
RemoteFileServer fileServer = new RemoteFileServer();
fileServer.acceptConnections();
}
}


import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;

public class ConnectionHandler implements Runnable{
public Socket connectionSocket;
public ConnectionHandler(Socket connectionSocket){
this.connectionSocket = connectionSocket;
}
public void run() {
// TODO Auto-generated method stub
try {
OutputStream outputToSocket = connectionSocket.getOutputStream();
InputStream inputformSocket = connectionSocket.getInputStream();
BufferedReader steamReader = new BufferedReader(new InputStreamReader(inputformSocket));
FileReader fileReader = new FileReader(new File(steamReader.readLine()));
BufferedReader bufferedFileReader = new BufferedReader(fileReader);
PrintWriter streamWriter = new PrintWriter(outputToSocket);
String line = null;
while((line=bufferedFileReader.readLine())!=null)
streamWriter.println(line);
fileReader.close();
streamWriter.close();
steamReader.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}

  by the way:
  File类
  1 ) File 类介绍
  File 类封装了对用户机器的文件系统进行操作的功能。例如,可以用 File 类获得文件上次修改的时间移动,
  或者对文件进行删除、重命名。换句话说,流类关注的是文件内容,而 File 类关注的是文件在磁盘上的存储
  File 类的主要方法有(),lastMod: getName(),getCanonicalFileified(),isDerector(),isFile(),getPath() 等;
  
2 ) File 类与 FileInputStream 类的区别:
  流类关注的是文件内容,而 File 类关注的是文件在磁盘上的存储。
File 不属于文件流 , 只能代表一个文件或是目录的路径名而已。
提示:
  如果处理文件或者目录名,就应该使用 File 对象,而不是字符串。例如, File 类的 equals 方法知道一些
  文件系统对大小写是敏感的,目录尾的“ / ”字符无关紧要。
  FileInputStream 类或者 FileReader 类的构造函数有多个,其中典型的两个分别为:一个使用 File 对象为参数;而另一个使用表示路径的 String 对象作为参数;自己以前一直觉得直接用了 String 指定路径就可以了,一直不明白为什么很多人都先构造一个 File 对象,现在终于明白了,“如果处理文件或者目录名,就应该使用 File 对象,而不是字符串。”!
  FileInputStream 类
  1 ) FileInputStream 类介绍:
  以字节为单位的流处理。字节序列:二进制数据。与编码无关,不存在乱码问题。
  FileInputStream 类的主要方法有:
  Read (), read ( byte[] b ), read ( byte[],int off,int len ) ,available();
2 ) FileInputStream 类与 FileReader 类的区别:
  两个类的构造函数的形式和参数都是相同的,参数为 File 对象或者表示路径的 String ,它们到底有何区别
  呢?
  FileInputStream :以字节流方式读取;
  FileReader :把文件转换为字符流读入;
InputStream提供的是字节流的读取,而非文本读取,这是和Reader类的根本区别。用Reader读取出
  来的是char数组或者String ,使用InputStream读取出来的是byte数组。
  
Reader类及其子类提供的字符流的读取char,inputStream及其子类提供字节流的读取byte,所以FileReader类是将文件按字符流的方式读取,FileInputStream则按字节流的方式读取文件;InputStreamReader可以将读如stream转换成字符流方式,是reader和stream之间的桥梁
  
最初Java是不支持对文本文件的处理的,为了弥补这个缺憾而引入了Reader和Writer两个类。
 
FileInputStream 类以二进制输入 / 输出, I/O 速度快且效率搞,但是它的 read ()方法读到
  的是一个字节,很不利于人们阅读。 而 FileReader 类弥补了这个缺陷,可以以文本格式输入/ 输出,非常方便;比如可以使用 while((ch = filereader.read())!=-1 ) 循环来读取文件;可以使用BufferedReader 的 readLine() 方法一行一行的读取文本。
  当我们读写文本文件的时候,采用 Reader 是非常方便的,比如 FileReader , InputStreamReader 和 BufferedReader 。其中最重要的类是 InputStreamReader ,它是字节转换为字符的桥梁。 你可以在构造器中指定编码的方式,如果不指定的话将采用底层操作系统的默认编码方式,例如 GBK 等。
  FileReader 与 InputStreamReader 涉及编码转换 ( 指定编码方式或者采用 os 默认编码 ) ,可能在不同的平台上出现乱码现象!而 FileInputStream 以二进制方式处理,不会出现乱码现象 .
  如果处理纯文本文件,建议使用 FileReader ,因为更方便,也更适合阅读;但是要注意编码问题!其他情况(处理非纯文本文件),FileInputStream是唯一的选择;FileInputStream是进Socket通讯时会用到很多,如将文件流是Stream的方式传向服务器!
 
FileReader 类
  FileReader 类介绍:
  InputStreamReader 类的子类,所有方法(read ()等)都从父类 InputStreamReader 中继承来;
  与 InputStreamReader 类的区别: 
  该类与它的父类 InputStreamReader 的主要不同在于构造函数,主要区别也就在于构造函数!从
  InputStreamReader 的构造函数中看到,参数为 InputStream 和编码方式,可以看出,当要指定编码方式时,必须使用 InputStreamReader 类;而 FileReader 构造函数的参数与 FileInputStream 同,为 File 对象或表示 path 的 String ,可以看出,当要根据 File 对象或者 String 读取一个文件时,用 FileReader 我想FileReader 子类的作用也就在于这个小分工吧。
  一般用法:
  FileReader fr = new FileReader("ming.txt");
   char[] buffer = new char[1024];
   int ch = 0;
   while((ch = fr.read())!=-1 )
   {
    System.out.print((char)ch);
   }
  InputStreamReader 类
  以文本格式输入 / 输出,可以指定编码格式;
  主要方法:
  getEncoding (),read();
  一般用法:
  InputStreamReader isr = new InputStreamReader(new FileInputStream("ming.txt"));
   while((ch = isr.read())!=-1)
   {
    System.out.print((char)ch);
   }
  BufferedReader 类
  BufferedReader 由Reader类扩展而来,提供通用的缓冲方式文本读取,而且提供了很实用的readLine,
  读取分行文本很适合,BufferedReader是针对Reader的,不直接针对文件,也不是只针对文件读取。
  
一般用法:
   
BufferedReader br = new BufferedReader(new InputStreamReader(new FileInputStream("ming.txt")));
  String data = null;
  while((data = br.readLine())!=null)
  {
   System.out.println(data);
  }
   
 
总结以上内容,得出比较好的规范用法:
  1)    File file = new File ("hello.txt");
  FileInputStream in=new FileInputStream(file);
  2)    File file = new File ("hello.txt");
  FileInputStream in=new FileInputStream(file);
  InputStreamReader inReader=new InputStreamReader(in);
  BufferedReader bufReader=new BufferedReader(inReader);
  3)    File file = new File ("hello.txt");
  FileReader fileReader=new FileReader(file);
  BufferedReader bufReader=new BufferedReader(fileReader);
  
1)
File file = new File ("hello.txt");
FileInputStream in=new FileInputStream(file);
InputStreamReader inReader=new InputStreamReader(in);
BufferedReader bufReader=new BufferedReader(inReader);
  2)
FileInputStream in=null;
File file = new File ("hello.txt");
in=new FileInputStream(file);
BufferedReader bufReader=new BufferedReader(new InputStreamReader(in));
  3)
File file = new File ("hello.txt");
BufferedReader bufReader=new BufferedReader(new InputStreamReader(new FileInputStream(file)));
  上述两种写法的微小区别:
a)第二种方式中把“FileInputStream in=null;”定义单独放在开始处,说明下面应该还有要用到in对象变量的地方;(BufferedReader处用了)
  b)第二种方式没有定义InputStreamReader的对象变量,直接在BufferedReader的构造函数中new一个,
这种方式与第一种方式的主要区别:InputStreamReader对象只使用一次!
  这对于在这里只需要使用一次这个InputStreamReader对象的应用来说更好;无需定义InputStreamReader的对象变量,接收由new返回的该对象的引用,因为下面的程序中不需要这个InputStreamReader的对象变量,所以无需定义;所以这种情况下,第二种方式比第一种更好一些。
  c)第三种方式中,典型的三层嵌套委派关系,清晰看出Reader的委派模式(《corejava》12章有图描述该委派关系),FileInputStream和InputStreamReader都没有定义变量,new生成的对象都只是使用一次。
  d)三种方式的区别也就在于FileInputStream和InputStreamReader对象是否都只使用一次,是否需要定义它们的对象变量,以及个人的编码习惯。
  e)但是要注意异常处理,FileInputStream(file)会抛出NotFileFoundException,如果采用surround方式
(try&catch)处理,应该用第二种方式,这样可以用System.out.println提示文件未找到;
当然在函数名后使用throws Exception,然后用第三种方式也行,但似乎这适合有用户界面的情况,把异常抛出在客户端在处理。
  
本文来自CSDN博客,出处:http://blog.csdn.net/leiyuanxiu/archive/2009/03/30/4036001.aspx

运维网声明 1、欢迎大家加入本站运维交流群:群②:261659950 群⑤:202807635 群⑦870801961 群⑧679858003
2、本站所有主题由该帖子作者发表,该帖子作者与运维网享有帖子相关版权
3、所有作品的著作权均归原作者享有,请您和我们一样尊重他人的著作权等合法权益。如果您对作品感到满意,请购买正版
4、禁止制作、复制、发布和传播具有反动、淫秽、色情、暴力、凶杀等内容的信息,一经发现立即删除。若您因此触犯法律,一切后果自负,我们对此不承担任何责任
5、所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其内容的准确性、可靠性、正当性、安全性、合法性等负责,亦不承担任何法律责任
6、所有作品仅供您个人学习、研究或欣赏,不得用于商业或者其他用途,否则,一切后果均由您自己承担,我们对此不承担任何法律责任
7、如涉及侵犯版权等问题,请您及时通知我们,我们将立即采取措施予以解决
8、联系人Email:admin@iyunv.com 网址:www.yunweiku.com

所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其承担任何法律责任,如涉及侵犯版权等问题,请您及时通知我们,我们将立即处理,联系人Email:kefu@iyunv.com,QQ:1061981298 本贴地址:https://www.yunweiku.com/thread-381053-1-1.html 上篇帖子: java 泛型简介 --摘自IBM developerWorks 中国 下篇帖子: IBM MQ/WMB(一) 基本配置
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

扫码加入运维网微信交流群X

扫码加入运维网微信交流群

扫描二维码加入运维网微信交流群,最新一手资源尽在官方微信交流群!快快加入我们吧...

扫描微信二维码查看详情

客服E-mail:kefu@iyunv.com 客服QQ:1061981298


QQ群⑦:运维网交流群⑦ QQ群⑧:运维网交流群⑧ k8s群:运维网kubernetes交流群


提醒:禁止发布任何违反国家法律、法规的言论与图片等内容;本站内容均来自个人观点与网络等信息,非本站认同之观点.


本站大部分资源是网友从网上搜集分享而来,其版权均归原作者及其网站所有,我们尊重他人的合法权益,如有内容侵犯您的合法权益,请及时与我们联系进行核实删除!



合作伙伴: 青云cloud

快速回复 返回顶部 返回列表