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

一、定界符成帧

framer接口

package framer;

import java.io.IOException;
import java.io.OutputStream;

public interface framer {
  
  void frameMsg(byte[] message, OutputStream out) throws IOException;

  
  byte[] nextMsg() throws IOException;
}

基于定界符的成帧

package framer;

import java.io.*;


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编程学习--基于定界符的成帧详解整合，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对考高分网网站的支持！