Mina文件及字符串传输

package server; import org.apache.mina.core.service.IoHandlerAdapter; import org.apache.mina.core.session.IoSession; import com.FileRequest; import com.FileResponse; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.IOException; import java.nio.ByteBuffer; import java.nio.channels.FileChannel; /** * 文件传输服务端业务处理类 * @author wuzongan * @version 1.0 * @created 2011-3-14 下午06:36:55 */ public class FileServerIoHandler extends IoHandlerAdapter { /*服务端接收到的文件名*/ private String fileName ; public String getFileName() { return fileName; } public void setFileName(String fileName) { this.fileName = fileName; } private static Logger LOGGER = LoggerFactory.getLogger(FileServerIoHandler.class); public void sessionOpened(IoSession session) throws Exception { } public void exceptionCaught(IoSession session, Throwable cause) throws Exception { LOGGER.warn(cause.getMessage(), cause); } /** * 服务端接收类 * @param session * @param message * @throws Exception * @see org.apache.mina.core.service.IoHandlerAdapter#messageReceived(org.apache.mina.core.session.IoSession, java.lang.Object) */ @Override public void messageReceived(IoSession session, Object message) throws Exception { FileRequest fr = (FileRequest) message; System.out.println("服务端接收到数据："+fr.getFileName()); setFileName(fr.getFileName()); fileName = "F:\\"+fileName; FileInputStream fis = null; try{ fis = new FileInputStream(fileName); }catch(FileNotFoundException e){ System.out.println("请求文件不存在"); /*FileResponse frs = new FileResponse(null, "请求文件不存在"); session.write(frs);*/ //session.write("请求文件不存在"); } ByteBuffer bf = getFileContents(fis); FileResponse frs = new FileResponse(bf, null); session.write(frs); } /** * 根据文件流得到文件的ByteBuffer * @param fis * @return * @throws IOException */ public ByteBuffer getFileContents(FileInputStream fis) throws IOException{ // 得到文件通道 FileChannel fc = fis.getChannel(); // 指定大小为 20MB的缓冲区 ByteBuffer bf = ByteBuffer.allocate(1024*1000*20); while (fc.read(bf) != -1) { //把缓冲中当前位置回复为零，前把缓冲区的 limit 设置为之前 position 值 bf.flip(); // 输出缓冲区中的内容 while (bf.hasRemaining()) { bf.get(); //System.out.print((char) bf.get()); } break; // 清理缓冲区，准备再次读取数据 //bf.clear(); } return bf; } }