< 返回技术文档列表

Java 中怎么利用Socket实现网络传输

发布时间:2021-09-01 01:29:03⊙投诉举报

今天就跟大家聊聊有关Java 中怎么利用Socket实现网络传输,可能很多人都不太了解,为了让大家更加了解,小编给大家总结了以下内容,希望大家根据这篇文章可以有所收获。

采用Java Socket网络传输的序列化机制,将对象“压扁”成二进制字节,将二进制字节在网络中传输;

自定义协议,将对象用字符串描述出来,将字符串用二进制表示,在网络中传输,在另外一边用相反的策略解析这个字符串,重新构造业务对象,这个方法能够在异构平台中进行传输而不变形,但是需要额外的编写“压扁”和“充气”的代码;

我们这里用***种方法:

  1. package stream.demo;  

  2. import java.io.ByteArrayInputStream;  

  3. import java.io.ByteArrayOutputStream;  

  4. import java.io.File;  

  5. import java.io.FileInputStream;  

  6. import java.io.FileOutputStream;  

  7. import java.io.IOException;  

  8. import java.io.InputStream;  

  9. import java.io.ObjectInputStream;  

  10. import java.io.ObjectOutputStream;  

  11. import java.io.OutputStream;  

  12. import java.util.Date;  

  13. public class Persistence {  

  14. public static void main(String[] args) {  

  15. byte[] bs = Persistence.toBytes();  

  16. //在网络中进行传输  

  17. Persistence.getBytes(bs);  

  18. }  

  19. public static byte[] toBytes() {  

  20. Person p = new Person();  

  21. p.setName("corey");  

  22. p.setTall(171);  

  23. p.setBirthday(new Date());  

  24. p.setAddress(new Address("yiyang", "ziyang"));  

  25. ByteArrayOutputStream out = new 
    ByteArrayOutputStream();  

  26. try {  

  27. ObjectOutputStream oout = new ObjectOutputStream(out);  

  28. oout.writeObject(p);  

  29. } catch (IOException e) {  

  30. // TODO Auto-generated catch block  

  31. e.printStackTrace();  

  32. }  

  33. return out.toByteArray();  

  34. }  

  35. public static void getBytes(byte[] bs) {  

  36. try {  

  37. ByteArrayInputStream byteIn = new 
    ByteArrayInputStream(bs);  

  38. ObjectInputStream in = new ObjectInputStream(byteIn);  

  39. Person p = (Person) in.readObject();  

  40. System.out.println(p.getName());  

  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) {  

  46. // TODO Auto-generated catch block  

  47. e.printStackTrace();  

  48. }  

  49. }  

其中服务端代码片段为:

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);  }

看完上述内容,你们对Java 中怎么利用Socket实现网络传输有进一步的了解吗?如果还想了解更多知识或者相关内容,请关注血鸟云行业资讯频道,感谢大家的支持。


/template/Home/Zkeys/PC/Static