详解Java的TCP/IP编程学习--基于定界符的成帧

一、定界符成帧

framer接口

package framer;

import java.io.ioexception;
import java.io.outputstream;

public interface framer {
  /**
   * 添加成帧信息并将指定消息输出到指定流
   * @param message
   * @param out
   * @throws ioexception
   */
  void framemsg(byte[] message, outputstream out) throws ioexception;

  /**
   * 扫描指定的流，从中抽取下一条信息
   * @return
   * @throws ioexception
   */
  byte[] nextmsg() throws ioexception;
}

基于定界符的成帧

package framer;

import java.io.*;

/**
 * @classname delimframer
 * @description todo
 * @author cays
 * @date 2019/3/16 22:04
 * @version 1.0
 **/
public class delimframer implements framer {
  //输入流
  private inputstream in;
  //定界符为换行符
  private static final byte delimiter='\n';

  public delimframer(inputstream in) {
    this.in = in;
  }

  @override
  public void framemsg(byte[] message, outputstream out) throws ioexception {
    //检测信息中是否包含换行符
    for (byte b:message){
      if (b==delimiter){
        throw new ioexception("message contaions delimiter");
      }
    }
    //将成帧的信息输出到流中
    out.write(message);
    //添加定界符
    out.write(delimiter);
    out.flush();
  }

  @override
  public byte[] nextmsg() throws ioexception {
    bytearrayoutputstream messagebuffer=new bytearrayoutputstream();
    int nextbyte;
    //读取流中的每一个字节，直到遇到定界符
    while ((nextbyte=in.read())!=delimiter){
      if (nextbyte==-1){
        //如果遇到定界符之前就到了流的终点
        if (messagebuffer.size()==0){
          return null;
        }else {
          //如果存入缓存区之前有数据，抛出异常
          throw new eofexception("non-empty message without delimiter");
        }
      }
      //将无定界符的字节写入消息缓存区
      messagebuffer.write(nextbyte);
    }
    //将消息缓存区的内容以字节数组的形式返回
    return messagebuffer.tobytearray();
  }
}

以上所述是小编给大家介绍的java的tcp/ip编程学习--基于定界符的成帧详解整合，希望对大家有所帮助