详解Java的TCP/IP编程学习

详解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){

vmwjhLCDK if (nextByte==-1){

//如果遇到定界符之前就到了流的终点

if (messageBuffer.size()==0){

return null;

}else {

//如果存入缓存区之前有数据，抛出异常

throw new EOFException("Non-empty message without delimiter");

}

}

http:// //将无定界符的字节写入消息缓存区

messageBuffer.write(vmwjhLCDKnexvmwjhLCDKtByte);

}

//将消息缓存区的内容以字节数组的形式返回

return messageBuffer.toByteArray();

}

}

以上所述是给大家介绍的Java的TCP/IP编程学习--基于定界符的成帧详解整合，希望对大家有所帮助，如果大家有任何疑问请给我留言，会及时回复大家的。在此也非常感谢大家对我们网站的支持！

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。