- 浏览: 390193 次
- 性别:
- 来自: 北京
文章分类
最新评论
1 引子
在Socket通信中,我们要在客户端和服务端中传输数据,传输的数据有各种类型,int,short,long以及String,甚至是自定义的各种Object,我们如何能够保证在服务端和客户端之间的数据能够使得两端都能理解,这就是所谓的“应用协议”;
在通信的“管道”中,流的都是二进制数据,所以,双方如何约定好“解析规则”,则就必须要求通信双方都预先制定好协议;
2 序列化和反序列化
在Java中,有一个借口Serializable接口,这个接口不需要实现实现任何方法,只是一个标识,Java 序列化技术可以使你将一个对象的状态写入一个Byte 流里,并且可以从其它地方把该Byte 流里的数据读出来。重新构造一个相同的对象。这种机制允许你将对象通过网络进行传播,并可以随时把对象持久化到数据库、文件等系统里。
代码如下:
我们将这个对象串行化至文件系统,然后将之还原,这个过程其实类似于一个“压扁”和“充气”的过程,请注意,我们的Person类中包含一个嵌入对象,并且birthday变化,将之设置为transient限定符,这表示我们放弃了birthday的串行化;
可见,我们的目的实现了,并且birthday没有被串行化;如果我们不讲Address实现Serializable,会发生异常:
java.io.WriteAbortedException: writing aborted
3 IO流
我们都知道JAVA的IO是一个极其庞大的类家族,也正是运用了装饰模式的经典场景;
可见,我们一部分管道是直接连接了数据源,或者直接输出到数据源,他们能够直接读数据或者写数据,我们上一节中使用的FileoutputStream和FileInputStream就是这样的管道,他们的数据源就是指存在文件系统中的文件;下一部分我们要求使用的ByteArrayInputStream和ByteArrayOutputStream也是这样的管道,不过他的数据源是存在内存中的数组;他能够通过write把数据,字符串等等写进这块数组区域,并且能够得到一个完整的字节数组;
而另外的一部分则不能直接与数据源发生读写交互,他主要用于装饰上一部分的管道,给这个管道赋予更加便捷的功能,诸如BufferedReader等等的,主要是提供了缓存,就好比给上一部分管道中间提供了一个“蓄水池”,这个“蓄水池”等到“水流”到了一定的程度的时候,才会一次性的流进或者流出等等,诸如ObjectInputStream和ObjectOutputStream,他们能够直接读写一个Object,但是这个Object被写到了哪里,是内存中的字节数组还是文件文件的文件中,而必须委托给其他管道实现;
4 在网络中传输对象
在网络中的两台机器中传输对象,前提首先是基于同一个平台,这是序列化的基础,所以这里主要有两种做法:
l 采用JAVA的序列化机制,将对象“压扁”成二进制字节,将二进制字节在网络中传输;
l 自定义协议,将对象用字符串描述出来,将字符串用二进制表示,在网络中传输,在另外一边用相反的策略解析这个字符串,重新构造业务对象,这个方法能够在异构平台中进行传输而不变形,但是需要额外的编写“压扁”和“充气”的代码;
我们这里用第一种方法:
我这边没问题呀,你的Date是否用得java.util包中的?
在Socket通信中,我们要在客户端和服务端中传输数据,传输的数据有各种类型,int,short,long以及String,甚至是自定义的各种Object,我们如何能够保证在服务端和客户端之间的数据能够使得两端都能理解,这就是所谓的“应用协议”;
在通信的“管道”中,流的都是二进制数据,所以,双方如何约定好“解析规则”,则就必须要求通信双方都预先制定好协议;
2 序列化和反序列化
在Java中,有一个借口Serializable接口,这个接口不需要实现实现任何方法,只是一个标识,Java 序列化技术可以使你将一个对象的状态写入一个Byte 流里,并且可以从其它地方把该Byte 流里的数据读出来。重新构造一个相同的对象。这种机制允许你将对象通过网络进行传播,并可以随时把对象持久化到数据库、文件等系统里。
代码如下:
Person: import java.io.Serializable; import java.util.Date; public class Person implements Serializable { private String name; private int tall; private transient Date birthday; private Address address; public String getName() { return name; } public void setName(String name) { this.name = name; } public int getTall() { return tall; } public void setTall(int tall) { this.tall = tall; } public Date getBirthday() { return birthday; } public void setBirthday(Date birthday) { this.birthday = birthday; } public Address getAddress() { return address; } public void setAddress(Address address) { this.address = address; } } Address: package stream.demo; import java.io.Serializable; public class Address implements Serializable{ private String city; private String street; public Address() { } public Address(String city, String street) { this.city = city; this.street = street; } public String getCity() { return city; } public void setCity(String city) { this.city = city; } public String getStreet() { return street; } public void setStreet(String street) { this.street = street; } }
我们将这个对象串行化至文件系统,然后将之还原,这个过程其实类似于一个“压扁”和“充气”的过程,请注意,我们的Person类中包含一个嵌入对象,并且birthday变化,将之设置为transient限定符,这表示我们放弃了birthday的串行化;
package stream.demo; import java.io.ByteArrayInputStream; import java.io.ByteArrayOutputStream; import java.io.File; import java.io.FileInputStream; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.ObjectInputStream; import java.io.ObjectOutputStream; import java.io.OutputStream; import java.util.Date; public class Persistence { public static void main(String[] args) { Persistence.savePerson(); Persistence.getPerson(); } public static void getPerson() { try { InputStream in = new FileInputStream("c:\\person.dat"); ObjectInputStream dataInput = new ObjectInputStream(in); Person p = (Person) dataInput.readObject(); System.out.println(p.getName()); System.out.println(p.getTall()); System.out.println(p.getBirthday()); System.out.println(p.getAddress().getCity()); System.out.println(p.getAddress().getStreet()); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } } public static void savePerson() { Person p = new Person(); p.setName("corey"); p.setTall(171); p.setBirthday(new Date()); p.setAddress(new Address("yiyang", "ziyang")); OutputStream out = new ByteArrayOutputStream(); try { OutputStream fileOut = new FileOutputStream(new File( "c:\\person.dat")); ObjectOutputStream dataOut = new ObjectOutputStream(fileOut); dataOut.writeObject(p); dataOut.close(); fileOut.close(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }
可见,我们的目的实现了,并且birthday没有被串行化;如果我们不讲Address实现Serializable,会发生异常:
java.io.WriteAbortedException: writing aborted
3 IO流
我们都知道JAVA的IO是一个极其庞大的类家族,也正是运用了装饰模式的经典场景;
可见,我们一部分管道是直接连接了数据源,或者直接输出到数据源,他们能够直接读数据或者写数据,我们上一节中使用的FileoutputStream和FileInputStream就是这样的管道,他们的数据源就是指存在文件系统中的文件;下一部分我们要求使用的ByteArrayInputStream和ByteArrayOutputStream也是这样的管道,不过他的数据源是存在内存中的数组;他能够通过write把数据,字符串等等写进这块数组区域,并且能够得到一个完整的字节数组;
而另外的一部分则不能直接与数据源发生读写交互,他主要用于装饰上一部分的管道,给这个管道赋予更加便捷的功能,诸如BufferedReader等等的,主要是提供了缓存,就好比给上一部分管道中间提供了一个“蓄水池”,这个“蓄水池”等到“水流”到了一定的程度的时候,才会一次性的流进或者流出等等,诸如ObjectInputStream和ObjectOutputStream,他们能够直接读写一个Object,但是这个Object被写到了哪里,是内存中的字节数组还是文件文件的文件中,而必须委托给其他管道实现;
4 在网络中传输对象
在网络中的两台机器中传输对象,前提首先是基于同一个平台,这是序列化的基础,所以这里主要有两种做法:
l 采用JAVA的序列化机制,将对象“压扁”成二进制字节,将二进制字节在网络中传输;
l 自定义协议,将对象用字符串描述出来,将字符串用二进制表示,在网络中传输,在另外一边用相反的策略解析这个字符串,重新构造业务对象,这个方法能够在异构平台中进行传输而不变形,但是需要额外的编写“压扁”和“充气”的代码;
我们这里用第一种方法:
可见,我们的目的实现了,并且birthday没有被串行化;如果我们不讲Address实现Serializable,会发生异常: java.io.WriteAbortedException: writing aborted 3 IO流 我们都知道JAVA的IO是一个极其庞大的类家族,也正是运用了装饰模式的经典场景; 可见,我们一部分管道是直接连接了数据源,或者直接输出到数据源,他们能够直接读数据或者写数据,我们上一节中使用的FileoutputStream和FileInputStream就是这样的管道,他们的数据源就是指存在文件系统中的文件;下一部分我们要求使用的ByteArrayInputStream和ByteArrayOutputStream也是这样的管道,不过他的数据源是存在内存中的数组;他能够通过write把数据,字符串等等写进这块数组区域,并且能够得到一个完整的字节数组; 而另外的一部分则不能直接与数据源发生读写交互,他主要用于装饰上一部分的管道,给这个管道赋予更加便捷的功能,诸如BufferedReader等等的,主要是提供了缓存,就好比给上一部分管道中间提供了一个“蓄水池”,这个“蓄水池”等到“水流”到了一定的程度的时候,才会一次性的流进或者流出等等,诸如ObjectInputStream和ObjectOutputStream,他们能够直接读写一个Object,但是这个Object被写到了哪里,是内存中的字节数组还是文件文件的文件中,而必须委托给其他管道实现; 4 在网络中传输对象 在网络中的两台机器中传输对象,前提首先是基于同一个平台,这是序列化的基础,所以这里主要有两种做法: l 采用JAVA的序列化机制,将对象“压扁”成二进制字节,将二进制字节在网络中传输; l 自定义协议,将对象用字符串描述出来,将字符串用二进制表示,在网络中传输,在另外一边用相反的策略解析这个字符串,重新构造业务对象,这个方法能够在异构平台中进行传输而不变形,但是需要额外的编写“压扁”和“充气”的代码; 我们这里用第一种方法: package stream.demo; import java.io.ByteArrayInputStream; import java.io.ByteArrayOutputStream; import java.io.File; import java.io.FileInputStream; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.ObjectInputStream; import java.io.ObjectOutputStream; import java.io.OutputStream; import java.util.Date; public class Persistence { public static void main(String[] args) { byte[] bs = Persistence.toBytes(); //在网络中进行传输 Persistence.getBytes(bs); } public static byte[] toBytes() { Person p = new Person(); p.setName("corey"); p.setTall(171); p.setBirthday(new Date()); p.setAddress(new Address("yiyang", "ziyang")); ByteArrayOutputStream out = new ByteArrayOutputStream(); try { ObjectOutputStream oout = new ObjectOutputStream(out); oout.writeObject(p); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } return out.toByteArray(); } public static void getBytes(byte[] bs) { try { ByteArrayInputStream byteIn = new ByteArrayInputStream(bs); ObjectInputStream in = new ObjectInputStream(byteIn); Person p = (Person) in.readObject(); System.out.println(p.getName()); System.out.println(p.getTall()); System.out.println(p.getBirthday()); System.out.println(p.getAddress().getCity()); System.out.print(p.getAddress().getStreet()); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } } } 其中服务端代码片段为: in = this.getRequestSocket().getInputStream(); out = this.getRequestSocket().getOutputStream(); byte[] bs = Persistence.toBytes(); System.out.println("发送数字长度:"+bs.length); out.write(bs); this.getRequestSocket().close(); 客户端代码片段为: InputStream in = request.getInputStream(); byte[] bin = new byte[200]; int length = 0; while ((length = in.read(bin)) != -1) { System.out.println("length:" + length); Persistence.getBytes(bin); }其中,服务端代码和客服端代码都引用了Person 的jar包;
评论
4 楼
xiao_bodian
2012-05-24
我现在有ArrayList<String>,需要用这种方法传输吗?我现在不确定怎么传
3 楼
ywx217
2012-05-16
收获很多,感谢楼主。
2 楼
eason26_li
2010-07-19
youshini 写道
首先谢谢您的分享。在socket中测试了下,发现Date数据类型在接收的时候是null(即接收到的是null,而不是预期的结果)。请问你出现这样的情况吗?麻烦解答下,谢谢。
我这边没问题呀,你的Date是否用得java.util包中的?
1 楼
youshini
2010-06-05
首先谢谢您的分享。在socket中测试了下,发现Date数据类型在接收的时候是null(即接收到的是null,而不是预期的结果)。请问你出现这样的情况吗?麻烦解答下,谢谢。
发表评论
-
Java 7七大新功能预览
2011-03-22 23:09 955Java 7已经完成的7大新功能: 1 对集合类的 ... -
Jprofiler 5.1.2 配置。
2011-01-12 18:18 2770作者:lizongbo 发表于:18:34. 星期一, 三月 ... -
Java关键字之native,strict fp,transient,volatile
2010-11-30 22:08 2157abstract default if ... -
[转]ArrayList Vector LinkedList 区别与用法
2010-09-01 21:37 908最近用到了,所以依然 ... -
流 JAVA IO 基本小结 通过一行常见的代码讨论:new BufferedReader(new InputStreamReader(System.in))
2010-08-12 15:13 1585java的IO是基于流(stream ... -
简述FileInputStream和FileReader的区别
2010-08-12 15:11 1772核心提示:1 ) File 类 ... -
java的转义字符
2010-08-02 13:58 1121点的转义:. ==> u002E 美元符号的转义: ... -
[转]java源代码:POI 操作Excel,创建下拉框
2010-07-28 13:28 1376package poiexcel; import ... -
Socket 网络交互简单示例
2010-01-23 11:22 1406java中的网络信息传输方式是基于TCP协议或者UD协议P的, ... -
DatabaseMetaData和ResultSetMetaData用法实例
2010-01-21 21:15 1840有关DatabaseMetaData的用法 一 、得到这个 ... -
用Java进行网速测试
2010-01-18 10:46 5690命令格式: ping ip地址 ... -
在JAR包中读取图片
2010-01-16 13:19 1562当你编写一个图形界面的程序的时候,你肯定要使用各种图片资源。那 ... -
美国Java程序员薪水调查(为什么外包)
2009-11-15 23:18 6046为什么美国软件会外包 ... -
Java 读取文件
2009-11-12 14:46 1362import java.io.BufferedReader ... -
java获取几天前和几天后的日期
2009-08-04 16:06 4518/** * 得到几天前的时间 * @par ... -
instanceof 的 测试 例子 ( 帮助理解 instance 用法 和 继承 的关键点 )
2009-08-04 09:31 1473//AA是基类 class AA { public void ... -
java反射机制简单例子
2009-08-04 09:29 1182package com.yemaozi.reflect; im ... -
Java如何进阶
2009-07-25 11:56 953Java目前是最流行的语言之一, 是很多公司和程序员喜爱的一门 ... -
java Socket 通讯的代码例子
2009-07-12 12:19 1140实现Client端功能的ClientApp.Java原文件: ...
相关推荐
通过 socket 这种约定,一台计算机可以接收其他计算机的数据,也可以向其他计算机发送数据。 socket 的典型应用就是 Web 服务器和浏览器:浏览器获取用户输入的 URL,向服务器发起请求,服务器分析接收到的 URL,将...
主要介绍了Java Socket实现传输压缩对象的方法,结合具体实例形式分析了java socket针对数据的压缩、传输、接收、解压缩等操作相关实现技巧,需要的朋友可以参考下
1、Java socket 说明及传输协议说明 2、网络编程中两类数据交互 3、两类传输协议:TCP;UDP 4、Socket应用 4.1 Socket编程说明及简单应用 4.2 多线程通信 4.3 实现信息共享:在Socket上的实时交流 4.4 socket ...
* <p>Description: 文件传输接收端 * * <p>Copyright: Copyright (c) 2009 * * <p>Company: 酷猫科技</a></p> * * @author 贺翔 * @version 1.0 */ public class ReveiceThread extends Thread { private ...
UDP 在传送数据之前不需要先建立连接。虽然 UDP 不提供可靠交付,但在某些情况下 UDP 是一种最有效的工作方式。 1. 端到端的传输协议UDP 第13章-Java网络编程-Java面向对象程序设计教程-微课视频版-程杰-清华大学...
主要功能:能友好的用java处理任何发送的C结构体对象,并且能发送java对象转换成C结构体接收的二进制。 功能说明 1、基于spring框架开发 2、对于结构体定义采用可视化XML配置,便于维护与调试,防止协议多次修改带来...
关于数字签名:产生RSA密钥对(myKeyPair),得到RSA密钥对,产生Signature对象,对用私钥对信息(info)签名,用指定算法产生签名对象,用私钥初始化签名对象,将待签名的数据传送给签名对象(须在初始化之后),用公钥...
关于数字签名:产生RSA密钥对(myKeyPair),得到RSA密钥对,产生Signature对象,对用私钥对信息(info)签名,用指定算法产生签名对象,用私钥初始化签名对象,将待签名的数据传送给签名对象(须在初始化之后),用公钥...
UDP是面向非连接的,UDP传输的是数据报只负责传输信息,不保证信息一定收到,虽然安全性不如TCP(面向连接、用Socket进行通信),但是性能较好。 从简单到复杂,首先简单介绍一下怎么利用UDP实现客服端发送消息给...
使用Socket对象进行数据传输 远程端口扫描的实现步骤如下: 创建Socket对象并指定远程主机和端口号 使用Socket对象进行数据传输 可以使用Java的网络编程库Nmap4J来实现更复杂的远程端口扫描,例如发现主机上开放的...
c)使用对象的方式,在服务端和客户端之间传送数据。 3、技术技巧提问 a)服务端如何删除和警告JList中存在的用户? JList中添加对象的方式。通过得到对象中的数据(如ip,线程等),再向该用户发送数据。 b)服务端和...
用到多媒体技术(JAVA 多媒体框架JMF),视频和音频用TRP协议传输,用到Socket编程技术,多播技术。网络视频会议首先是基于网络传输的,那么就必然要依托于JAVA网络编程的相关知识。在这基础上,由于相关音频、视频...
15 applet java可以编写两类程序,applications和applet,applications可以在控制台直接运行,与其他高级编程语言没有太大区别,而java的特色在于它具有编制小应用程序的功能,applet可以在internet上传输并在兼容...
Java 组播组中发送和接受数据实例 Java 飞机订票.rar Java 高考信息管理系统 SQL数据库.rar Java (Jsp)制作简单的表单程序.rar Java+ajax写的登录实例.rar JAVA+JSP的聊天室.rar Java+MsSQL超市进销存(毕业设计及...
关于数字签名:产生RSA密钥对(myKeyPair),得到RSA密钥对,产生Signature对象,对用私钥对信息(info)签名,用指定算法产生签名对象,用私钥初始化签名对象,将待签名的数据传送给签名对象(须在初始化之后),用公钥...
关于数字签名:产生RSA密钥对(myKeyPair),得到RSA密钥对,产生Signature对象,对用私钥对信息(info)签名,用指定算法产生签名对象,用私钥初始化签名对象,将待签名的数据传送给签名对象(须在初始化之后),用公钥...
关于数字签名:产生RSA密钥对(myKeyPair),得到RSA密钥对,产生Signature对象,对用私钥对信息(info)签名,用指定算法产生签名对象,用私钥初始化签名对象,将待签名的数据传送给签名对象(须在初始化之后),用公钥...
关于数字签名:产生RSA密钥对(myKeyPair),得到RSA密钥对,产生Signature对象,对用私钥对信息(info)签名,用指定算法产生签名对象,用私钥初始化签名对象,将待签名的数据传送给签名对象(须在初始化之后),用公钥...
一般的tcp网络编程分为客户端和服务器端,用Socket对象进行客户端与服务器端的数据交流,用IO流技术充当桥梁。本案例详细的阐述了这一过程。
Java既支持各种层次的网络连接,又以Socket类支持可靠的流(stream)网络连接,所以用户可以产生分布式的客户机和服务器。 网络变成软件应用的分布运载工具。Java程序只要编写一次,就可到处运行。 编译和解释性 ...