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

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

   }

}