网上查了堆资料，传送文件名都是写死了的。那如何同时传送文件和文件名？这就要用到Mina 的编码和解码，在刚接触mina的时候，大家可以先看下这个pdf Apache_Mina_Server_2.0中文参考手册V1.0.pdf 这个文档刚开始一般大家都会很容易传送字符串，但是到传送文件就有点难了。
直接介绍编码和解码了：
package com.blazefire.client;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IoSession;
import com.blazefire.bean.BaseMessage;
import com.blazefire.bean.FileBean;
import com.blazefire.util.BeanUtil;
import com.blazefire.util.FileHelper;
public class ClientHandler extends IoHandlerAdapter{
/**
* 客户端接收到信息
* */
public void messageReceived(IoSession session, Object message)
throws Exception {
// TODO Auto-generated method stub
super.messageReceived(session, message);
}
public void sessionOpened(IoSession session) {
BaseMessage baseMessage = new BaseMessage();
baseMessage.setDataType(BeanUtil.UPLOAD_FILE);
FileBean bean = new FileBean();
File file = new File("e:\\中国.jpg");
bean.setFileName(file.getName());
bean.setFileSize((int)file.length());
try {
FileHelper helper =new FileHelper();
bean.setFileContent(helper.getContent(file));
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
baseMessage.setData(bean);
session.write(baseMessage);
}
public void sessionCreated(IoSession session) throws Exception {
// TODO Auto-generated method stub
super.sessionCreated(session);
}
}
在连接成功后，调用sessionOpened方法，读取本地文件，向服务器传送文件，其中用到的一些类将在文章末尾贴出。
传送文件需要文件名，文件大小，文件byte数组： 文件名这个不用说，文件大小是为了解码的时候知道读取到哪个字节就可以停止了。文件byte数组 存储文件内容
BaseMessage baseMessage = new BaseMessage();
baseMessage.setDataType(BeanUtil.UPLOAD_FILE);//BeanUtil.UPLOAD_FILE值为1
准备好这些信息之后，调用session.write方法开始编码。
package com.blazefire.util;
import java.nio.charset.Charset;
import org.apache.mina.core.buffer.IoBuffer;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.filter.codec.ProtocolEncoderOutput;
import org.apache.mina.filter.codec.demux.MessageEncoder;
import com.blazefire.bean.BaseMessage;
import com.blazefire.bean.FileBean;
public class BaseMessageEncoder implements MessageEncoder<BaseMessage> {
/**
* 基本信息编码
* */
public void encode(IoSession session, BaseMessage message,ProtocolEncoderOutput outPut) throws Exception {
// TODO Auto-generated method stub
IoBuffer buffer = IoBuffer.allocate(1024*1024*50);
buffer.putInt(message.getDataType());
FileBean bean = (FileBean) message.getData();
byte[] byteStr = bean.getFileName().getBytes(BeanUtil.charset);
buffer.putInt(byteStr.length);
buffer.putInt(bean.getFileSize());
buffer.put(byteStr);
buffer.put(bean.getFileContent());
buffer.flip();
outPut.write(buffer);
System.out.println("编码完成！");
}
}buffer.putInt(message.getDataType());首先放入了一个int值1 放入这个值，主要是因为这个项目要用到多个解码器，针对不同的信息进行不同的编码，在解码的时候会根据这个参数来判断是否要用这个解码器来解码。
byte[] byteStr = bean.getFileName().getBytes(BeanUtil.charset); 将字符串转换成byte数组，BeanUtil.charset Charset charset = Charset.forName("utf-8"); utf-8编码
buffer.putInt(byteStr.length); 记录文件名的byte数组长度
buffer.putInt(bean.getFileSize()); 记录文件的byte数组长度
buffer.put(byteStr); 存入到buffer
buffer.put(bean.getFileContent());存入到buffer
编码就到此完成了。
现在开始服务器的解码：
package com.blazefire.util;
import java.io.File;
import java.io.FileOutputStream;
import java.nio.charset.Charset;
import org.apache.mina.core.buffer.IoBuffer;
import org.apache.mina.core.session.AttributeKey;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.filter.codec.CumulativeProtocolDecoder;
import org.apache.mina.filter.codec.ProtocolDecoderOutput;
import org.apache.mina.filter.codec.demux.MessageDecoder;
import org.apache.mina.filter.codec.demux.MessageDecoderResult;
import com.blazefire.bean.BaseMessage;
import com.blazefire.bean.FileBean;
public class BaseMessageDecoder implements MessageDecoder {
private AttributeKey CONTEXT = new AttributeKey(getClass(), "context");
/**
* 是否适合解码
* */
public MessageDecoderResult decodable(IoSession session, IoBuffer in) {
// TODO Auto-generated method stub
Context context = (Context) session.getAttribute(CONTEXT);
if(context == null){
context = new Context();
context.dataType = in.getInt();
if(context.dataType == BeanUtil.UPLOAD_FILE){
context.strLength = in.getInt();
context.byteStr = new byte[context.strLength];
context.fileSize = in.getInt();
context.byteFile = new byte[context.fileSize];
session.setAttribute(CONTEXT, context);
return MessageDecoderResult.OK;
}else{
return MessageDecoderResult.NOT_OK;
}
}else{
if(context.dataType == BeanUtil.UPLOAD_FILE){
return MessageDecoderResult.OK;
}else{
return MessageDecoderResult.NOT_OK;
}
}
}
/**
* 数据解码
* */
public MessageDecoderResult decode(IoSession session, IoBuffer in,
ProtocolDecoderOutput outPut) throws Exception {
// TODO Auto-generated method stub
System.out.println("开始解码：");
Context context = (Context) session.getAttribute(CONTEXT);
if(!context.init){
context.init = true;
in.getInt();
in.getInt();
in.getInt();
}
byte[] byteFile = context.byteFile;
int count = context.count;
while(in.hasRemaining()){
byte b = in.get();
if(!context.isReadName){
context.byteStr[count] = b;
if(count == context.strLength-1){
context.fileName = new String(context.byteStr,BeanUtil.charset);
System.out.println(context.fileName);
count = -1;
context.isReadName = true;
}
}
if(context.isReadName && count != -1){
byteFile[count] = b;
}
// byteFile[count] = b;
count++;
}
context.count = count;
System.out.println("count:"+count);
System.out.println("context.fileSize:"+context.fileSize);
session.setAttribute(CONTEXT, context);
if(context.count == context.fileSize){
BaseMessage message = new BaseMessage();
message.setDataType(context.dataType);
FileBean bean = new FileBean();
bean.setFileName(context.fileName);
bean.setFileSize(context.fileSize);
bean.setFileContent(context.byteFile);
message.setData(bean);
outPut.write(message);
context.reset();
}
return MessageDecoderResult.OK;
}
/**
*
* */
public void finishDecode(IoSession session, ProtocolDecoderOutput outPut)
throws Exception {
// TODO Auto-generated method stub
System.out.println("end:::::::::::::::::");
}
private class Context{
public int dataType;
public byte[] byteFile;
public int count;
public int strLength;
public boolean isReadName;
public int fileSize;
public byte[] byteStr;
public String fileName;
public boolean init = false;
public void reset(){
dataType = 0;
byteFile = null;
count = 0;
strLength = 0;
isReadName = false;
fileSize = 0;
byteStr = null;
fileName = null;
}
}
}
decodable方法就是判断是否要用当前这个解码器
如果你看过上面提到的pdf中 对于这个CumulativeProtocolDecoder解码器的一些介绍和使用，特别是复杂的解码器的说明这块
你就会知道为什么这里会用到CONTEXT 这个属性，因为编码的时候，文件内容较长，分成了许多数据包，这个时候在解码的时候就需要记录解码到那个字节，下次再解码的时候就从这个字节开始。
这里需要说下注意点 当前解码器实现的是MessageDecoder这个接口。而pdf中解码器是继承CumulativeProtocolDecoder这个类。
CumulativeProtocolDecoder这个类 在doDecode方法中需要自己去判断是否需要继续调用doDecode这个方法来完成解码。如果还需要数据解码，这返回值为true,如果解码已完成则直接返回false.
而MessageDecoder这个接口不需要自己去判断
这个类会自己调用自己来将数据传送完，所以每次都会调用这个类里面的方法，每次都会将成员变量初始化.
解码这块主要是解决多个数据包的解码拼成一条完成的消息，这个问题解决了，就没有啥难题了。
if(!context.init){
context.init = true;
in.getInt();
in.getInt();
in.getInt();
}
加这个是将那些传入的整数字节读取掉，只剩下文件名的字节和文件字节。
读取完之后，记得重置context的值，否则将影响后续文件的读取。
处理完这些之后，就是直接写文件了。
package com.blazefire.server;
import java.io.FileOutputStream;
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IoSession;
import com.blazefire.bean.BaseMessage;
import com.blazefire.bean.FileBean;
public class ServerHandler extends IoHandlerAdapter{
public void sessionCreated(IoSession session) throws Exception {
// TODO Auto-generated method stub
super.sessionCreated(session);
}
public void sessionOpened(IoSession session) throws Exception {
// TODO Auto-generated method stub
super.sessionOpened(session);
}
/**
* 服务器接收到消息
* */
public void messageReceived(IoSession session, Object message)
throws Exception {
// TODO Auto-generated method stub
super.messageReceived(session, message);
System.out.println("==============");
BaseMessage baseMessage = (BaseMessage) message;
FileBean bean = (FileBean) baseMessage.getData();
System.out.println(bean.getFileName());
FileOutputStream os = new FileOutputStream("f:\\"+bean.getFileName());
os.write(bean.getFileContent());
os.close();
}
public void exceptionCaught(IoSession session, Throwable cause)
throws Exception {
// TODO Auto-generated method stub
super.exceptionCaught(session, cause);
}
}
mina这块刚开始对编码解码也不是很熟悉，后来还是根据别人的代码，自己测试才最终出了这个版本。本只想让大家自己自己动手做出来，这样也可以更深入了解。为了方便大家，还是贴下源码算了。
源码下载
分享到：
相关推荐
本文将围绕"MINA上传文件和文件名"这一主题，深入探讨MINA的核心特性、文件上传的实现机制以及如何处理文件名。 MINA的核心特性包括非阻塞I/O、事件驱动的架构、多线程模型和丰富的缓冲区管理。非阻塞I/O使得MINA...
在"Mina文件及字符串传输"这个场景中，我们可以理解为利用Mina框架实现了一种服务，允许客户端通过发送字符串请求来获取服务器上的文件。这种功能在分布式系统、文件共享或者远程操作等场景中非常常见。下面我们将...
在本案例中，客户端将通过Socket连接到Mina服务端，发送文件请求，并传输文件内容。 三、Mina服务端实现 1. 初始化IoAcceptor：Mina服务端首先需要创建一个IoAcceptor实例，用于监听特定端口的连接请求。通常使用...
4. **数据传输**: 文件数据被分块并通过网络传输，Mina的Filter链在此过程中进行数据的编码和解码。同时，Handler监听Read事件，逐块接收文件内容。 5. **保存文件**: 服务器端Handler接收到每个数据块后，将其累积...
在压缩包子文件的文件名“M2M”中，通常M2M代表Machine-to-Machine通信，这可能是指使用MINA来实现设备之间的数据交换，例如在物联网（IoT）环境中。MINA的灵活性和可扩展性使得它适合于处理各种设备间的通信需求，...
**基于Mina的开源文件传输软件** Mina（Minimum Asynchronous Network）是一个高度可扩展的、高性能的网络应用开发框架，主要用于构建网络服务，如FTP（文件传输协议）服务器。这个开源项目允许开发者使用Java NIO...
如果是压缩文件名，那么解压后可能会得到一个包含多个jar的结构，这些jar共同构成了完整的Mina运行环境。 为了使用这个压缩包，你需要将其解压到合适的位置，然后在你的项目中添加对应的类路径引用。对于Java项目，...
"mina2_echo_server_udp" 这个文件名暗示了这是MINA2框架的一个Echo服务器，其功能可能是接收来自客户端的UDP数据包，然后原样返回，这是验证网络通信的一种常见方式。 **详细知识点讲解：** 1. **UDP协议**：UDP...
标题“mina发布所有jar包”表明我们将探讨MINA项目的全套JAR文件，这些文件包含了运行和开发基于MINA的应用所需的所有组件。 描述中提到“包含操作文档”，意味着除了核心库之外，压缩包可能还包含了使用和配置MINA...
通过`MINAtest_android1`这个文件名，我们可以推测这是一个用于测试MINA框架在Android环境中的示例项目。在这个项目中，可能包含了配置MINA、处理网络连接、数据交换以及处理乱码和连接稳定性等各个方面的问题。通过...
在压缩包文件名列表中，只有“sshd”这一项，可能包含了修改后的源代码、配置文件、示例或者测试用例。为了进一步理解这个修改版，你需要查看这些文件，包括阅读源代码，理解修改之处，以及运行测试以评估其行为。 ...
"apache-mina-2.2.1"这个文件名可能是MINA框架的主目录，包含了库文件、示例代码、文档和其他相关资源。 在Apache MINA框架中，主要涉及的知识点包括： 1. **异步事件驱动模型**：MINA使用非阻塞I/O模型，通过事件...
在压缩包内的文件名列表中，我们看到有"mina"，这很可能包含了关于如何使用Mina的示例代码、文档或者其他资源。"H1"和"A"可能是其他相关的文件，可能是教程、测试脚本或者是Mina项目的特定部分。而"H"可能代表的是...
在MINA中，Socket被用来建立和维护客户端和服务器之间的连接，传输数据。 3. **非阻塞I/O**：MINA采用非阻塞I/O模式，这意味着当等待数据时，程序可以继续执行其他任务，而不是被迫等待，从而提高系统效率。 4. **...
JavaSSH框架，通常指的是Java实现的安全 Shell (SSH) 库，它允许开发者在Java应用程序中进行远程系统操作，如执行命令、传输文件等。SSH是一种网络协议，用于提供安全的远程登录和其他网络服务，比如SFTP（Secure ...
MINA-master这个文件名可能是项目源代码的根目录，里面可能包含了服务端和客户端的实现，包括配置文件、CMPP协议解析类、MINA的网络事件处理器等组件。深入研究这个项目，可以学习到如何利用MINA实现与CMPP协议的...
文件名"springwith-mina"可能包含了一个示例项目，演示了如何在Spring中集成Mina。这个项目可能包含了配置文件、Mina服务器的实现以及相关的业务逻辑。通过研究这个项目，你可以更深入地理解Spring和Mina如何协同...
同时，他们也需要熟悉该库提供的API，学习如何创建SSH连接、执行远程命令、传输文件等操作。对于Java开发者，可能需要阅读JSch或Apache MINA的官方文档，了解如何配置和初始化SSH会话，处理认证和异常等问题。对于...
开发者需要注意在不同操作系统和文件系统之间可能存在的编码差异，确保文件名正确传输。 Apache FTPServer还支持通过插件机制扩展功能，例如，可以通过`UserManager`插件来管理用户账户，通过`CommandHandler`插件...
根据压缩包子文件的文件名称列表，虽然没有具体的文件名给出，但我们可以推测其中可能包含了如JSch、Apache MINA、OpenSSH等实现SSH2的Java库。JSch是一个纯Java实现的SSH2库，允许开发者在Java应用中实现SSH2的会话...