一、定界符成帧

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