【转】java socket程序
2009年09月21日
老久没有动手写Socket程序了,今天应同事的要求上了一段程序。
这是一段很简单与C++编写的服务端通讯的java客户端,咋一看上去,没有任何问题。
貌似没有问题的程序
Java代码
public static String sendSynMsg(String ipAddr, byte[] datas) throws Exception{ //解析服务器地址和端口号 int dotPos = ipAddr.indexOf(':'); String ip = ipAddr.substring(0, dotPos).trim(); int port = Integer.parseInt(ipAddr.substring(dotPos+1).trim()); InetSocketAddress endpoint = new InetSocketAddress(ip , port); Socket socket = null; OutputStream out = null; InputStream in = null; try { socket = new Socket(); //设置发送逗留时间2秒 socket.setSoLinger(true, 2); //设置InputStream上调用 read()阻塞超时时间2秒 socket.setSoTimeout(2000); //设置socket发包缓冲为32k; socket.setSendBufferSize(32*1024); //设置socket底层接收缓冲为32k socket.setReceiveBufferSize(32*1024); //关闭Nagle算法.立即发包 socket.setTcpNoDelay(true); //连接服务器 socket.connect(endpoint); //获取输出输入流 out = socket.getOutputStream(); in = socket.getInputStream(); //输出请求 out.write(datas); out.flush(); //接收应答 BufferedReader br = new BufferedReader( new InputStreamReader(in) , 4096); StringWriter received = new StringWriter(4096); char[] charBuf = new char[4096]; int size = 0; while ((size = br.read(charBuf)) > 0){ received.write(charBuf, 0, size); } return received.toString(); } finally { if (out != null) { try { out.close(); } catch(Exception ex) { ex.printStackTrace(); } } if (in != null) { try { in.close(); } catch(Exception ex) { ex.printStackTrace(); } } if (socket != null) { try { socket.close(); } catch(Exception ex) { ex.printStackTrace(); } } } }
public static String sendSynMsg(String ipAddr, byte[] datas) throws Exception{ //解析服务器地址和端口号 int dotPos = ipAddr.indexOf(':'); String ip = ipAddr.substring(0, dotPos).trim(); int port = Integer.parseInt(ipAddr.substring(dotPos+1).trim()); InetSocketAddress endpoint = new InetSocketAddress(ip , port); Socket socket = null; OutputStream out = null; InputStream in = null; try { socket = new Socket(); //设置发送逗留时间2秒 socket.setSoLinger(true, 2); //设置InputStream上调用 read()阻塞超时时间2秒 socket.setSoTimeout(2000); //设置socket发包缓冲为32k; socket.setSendBufferSize(32*1024); //设置socket底层接收缓冲为32k socket.setReceiveBufferSize(32*1024); //关闭Nagle算法.立即发包 socket.setTcpNoDelay(true); //连接服务器 socket.connect(endpoint); //获取输出输入流 out = socket.getOutputStream(); in = socket.getInputStream(); //输出请求 out.write(datas); out.flush(); //接收应答 BufferedReader br = new BufferedReader( new InputStreamReader(in) , 4096); StringWriter received = new StringWriter(4096); char[] charBuf = new char[4096]; int size = 0; while ((size = br.read(charBuf)) > 0){ received.write(charBuf, 0, size); } return received.toString(); } finally { if (out != null) { try { out.close(); } catch(Exception ex) { ex.printStackTrace(); } } if (in != null) { try { in.close(); } catch(Exception ex) { ex.printStackTrace(); } } if (socket != null) { try { socket.close(); } catch(Exception ex) { ex.printStackTrace(); } } } }
但实际的调试中,总是报Read TimeOut异常!!排查原因后发现,数据是接收到了,只是size = br.read(charBuf)不会返回-1(java doc中的说明是读取到结束时size会返回-1)。
对于编写服务器端程序的C++程序员而言,他们通常会在通讯结束的时候,在数据的尾部加上一个\0的结束字符。因此,我们针对此做了修正
出问题的程序段
Java代码
while ((size = br.read(charBuf)) > 0){ received.write(charBuf, 0, size); }
while ((size = br.read(charBuf)) > 0){ received.write(charBuf, 0, size); }
修改后的正确写法
Java代码
char lastChar = 0; do { size = br.read(charBuf , 0 , 4096); lastChar = charBuf[size-1]; if(lastChar == 0){ //去除尾部的\0字符 received.write(charBuf, 0, size - 1); } }while(lastChar != 0);
char lastChar = 0; do { size = br.read(charBuf , 0 , 4096); lastChar = charBuf[size-1]; if(lastChar == 0){ //去除尾部的\0字符 received.write(charBuf, 0, size - 1); } }while(lastChar != 0);
最终的完整程序段:
Java代码
private static String sendSynMsg(String ipAddr, byte[] datas) throws Exception{ //解析服务器地址和端口号 int dotPos = ipAddr.indexOf(':'); String ip = ipAddr.substring(0, dotPos).trim(); int port = Integer.parseInt(ipAddr.substring(dotPos+1).trim()); InetSocketAddress endpoint = new InetSocketAddress(ip , port); Socket socket = null; OutputStream out = null; InputStream in = null; try { socket = new Socket(); //设置发送逗留时间2秒 socket.setSoLinger(true, 2); //设置InputStream上调用 read()阻塞超时时间2秒 socket.setSoTimeout(2000); //设置socket发包缓冲为32k; socket.setSendBufferSize(32*1024); //设置socket底层接收缓冲为32k socket.setReceiveBufferSize(32*1024); //关闭Nagle算法.立即发包 socket.setTcpNoDelay(true); //连接服务器 socket.connect(endpoint); //获取输出输入流 out = socket.getOutputStream(); in = socket.getInputStream(); //输出请求 out.write(datas); out.flush(); //接收应答 BufferedReader br = new BufferedReader( new InputStreamReader(in) , 4096); StringWriter received = new StringWriter(4096); char[] charBuf = new char[4096]; int size = 0; char lastChar = 0; do { size = br.read(charBuf , 0 , 4096); lastChar = charBuf[size-1]; if(lastChar == 0){ received.write(charBuf, 0, size - 1); } //System.out.println(received.toString()); }while(lastChar != 0); return received.toString(); } finally { if (out != null) { try { out.close(); } catch(Exception ex) { ex.printStackTrace(); } } if (in != null) { try { in.close(); } catch(Exception ex) { ex.printStackTrace(); } } if (socket != null) { try { socket.close(); } catch(Exception ex) { ex.printStackTrace(); } } } }
private static String sendSynMsg(String ipAddr, byte[] datas) throws Exception{ //解析服务器地址和端口号 int dotPos = ipAddr.indexOf(':'); String ip = ipAddr.substring(0, dotPos).trim(); int port = Integer.parseInt(ipAddr.substring(dotPos+1).trim()); InetSocketAddress endpoint = new InetSocketAddress(ip , port); Socket socket = null; OutputStream out = null; InputStream in = null; try { socket = new Socket(); //设置发送逗留时间2秒 socket.setSoLinger(true, 2); //设置InputStream上调用 read()阻塞超时时间2秒 socket.setSoTimeout(2000); //设置socket发包缓冲为32k; socket.setSendBufferSize(32*1024); //设置socket底层接收缓冲为32k socket.setReceiveBufferSize(32*1024); //关闭Nagle算法.立即发包 socket.setTcpNoDelay(true); //连接服务器 socket.connect(endpoint); //获取输出输入流 out = socket.getOutputStream(); in = socket.getInputStream(); //输出请求 out.write(datas); out.flush(); //接收应答 BufferedReader br = new BufferedReader( new InputStreamReader(in) , 4096); StringWriter received = new StringWriter(4096); char[] charBuf = new char[4096]; int size = 0; char lastChar = 0; do { size = br.read(charBuf , 0 , 4096); lastChar = charBuf[size-1]; if(lastChar == 0){ received.write(charBuf, 0, size - 1); } //System.out.println(received.toString()); }while(lastChar != 0); return received.toString(); } finally { if (out != null) { try { out.close(); } catch(Exception ex) { ex.printStackTrace(); } } if (in != null) { try { in.close(); } catch(Exception ex) { ex.printStackTrace(); } } if (socket != null) { try { socket.close(); } catch(Exception ex) { ex.printStackTrace(); } } } }
程序中的关键点:
1. 不直接使用new Socket(String ip , int port)的构造函数,而是设置了socket的环境参数后再连接
2.设置发送逗留时间 socket.setSoLinger(true, 2); 这个参数是socket发送数据时的超时,如果对方在固定时间内不接受,则关闭socket。与socket.setSoTimeout(2000)不同,这个是设置InputStream上调用 read()阻塞超时时间。
3.socket.setTcpNoDelay(true);关闭Nagle算法。这使得在调用out.flush();时总能第一时间的发送数据包(这个适用于你的数据包是完整的一次性发送的前提)。
4.根据应用协议的实际大小,优化你的接收和发送缓冲,这两个参数可以有效提高网络通信的效率。
5.使用char的数组配合StringWriter作为接收数据的写入,这个比使用readLine方法实现更优雅。
发表评论
-
apache1.3.39源码alloc.c阅读笔记
2012-01-20 00:48 643apache1.3.39源码alloc.c阅读笔记 2011 ... -
Web安全漏洞之:JDK1.5环境下扫描远程调试端口导致JVM崩溃【JDWP exit error JVMTI_ERROR_NONE(0)】
2012-01-20 00:48 1253Web安全漏洞之:JDK1.5环境 ... -
PowerTalkBox和飞信结合搞定在线客户端(.net)
2012-01-20 00:48 865PowerTalkBox和飞信结合搞 ... -
Lua的协同程序
2012-01-20 00:48 822Lua的协同程序 2011年03 ... -
同步 异步 阻塞 非阻塞
2012-01-20 00:48 640同步 异步 阻塞 非阻塞 2010年11月15日 阻塞: ... -
MaxDOS 8.0 发布,全面支持WIN7及X64系统
2012-01-17 01:05 1104MaxDOS 8.0 发布,全面支持WIN7及X64系统 2 ... -
单机MySQL数据库的优化
2012-01-17 01:05 669单机MySQL数据库的优化 ... -
DOS的命令
2012-01-17 01:05 593DOS的命令 2011年04月23日 先介绍一下通配符的 ... -
常用词汇解释
2012-01-17 01:05 566常用词汇解释 2011年02月10日 1*Android ... -
Linux下FrameBuffer直接写屏
2012-01-17 01:05 1408Linux下FrameBuffer直接写屏 2011年09月 ... -
关于手机开发socket笔记。
2012-01-15 19:47 705关于手机开发socket笔记。 2009年11月06日 ... -
提高 Linux 上 socket 性能
2012-01-15 19:47 514提高 Linux 上 socket 性能 ... -
Java-socket编程最基本介绍
2012-01-15 19:47 533Java-socket编程最基本介 ... -
Socket通信的网络仿真
2012-01-15 19:47 806Socket通信的网络仿真 2011年06月25日 这学 ...
相关推荐
一个简单的socket程序,一个服务端对应一个客户端的... 最简单的 入门级..
实现Java Socket聊天多线程编程,图形化界面,多人聊天(群聊),私人聊天,是基于本地模拟的Java聊天程序。 Java Socket聊天程序是我用了三天的时间写出来,用Netbeans建的工程,图形化界面是Netbeans拖拉出来的,...
java聊天室程序源码 2 需求分析 2.1 业务需求 1. 与聊天室成员一起聊天。 2. 可以与聊天室成员私聊。 3. 可以改变聊天内容风格。 4. 用户注册(含头像)、登录。 5. 服务器监控聊天内容。 6. 服务器过滤非法内容。 7...
java socket处理硬件传过来的16进制数据的工具类,包含大小端转换、byte[]数组转换为16进制的字符串、byte[]转ByteBuffer、16进制字符串转换为byte数组等
java socket做的通信client端程序
java socket 通讯例子附有源码 希望还不太理解java socket的原理的朋友,通过这3个简单到复杂的例子有锁帮助。 详细说明请下载。
JAVA SOCKET通讯程序
基于java socket实现的多人聊天程序,分为客户端和服务器端,希望可以对你有帮助
java做的通信程序,实现Server与client的通信。
Java语言 socket编程 多人聊天室程序,界面
java socket 简单的文件传输程序,只是实现了基本功能而已。
java socket USB和 串口通讯,使用java程序与硬件通讯的三种方式。
使用Java语言编写的最简单的socket编程程序,实现点对点通讯,多人聊天
JAVA聊天程序,基于socket的java聊天程序
一个使用java的Socket实现的多人聊天程序,有简单的用户界面,代码有详细注释,并附有打包好的jar文件,欢迎大家下载学习!
要想与服务器通信必须具备三个条件:服务器程序、客户程序和连接它们的socket程序。这三个部分缺一不可。但是,客户与服务器之间的通信有很多的方式,其中另一个方法是把客户作为索取者,把服务器作为给予者。下面...
用java写的服务器客户端程序,是对socket的简单应用,可以进行通讯,简单易懂!
JAVA 聊天程序
还不错的小程序,主要是用来和服务器交流的,客户端之间也可以相互交流。主要用了Socket技术