上一篇文章说到了用Java Socket来传输对象,但是在有些情况下比如网络环境不好或者对象比较大的情况下需要把数据对象进行压缩然后在传输,此时就需要压缩这些对象流,此时就可以GZIPInputStream和GZIPOutputStream来处理一下socket的InputStream和OutputStream。
仍然需要一个实现了java.io.Serializable接口的简单Java对象
package com.googlecode.garbagecan.test.socket.sample4; public class User implements java.io.Serializable { private static final long serialVersionUID = 1L; private String name; private String password; public User() { } public User(String name, String password) { this.name = name; this.password = password; } public String getName() { return name; } public void setName(String name) { this.name = name; } public String getPassword() { return password; } public void setPassword(String password) { this.password = password; } }
在Server端使用,socket的InputStream首先被包装成GZIPInputStream,然后又被包装成ObjectInputStream,而socket的OutputStream首先被包装成GZIPOutputStream,然后又被包装成ObjectOutputStream,如下:
package com.googlecode.garbagecan.test.socket.sample4; import java.io.IOException; import java.io.ObjectInputStream; import java.io.ObjectOutputStream; import java.net.ServerSocket; import java.net.Socket; import java.util.logging.Level; import java.util.logging.Logger; import java.util.zip.GZIPInputStream; import java.util.zip.GZIPOutputStream; public class MyServer { private final static Logger logger = Logger.getLogger(MyServer.class.getName()); public static void main(String[] args) throws IOException { ServerSocket server = new ServerSocket(10000); while (true) { Socket socket = server.accept(); socket.setSoTimeout(10 * 1000); invoke(socket); } } private static void invoke(final Socket socket) throws IOException { new Thread(new Runnable() { public void run() { GZIPInputStream gzipis = null; ObjectInputStream ois = null; GZIPOutputStream gzipos = null; ObjectOutputStream oos = null; try { gzipis = new GZIPInputStream(socket.getInputStream()); ois = new ObjectInputStream(gzipis); gzipos = new GZIPOutputStream(socket.getOutputStream()); oos = new ObjectOutputStream(gzipos); Object obj = ois.readObject(); User user = (User)obj; System.out.println("user: " + user.getName() + "/" + user.getPassword()); user.setName(user.getName() + "_new"); user.setPassword(user.getPassword() + "_new"); oos.writeObject(user); oos.flush(); gzipos.finish(); } catch (IOException ex) { logger.log(Level.SEVERE, null, ex); } catch(ClassNotFoundException ex) { logger.log(Level.SEVERE, null, ex); } finally { try { ois.close(); } catch(Exception ex) {} try { oos.close(); } catch(Exception ex) {} try { socket.close(); } catch(Exception ex) {} } } }).start(); } }
Client也和Server端类似,同样要不socket的XXXStream包装成GZIPXXXStream,然后再包装成ObjectXXXStream,如下:
package com.googlecode.garbagecan.test.socket.sample4; import java.io.IOException; import java.io.ObjectInputStream; import java.io.ObjectOutputStream; import java.net.InetSocketAddress; import java.net.Socket; import java.net.SocketAddress; import java.util.logging.Level; import java.util.logging.Logger; import java.util.zip.GZIPInputStream; import java.util.zip.GZIPOutputStream; public class MyClient { private final static Logger logger = Logger.getLogger(MyClient.class.getName()); public static void main(String[] args) throws Exception { for (int i = 0; i < 10; i++) { Socket socket = null; GZIPOutputStream gzipos = null; ObjectOutputStream oos = null; GZIPInputStream gzipis = null; ObjectInputStream ois = null; try { socket = new Socket(); SocketAddress socketAddress = new InetSocketAddress("localhost", 10000); socket.connect(socketAddress, 10 * 1000); socket.setSoTimeout(10 * 1000); gzipos = new GZIPOutputStream(socket.getOutputStream()); oos = new ObjectOutputStream(gzipos); User user = new User("user_" + i, "password_" + i); oos.writeObject(user); oos.flush(); gzipos.finish(); gzipis = new GZIPInputStream(socket.getInputStream()); ois = new ObjectInputStream(gzipis); Object obj = ois.readObject(); if (obj != null) { user = (User)obj; System.out.println("user: " + user.getName() + "/" + user.getPassword()); } } catch(IOException ex) { logger.log(Level.SEVERE, null, ex); } finally { try { ois.close(); } catch(Exception ex) {} try { oos.close(); } catch(Exception ex) {} try { socket.close(); } catch(Exception ex) {} } } } }
最后测试上面的代码,首先运行Server类,然后运行Client类,就可以分别在Server端和Client端控制台看到接收到的User对象实例了。
相关推荐
java socket使用加密协议传输对象
java socket 大文件传输,快速传输, 数据包的分片,组装,涉及UDP,TCP传输技术,NIO非阻塞等等,适合对socket编程进一步学习的同学
java socket 简单的文件传输程序,只是实现了基本功能而已。
java socket传输demo 客户端和服务器端传输demojava socket传输demo 客户端和服务器端传输demo
自己写的东东,已经打成jar包,java socket的聊天和文件传输的工具,暂不提供源代码,有兴趣可以反编译。
Java Socket传输图片源代码;短小精悍,适合初学者学习参考使用
采用java socket编程,利用Internet传输各种类型的文件,在传输过程中数据完整,传输速度快等优点。
用JAVA实现的文件上传,控制台输入,保存到数据库
基于java nio socket 的文件传输例程
主要介绍了Java Socket实现传输压缩对象的方法,结合具体实例形式分析了java socket针对数据的压缩、传输、接收、解压缩等操作相关实现技巧,需要的朋友可以参考下
此代码为 tcp 协议传输 java socket 图片
JAVA Socket教程 Java网络编程之传输控制协议 Socket套接字—Java套接字编程
java socket 多线程网络传输多个文件
Java基于Socket文件传输示例Java基于Socket文件传输示例Java基于Socket文件传输示例
java socket教程java socket教程java socket教程
合并了聊天和文件传输功能,能够一边传输文件一边聊天,在局域网已经初步测试。并附上源代码和简单的说明。
Java Socket编程 PC端程序 用来传输文件 包括服务器、客户端
java socket 聊天系统 java传输文件 多线程聊天系统
java socket处理硬件传过来的16进制数据的工具类,包含大小端转换、byte[]数组转换为16进制的字符串、byte[]转ByteBuffer、16进制字符串转换为byte数组等
计算机网络 作业实例 Java socket编程 文件传输