JAVA技巧：JavaSocket网络传输的序列化基础方法

会计考友

Java Socket网络传输如何才能更好的完成自己的任务？下面我们就来看看有关的代码介绍，希望大家有所收获。在网络中的两台机器中传输对象，前提首先是基于同一个平台，这是序列化的基础，所以这里主要有两种做法：
# V- c* w6 q7 q7 M# V　　采用Java  Socket网络传输的序列化机制，将对象“压扁”成二进制字节，将二进制字节在网络中传输；
　　自定义协议，将对象用字符串描述出来，将字符串用二进制表示，在网络中传输，在另外一边用相反的策略解析这个字符串，重新构造业务对象，这个方法能够在异构平台中进行传输而不变形，但是需要额外的编写“压扁”和“充气”的代码；
　　我们这里用第一种方法：
　　1.package stream.demo;
$ d  h6 Q5 [) G  h- A4 {; m* q* [　　2.import java.io.ByteArrayInputStream;
　　3.import java.io.ByteArrayOutputStream;
& `* K2 U8 J+ ^7 A8 x! t, ?# E　　4.import java.io.File;
' s, v; g" {2 O. N/ _　　5.import java.io.FileInputStream;
- t4 ?) a7 y/ x' G/ c  r　　6.import java.io.FileOutputStream;
% U: {. R9 z: N: b4 b% x  N　　7.import java.io.IOException;
9 i- J7 C/ Y# Y6 T* ]( M' c" O　　8.import java.io.InputStream;
4 x, e" N1 }0 S　　9.import java.io.ObjectInputStream;
　　10.import java.io.ObjectOutputStream;
' H. b: e3 T4 ^" z& t　　11.import java.io.OutputStream;
　　12.import java.util.Date;
) v$ F) A- d( g' l$ _　　13.public class Persistence {
　　14.public static void main(String[] args) {
! N- {: [3 M9 r, w　　15.byte[] bs = Persistence.toBytes();
　　16.//在网络中进行传输
　　17.Persistence.getBytes(bs);
% n% U. t  ?. r  h& i. X* w
　　18.}

会计考友

</p>　　19.public static byte[] toBytes() {
5 a" e3 C/ c5 }　　20.Person p = new Person();
　　21.p.setName("corey");
　　22.p.setTall(171);
　　23.p.setBirthday(new Date());
% v# c7 l9 T/ x+ \0 N, {0 f　　24.p.setAddress(new Address("yiyang", "ziyang"));
　　25.ByteArrayOutputStream out = new
　　ByteArrayOutputStream();
& y8 Y8 F& N9 D2 L* ^% C5 x　　26.try {
　　27.ObjectOutputStream oout = new ObjectOutputStream(out);
　　28.oout.writeObject(p);
3 a7 ?9 d5 @9 c　　29.} catch (IOException e) {
　　30.// TODO Auto-generated catch block
　　31.e.printStackTrace();
　　32.}
7 Y  C& r9 ^9 A; h7 p  t　　33.return out.toByteArray();
　　34.}
7 w9 }  N6 O" ~
; P; c$ c1 M: I4 u
　35.public static void getBytes(byte[] bs) {
　　36.try {
5 c" X; o7 j) d  H* z5 o　　37.ByteArrayInputStream byteIn = new
　　ByteArrayInputStream(bs);
　　38.ObjectInputStream in = new ObjectInputStream(byteIn);
* a" }5 C5 r# ~) W6 b% A　　39.Person p = (Person) in.readObject();
　　40.System.out.println(p.getName());
% Q: F5 G  h* m& A　　41.System.out.println(p.getTall());
　　42.System.out.println(p.getBirthday());
　　43.System.out.println(p.getAddress().getCity());
　　44.System.out.print(p.getAddress().getStreet());
　　45.} catch (Exception e) {
9 N. }; }  y* v2 d- c2 ?$ f# A" g　　46.// TODO Auto-generated catch block
　　47.e.printStackTrace();
　　48.}
* G" y4 Z4 Z0 b( |8 }0 x: N　　49.}
　　50.}
　　其中服务端代码片段为：
' v" n. h2 Y* Y' h7 X　　51.in = this.getRequestSocket().getInputStream();
! o; {3 D4 I/ O. S/ X' w　　52.out = this.getRequestSocket().getOutputStream();