Java Socket实战之四 传输压缩对象

2019独角兽企业重金招聘Python工程师标准>>> hot3.png

本文地址:http://blog.csdn.net/kongxx/article/details/7259834

Java Socket实战之一 单线程通信

Java Socket实战之二 多线程通信

Java Socket实战之三 传输对象

上一篇文章说到了用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对象实例了。







转载于:https://my.oschina.net/baochanghong/blog/423127

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/297246.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

批量提取文件创建时间_不要眨眼!批量提取文件名,只需30秒

私信回复关键词【工具】~获取Excel高效小工具合集&#xff01;让你的Excel效率开挂~众所周知&#xff0c;「复制粘贴」可以解决 Excel 中出现的大多数问题。那我们为什么还要学习 Excel 相关技巧&#xff1f;&#xff1f;&#xff1f;因为&#xff0c;「复制粘贴」费时费力呀&a…

“妈,你当年咋看上我爸的?”网友晒爸妈结婚照,笑抽了!

全世界只有3.14 % 的人关注了爆炸吧知识最近看到网上有人问什么事情让你开始怀疑人生一网友回答看到我爹妈的结婚照我开始怀疑人生我怀疑我妈当时被我爸绑架了▼妈&#xff0c;有啥想不开的好好说或者你告诉我我爸到底是有什么特殊才艺吸引了你▼爸&#xff01;我知道你娶到我妈…

【转】卖场开设社区便利店,不仅卖货,还有家政服务、售后衔接等(图)

台海网(微博)6月1日讯 &#xff08;海峡导报记者 孙春燕/文 吴晓平/图&#xff09;家门口开天虹便利店了&#xff0c;不仅有食品、水果&#xff0c;还有家政服务。  昨天&#xff0c;导报记者走访市场发现&#xff0c;厦门天虹第一家社区便利店“微喔”已于两周前悄然开业&am…

巴巴运动网学习笔记(16-20)

1.ProductType的JPA映射 View Code 1 Entity 2 public class ProductType { 3 private int id; 4 private String name; 5 private String note; 6 private boolean visible true; 7 private Set<ProductType> child; 8 private ProductType p…

批量生成 Gitee 仓库克隆命令的方法

当我们在一个新的公司入职或者发现一个很有意思的开源项目作者时&#xff0c;我们可能需要或者很想将该公司或作者的所有开源项目都克隆到本地慢慢研究。于是&#xff0c;笔者制作出了一段脚本可以一波将页面上的所有仓库生成克隆命令&#xff1a;var tmp []; $(.repository).…

Heartbeat+httpd+NFS 实现高可用的Web服务器

一、环境系统:CentOS 6.4x64位最小化安装nfs:192.168.3.31node1:192.168.3.32node2:192.168.3.33vip:192.168.3.34二、拓扑图三、前提条件1.节点之间主机名互相解析node1,node2:[rootheatbeat-node1 ~]# cat /etc/hosts 127.0.0.1 localhost localhost.localdomain localhost…

VS2005混合编译ARM汇编代码

2019独角兽企业重金招聘Python工程师标准>>> 在开发过程中&#xff0c;发现简单的在Storage Memory区域拷贝或粘贴文件不能达到硬件量测的要求&#xff0c;需要直接通过编写ARM汇编指令让CPU直接对Memory进行读写数据。 以前没有用VS2005编写过汇编代码&#xff0c;…

中国最险六大寺庙,最后一座至今无人登临

全世界只有3.14 % 的人关注了爆炸吧知识来源&#xff1a;「风景线」佛教远离尘世的特性使得很多寺庙修建于偏僻险要的山野&#xff0c;看似岌岌可危的建筑&#xff0c;却能屹立千百年而不倒&#xff0c;这不得不感叹古人智慧的伟大&#xff0c;这6大险要寺庙&#xff0c;绝对能…

c/c++ code JSON

cJSON 初体验 cJSON是一个超轻巧&#xff0c;携带方便&#xff0c;单文件&#xff0c;简单的可以作为ANSI-C标准的JSON解析器。官网地址 cJSON.c /*Copyright (c) 2009 Dave GamblePermission is hereby granted, free of charge, to any person obtaining a copyof this softw…

Dapr牵手.NET学习笔记:发布-订阅

queue&#xff0c;是很好的削峰填谷工具&#xff0c;在业内也是主流&#xff1b;发布订阅&#xff0c;可以有效的解耦两个应用&#xff0c;所以dapr把他们进行了有效的封装&#xff0c;我们使用起来更简单高效。本篇的案例是下完订单后&#xff0c;会把消息发布到redis&#xf…

sql年月日24小时制_Power Query 抓取气象台24小时降水量数据

我们借鉴之前抓取台风路径数据的例子&#xff0c;试一试抓取降水量数据&#xff1a;之前我们访问过这个网站&#xff0c;也试着抓取过数据&#xff0c;不过在谷歌浏览器中我们只能够找到两天的数据&#xff0c;但是通过台风路径数据抓取&#xff0c;我们猜想只要我们向服务器提…

薅羊毛丨5个平价好物,终于终于终于打折了!

▲ 点击查看大家好&#xff0c;超模全新的固定栏目「薅羊毛」上线了&#xff01;既然是薅羊毛&#xff0c;怎么能空着手来&#xff1f;别看今天是草单&#xff0c;但所有产品都是咱们商务部小哥谈了好久才拿下的团购&#xff0c;而且全都包邮。毕竟好用的好吃的&#xff0c;啥都…

Docker小白到实战之Docker Compose在手,一键足矣

前言Docker可以将应用程序及环境很方便的以容器的形式启动&#xff0c;但当应用程序依赖的服务比较多&#xff0c;或是遇到一个大系统拆分的服务很多时&#xff0c;如果还一个一个的根据镜像启动容器&#xff0c;那就有点累人了&#xff0c;到这有很多小伙伴会说&#xff1a;弄…

Hsiaoyang:Google搜索结果页面分析

Hsiaoyang:Google搜索结果页面分析首先请参看Google官方的“搜索结果页”用户在使用搜索引擎的时候&#xff0c;首先会在搜索框中输入关键词&#xff0c;随后SE会返回一个搜索结果呈现给用户。SEO的主要对象是搜索引擎&#xff0c;而了解搜索引擎对搜索结果的展现对于SEO人员的…

泰国小哥又双叒叕整活,奇怪的美少女出现了......

最近“文艺复兴”又流行起来了&#xff0c;这一次遭殃的是80和90后的童年偶像——水兵月。在推特“重绘水兵月”的标签下&#xff0c;民间的绘画高手甚至业内的大佬&#xff0c;都以自己的画风&#xff0c;对下面这张出自《美少女战士》的截图进行重绘。下面让我们来欣赏网络上…

和套套一样,一次性橡胶手套制作现场, 这鬼畜的画风

全世界只有3.14 % 的人关注了爆炸吧知识来源&#xff1a;普象工业设计小站ID&#xff1a;iamdesign如果说套套的制作过程很羞羞那同为乳胶制品的乳胶手套制作过程则可以用魔性甚至惊悚来说走进乳胶手套制作的工厂里迎面而来的是数不清的白色之手不停地在转啊转、甩啊甩这画面不…

Installing OpenCV 2.3.1 in Ubuntu

step1&#xff1a;下载 从http://sourceforge.net/projects/opencvlibrary 下载OpenCV源码&#xff0c;下载文件为OpenCV-2.3.1a.tar.bz2。 cd ~ wget http://sourceforge.net/projects/opencvlibrary/files/opencv-unix/2.1/OpenCV-2.3.1a.tar.bz2/download step2&#xff1a;…

Magicodes.IE 2.5.6.1发布

2.5.6.12021.10.06修复 #337&#xff0c;bool?类型导出的映射问题2.5.6.02021.10.05合并Magicodes.EPPlus到Magicodes.IE&#xff0c;修复所有单元测试并修复部分Bug对EPPlus进行了部分性能优化&#xff08;比如使用高性能内存流代替MemoryStream&#xff09;和功能加强2.5.5.…

OpenSSL--Window生成证书实战

为什么80%的码农都做不了架构师&#xff1f;>>> Windows下使用OpenSSL生成自签证书&#xff08;亲测&#xff09; 一&#xff0c;前言 经常写博客的小伙伴儿都知道&#xff0c;大家一般在前言里面会提到为什么写这篇博客&#xff0c;而我这篇博客 主要是探讨OpenSS…

7年赚的2个亿,数学家6年就花光了,全砸在自家的房子上

全世界只有3.14 % 的人关注了爆炸吧知识提到数学家&#xff0c;我以为是这样的&#xff1a;发际线不低&#xff0c;面部表情匮乏&#xff0c;总爱是写外星符号。然而却是这样的&#xff0c;刚刚还在讲sin、cos,一转头就掏出一把小提琴&#xff0c;超高难度的帕格尼尼随想曲说来…