欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

Java socket字节流传输示例解析

程序员文章站 2024-03-12 20:31:38
本文为大家分享了java socket字节流传输示例,供大家参考,具体内容如下 服务端server端:  package com.yuan.soc...

本文为大家分享了java socket字节流传输示例,供大家参考,具体内容如下

服务端server端: 

package com.yuan.socket;

import java.io.*;
import java.net.serversocket;
import java.net.socket;

/**
 * created by yuan on 2016-09-17.
 */
public class talkserver4byte {
  
  private serversocket server;
  private int port = 5020;

  public talkserver4byte() {
    try {
      server = new serversocket(port);
    } catch (ioexception e) {
    }
  }

  public void talk() {
    system.out.println("监控端口:" + port);
    socket socket = null;
    while (true) {
      try {
        // 阻塞等待,每接收到一个请求就创建一个新的连接实例
        socket = server.accept();
        system.out.println("连接客户端地址:" + socket.getremotesocketaddress());

        // 装饰流bufferedreader封装输入流(接收客户端的流)
        bufferedinputstream bis = new bufferedinputstream(
            socket.getinputstream());

        datainputstream dis = new datainputstream(bis);
        byte[] bytes = new byte[1]; // 一次读取一个byte
        string ret = "";
        while (dis.read(bytes) != -1) {
          ret += bytestohexstring(bytes) + " ";
          if (dis.available() == 0) { //一个请求
            dosomething(ret);
          }
        }

      } catch (ioexception e) {
        system.out.println(e.getmessage());
      } finally {
        try {
          socket.close();
        } catch (ioexception e) {
          system.out.println(e.getmessage());
        }
      }
    }

  }
  
  public static void dosomething(string ret) {
    system.out.println(ret);
  }

  public static string bytestohexstring(byte[] src) {
    stringbuilder stringbuilder = new stringbuilder("");
    if (src == null || src.length <= 0) {
      return null;
    }
    for (int i = 0; i < src.length; i++) {
      int v = src[i] & 0xff;
      string hv = integer.tohexstring(v);
      if (hv.length() < 2) {
        stringbuilder.append(0);
      }
      stringbuilder.append(hv);
    }
    return stringbuilder.tostring();
  }

  public static string byteshexstring(byte[] b) {
    string ret = "";
    for (int i = 0; i < b.length; i++) {
      string hex = integer.tohexstring(b[i] & 0xff);
      if (hex.length() == 1) {
        hex = '0' + hex;
      }
      ret += hex.touppercase();
    }
    return ret;
  }

  public static void main(string[] args) {
    talkserver4byte server = new talkserver4byte();
    server.talk();
  }
}
 

客户端client代码:

package com.yuan.socket;

import java.io.datainputstream;
import java.io.dataoutputstream;
import java.io.ioexception;
import java.io.inputstream;
import java.net.inetsocketaddress;
import java.net.socket;
import java.net.socketaddress;

/**
 * created by yuan on 2016-09-17.
 */
public class talkclient4byte {
  
  private socket socket;
  private socketaddress address;

  public talkclient4byte() {
    try {
      socket = new socket();
      address = new inetsocketaddress("127.0.0.1", 5020);
      socket.connect(address, 1000);
    } catch (ioexception e) {
      e.printstacktrace();
    }

  }

  public void talk() {

    try {

      //使用datainputstream封装输入流
      inputstream os = new datainputstream(system.in);
      
      byte [] b = new byte[1];
      dataoutputstream dos = new dataoutputstream(socket.getoutputstream());
      while (-1 != os.read(b)) {
        dos.write(b); // 发送给客户端
      }
      
      dos.flush();
      dos.close();
    } catch (ioexception e) {
      e.printstacktrace();
    } finally {
      try {
        socket.close();
      } catch (ioexception e) {

      }
    }
  }

  public static void main(string[] args) {
    talkclient4byte client = new talkclient4byte();
    client.talk();
  }

}

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。

上一篇: Seam中查看当前View的ID

下一篇: