详解Java的TCP/IP编程学习--基于定界符的成帧
一、定界符成帧
Framer接口
packageframer;
importjava.io.IOException;
importjava.io.OutputStream;
publicinterfaceFramer{
/**
*添加成帧信息并将指定消息输出到指定流
*@parammessage
*@paramout
*@throwsIOException
*/
voidframeMsg(byte[]message,OutputStreamout)throwsIOException;
/**
*扫描指定的流，从中抽取下一条信息
*@return
*@throwsIOException
*/
byte[]nextMsg()throwsIOException;
}
基于定界符的成帧
packageframer;
importjava.io.*;
/**
*@ClassNameDelimFramer
*@DescriptionTODO
*@AuthorCays
*@Date2019/3/1622:04
*@Version1.0
**/
publicclassDelimFramerimplementsFramer{
//输入流
privateInputStreamin;
//定界符为换行符
privatestaticfinalbyteDELIMITER='\n';
publicDelimFramer(InputStreamin){
this.in=in;
}
@Override
publicvoidframeMsg(byte[]message,OutputStreamout)throwsIOException{
//检测信息中是否包含换行符
for(byteb:message){
if(b==DELIMITER){
thrownewIOException("Messagecontaionsdelimiter");
}
}
//将成帧的信息输出到流中
out.write(message);
//添加定界符
out.write(DELIMITER);
out.flush();
}
@Override
publicbyte[]nextMsg()throwsIOException{
ByteArrayOutputStreammessageBuffer=newByteArrayOutputStream();
intnextByte;
//读取流中的每一个字节，直到遇到定界符
while((nextByte=in.read())!=DELIMITER){
if(nextByte==-1){
//如果遇到定界符之前就到了流的终点
if(messageBuffer.size()==0){
returnnull;
}else{
//如果存入缓存区之前有数据，抛出异常
thrownewEOFException("Non-emptymessagewithoutdelimiter");
}
}
//将无定界符的字节写入消息缓存区
messageBuffer.write(nextByte);
}
//将消息缓存区的内容以字节数组的形式返回
returnmessageBuffer.toByteArray();
}
}
以上所述是小编给大家介绍的Java的TCP/IP编程学习--基于定界符的成帧详解整合，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对毛票票网站的支持！