`
qyhdt
  • 浏览: 15304 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

关于mina的文件上传代码示例

MinaJavaApache多线程Socket 
阅读更多
mina传输对象已经不是什么难事，一般啃半天代码就能搞定，但是传输文件似乎不是很容易，之前在论坛上求助过但是没有解决，还是靠自己啃代码解决了文件的上传和下载，以下只是随便测试写的代码供学习用（只是有很多朋友发邮件求代码思路这里我也就公布了，之前一直没有办法上网实在不好意思之前发邮件到qyhdt@sina.com邮箱求解的朋友们，我在这里给你们答案了实在不好意思），希望与大家一起探讨mina更多的强大功能。对于mina我也是个初学者。
首先我们创建一个上传下载公共文件流线程类 
package com.rose.common.frame.mina;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;

/**
 * 用于mina 服务器上传下载
 * 流处理线程公共类
 * @author qiuy
 *
 */
public class IoStreamThreadWork extends Thread{
	public static final int BUFFER_SIZE = 1024*2;
	
	private BufferedInputStream bis;
	private BufferedOutputStream bos;
	
	
	public BufferedInputStream getBis() {
		return bis;
	}

	public void setBis(BufferedInputStream bis) {
		this.bis = bis;
	}

	public BufferedOutputStream getBos() {
		return bos;
	}

	public void setBos(BufferedOutputStream bos) {
		this.bos = bos;
	}

	public IoStreamThreadWork(InputStream in, OutputStream os){
		bis = new BufferedInputStream(in);
		bos = new BufferedOutputStream(os);
	}
	public synchronized void run() {
		byte[] bufferByte = new byte[BUFFER_SIZE];
		int tempData = 0;
		try {
			while((tempData = bis.read(bufferByte)) != -1 ){
				bos.write(bufferByte, 0, tempData);
			}
			try {
				bos.flush();
			} catch (IOException e) {
				e.printStackTrace();
			}
		} catch (IOException e) {
			e.printStackTrace();
		}finally{
			try {
				bos.close();
				bis.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}
}

写一个服务器端 
package com.rose.common.frame.mina;

import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetSocketAddress;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.filter.codec.serialization.ObjectSerializationCodecFactory;
import org.apache.mina.filter.logging.LoggingFilter;
import org.apache.mina.handler.stream.StreamIoHandler;
import org.apache.mina.transport.socket.nio.NioSocketAcceptor;

/**
 * @author qiuy
 * 文件传输服务器
 */
public class MinaFileServer extends StreamIoHandler{
	public static final int PORT = 8888;
	@Override
	public void sessionOpened(IoSession session) {
		System.out.println("客户端连接了:"+session.getRemoteAddress());
		super.sessionOpened(session);
	}

	protected void processStreamIo(IoSession session, InputStream in,OutputStream out) {
		//设定一个线程池
		//参数说明：最少数量3，最大数量6 空闲时间 3秒
		ThreadPoolExecutor threadPool = new ThreadPoolExecutor(3, 6, 3,TimeUnit.SECONDS, 
				//缓冲队列为3
				new ArrayBlockingQueue<Runnable>(3),
				//抛弃旧的任务
				new ThreadPoolExecutor.DiscardOldestPolicy());
		FileOutputStream fos = null;
		File receiveFile = new File("e:\\test.pdf");
		try {
			fos = new FileOutputStream(receiveFile);
		} catch (FileNotFoundException e1) {
			e1.printStackTrace();
		}
		//将线程放入线程池 当连接很多时候可以通过线程池处理
		threadPool.execute(new IoStreamThreadWork(in,fos));
		//直接启动线程 连接很少可以选用下面
//		new IoStreamThreadWork(in,fos).start();
	}
	
	public void createServerStream(){
		//建立一个无阻塞服务端socket 用nio
		NioSocketAcceptor acceptor = new NioSocketAcceptor();
		//创建接收过滤器 也就是你要传送对象的类型
		DefaultIoFilterChainBuilder chain = acceptor.getFilterChain();
		//===========过滤器创建好了就开始设定============
		
		//设定 对象传输工厂
		ObjectSerializationCodecFactory factory = new ObjectSerializationCodecFactory();
		//设定传输最大值
		factory.setDecoderMaxObjectSize(Integer.MAX_VALUE);// 设定后服务器可以接收大数据
		factory.setEncoderMaxObjectSize(Integer.MAX_VALUE);
		chain.addLast("logging", new LoggingFilter());//这个用于打印日志 可以不写
		//设定服务端消息处理器
		acceptor.setHandler(new MinaFileServer());
		InetSocketAddress inetSocketAddress = null;
		try {
			inetSocketAddress = new InetSocketAddress(8888);
			acceptor.bind(inetSocketAddress);
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		System.out.println("文件服务器已经开启："+8888);
	}
	public static void main(String[] args) {
		MinaFileServer server = new MinaFileServer();
		server.createServerStream();
	}
}

再写一个客户端 
package com.rose.common.frame.mina;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetSocketAddress;

import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;
import org.apache.mina.core.future.ConnectFuture;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.filter.codec.serialization.ObjectSerializationCodecFactory;
import org.apache.mina.filter.logging.LoggingFilter;
import org.apache.mina.handler.stream.StreamIoHandler;
import org.apache.mina.transport.socket.nio.NioSocketConnector;


/**
 * @author qiuy
 * 文件传输客户端 
 */
public class MinaFileClient extends StreamIoHandler{
	IoSession session;
	public void setSession(IoSession session) {
		this.session = session;
	}
	public IoSession getSession() {
		return session;  
	}
	@Override
	protected void processStreamIo(IoSession session, InputStream in,
			OutputStream out) {
		//客户端发送文件
			File sendFile = new File("F:\\ttt.pdf");
			FileInputStream fis = null;
			try {
				fis = new FileInputStream(sendFile);
				
			} catch (FileNotFoundException e) {
				e.printStackTrace();
			}
			//放入线程让其执行
			 //客户端一般都用一个线程实现即可 不用线程池
			new IoStreamThreadWork(fis,out).start();
			return;
	}
	
	public void createClienStream(){
		int port = 8888;
		String local = "127.0.0.1";
		
		NioSocketConnector connector = new NioSocketConnector();
		DefaultIoFilterChainBuilder chain = connector.getFilterChain();
		ObjectSerializationCodecFactory factory = new ObjectSerializationCodecFactory();
		factory.setDecoderMaxObjectSize(Integer.MAX_VALUE);
		factory.setEncoderMaxObjectSize(Integer.MAX_VALUE);
		chain.addLast("logging", new LoggingFilter());//用于打印日志可以不写
		connector.setHandler(new MinaFileClient());
		ConnectFuture connectFuture = connector.connect(new InetSocketAddress(local,port));
		connectFuture.awaitUninterruptibly();//写上这句为了得到下面的session 意思是等待连接创建完成 让创建连接由异步变同步
		//后来表明我开始的想法不行 动态依旧不能做到
//		@SuppressWarnings("unused")
//		IoSession session = connectFuture.getSession();
//		setSession(session);
	}
	public static void main(String[] args) {
		MinaFileClient client = new MinaFileClient();
		client.createClienStream();
	}
}

ok以上就可以实现客户端上传文件到服务器端 要是读者朋友想看看效果
代码拷贝后 在自己的f盘下放一个ttt.pdf然后运行服务器端，再运行客户端这样在你的e盘下会多出一个叫test.pdf文件。如果要用到具体工程中请自行封装一下代码。
参考：mina的API，网上相关资料。
4
顶
1
踩
分享到：
| MyEclipse7.0的注册机
评论
9 楼 宛然一笑 2013-03-29  
您好，我想问下如果我在服务器下指定一个上传目录而不是一个文件，这个要怎么实现？自己弄了半天还是没弄出来。您做过吗
8 楼 qyhdt 2011-12-23  
leehawk 写道
您好，我试着用您的例子代码传输一个2.7G的文件，在对本机（127.0.0.1）传输时很顺利，但是在局域网向不同的机器传输时总是出错，错误如下：
Exception in thread "Thread-0" java.lang.OutOfMemoryError: Java heap space
at java.lang.Object.clone(Native Method)
at org.apache.mina.handler.stream.IoSessionOutputStream.write(IoSessionOutputStream.java:67)
at java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:65)
at java.io.BufferedOutputStream.flush(BufferedOutputStream.java:123)
at java.io.FilterOutputStream.close(FilterOutputStream.java:140)
at com.mina.server.IoStreamThreadWork.run(IoStreamThreadWork.java:87)
请问您是否碰到过这种情况，是因为非阻塞方式传输导致的吗？恳请指教，谢谢！

你好 你这个是属于 大数据量传输 java虚拟机内存不够造成的 mina我也好久没有研究了 具体解决思路 就是 把你的文件分割 每次传输很小一部分 要不然 就把你的JVM虚拟机内存调超大 多试试吧
7 楼 leehawk 2011-11-23  
您好，我试着用您的例子代码传输一个2.7G的文件，在对本机（127.0.0.1）传输时很顺利，但是在局域网向不同的机器传输时总是出错，错误如下：
Exception in thread "Thread-0" java.lang.OutOfMemoryError: Java heap space
at java.lang.Object.clone(Native Method)
at org.apache.mina.handler.stream.IoSessionOutputStream.write(IoSessionOutputStream.java:67)
at java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:65)
at java.io.BufferedOutputStream.flush(BufferedOutputStream.java:123)
at java.io.FilterOutputStream.close(FilterOutputStream.java:140)
at com.mina.server.IoStreamThreadWork.run(IoStreamThreadWork.java:87)
请问您是否碰到过这种情况，是因为非阻塞方式传输导致的吗？恳请指教，谢谢！
6 楼 qyhdt 2011-11-07  
ylybbs 写道
protected void processStreamIo(IoSession session, InputStream in,OutputStream out) {  
        //设定一个线程池  
        //参数说明：最少数量3，最大数量6 空闲时间 3秒  
        ThreadPoolExecutor threadPool = new ThreadPoolExecutor(3, 6, 3,TimeUnit.SECONDS,   
                //缓冲队列为3  
                new ArrayBlockingQueue<Runnable>(3),  
                //抛弃旧的任务  
                new ThreadPoolExecutor.DiscardOldestPolicy());  
        FileOutputStream fos = null;  
        File receiveFile = new File("e:\\test.pdf");  
        try {  
            fos = new FileOutputStream(receiveFile);  
        } catch (FileNotFoundException e1) {  
            e1.printStackTrace();  
        }  
        //将线程放入线程池 当连接很多时候可以通过线程池处理  
        threadPool.execute(new IoStreamThreadWork(in,fos));  
        //直接启动线程 连接很少可以选用下面  
//      new IoStreamThreadWork(in,fos).start();  
    }


这处写得是不是有问题，这个ThreadPoolExecutor不用每次调用（有客户端发送字节流）都新建一个实例吧？应该把它作为一个实例变量在构建函数中创建，每新建一个ThreadWork，都放到这个线程池里。

恩 说的对 线程池应该是单例 那会儿也是刚接触mina 写的一个测试的玩应
5 楼 ylybbs 2011-11-04   
protected void processStreamIo(IoSession session, InputStream in,OutputStream out) {  
        //设定一个线程池  
        //参数说明：最少数量3，最大数量6 空闲时间 3秒  
        ThreadPoolExecutor threadPool = new ThreadPoolExecutor(3, 6, 3,TimeUnit.SECONDS,   
                //缓冲队列为3  
                new ArrayBlockingQueue<Runnable>(3),  
                //抛弃旧的任务  
                new ThreadPoolExecutor.DiscardOldestPolicy());  
        FileOutputStream fos = null;  
        File receiveFile = new File("e:\\test.pdf");  
        try {  
            fos = new FileOutputStream(receiveFile);  
        } catch (FileNotFoundException e1) {  
            e1.printStackTrace();  
        }  
        //将线程放入线程池 当连接很多时候可以通过线程池处理  
        threadPool.execute(new IoStreamThreadWork(in,fos));  
        //直接启动线程 连接很少可以选用下面  
//      new IoStreamThreadWork(in,fos).start();  
    }


这处写得是不是有问题，这个ThreadPoolExecutor不用每次调用（有客户端发送字节流）都新建一个实例吧？应该把它作为一个实例变量在构建函数中创建，每新建一个ThreadWork，都放到这个线程池里。
4 楼 qyhdt 2011-10-16  
import org.apache.mina.filter.codec.serialization.ObjectSerializationCodecFactory
keynescao 写道
ObjectSerializationCodecFactory factory
在哪里引用了呢？

import org.apache.mina.filter.codec.serialization.ObjectSerializationCodecFactory
3 楼 keynescao 2011-10-16  
ObjectSerializationCodecFactory factory
在哪里引用了呢？
2 楼 sunofsummer 2011-08-04  
您好 请问你之前提过的一个"一个关于MINA通信方面的问题，文件的传输-----求解"这个问题解决了吗？ 现在我也遇到了类似的问题。 万分感谢
1 楼 tinren 2011-04-12  
谢谢分享
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    mina多线程

    3. **编写示例代码**： - 创建一个简单的服务端程序，例如绑定到3005端口的TCP服务器。 ```java public class Demo1Server { private static Logger logger = Logger.getLogger(Demo1Server.class); private ...

    Android 简单FTP上传文件.zip

    本教程将详述如何使用Java编程语言在Android应用中实现简单的FTP文件上传功能。首先，我们需要了解FTP的基本概念，以及在Android环境中如何设置和使用FTP客户端。 FTP工作原理： FTP基于TCP/IP协议，通过建立两个...

    Apache_Mina-FtpServer_use:使用 Apache_Mina_FTP 服务器

    2. **文件监控**：服务器可以实时监控文件系统的变更，例如文件上传、下载或删除操作，然后根据预设的规则进行响应，如发送通知邮件或执行特定脚本。 3. **全面的账户管理**：Mina FTP Server 允许你创建、修改和...

    JAVA FTP 文件传输 服务端 客户端

    以下是一个简单的FTP客户端上传文件的Java代码示例： ```java import org.apache.commons.net.ftp.FTP; import org.apache.commons.net.ftp.FTPClient; public class FtpTest { public static void main(String[]...

    java版SFTP实现示例（使用jsch）

    `jsch_examples`文件可能包含了JSch库的示例代码，这些代码演示了如何使用JSch进行更复杂的操作，比如处理SFTP会话中的异常、断线重连、文件重命名等。 总的来说，Java版的SFTP实现利用JSch库可以方便地进行文件的...

    JAVA上百实例源码以及开源项目源代码

    Java读写文本文件的示例代码 1个目标文件。 java俄罗斯方块 一个目标文件。 Java非对称加密源码实例 1个目标文件 摘要:Java源码,算法相关,非对称加密 Java非对称加密源程序代码实例，本例中使用RSA加密技术，定义...

    ftp.rar_ftp_ftp java_java ftp

    开发者可能会使用`FTPClient.connect()`建立连接，`FTPClient.login()`进行身份验证，`FTPClient.changeWorkingDirectory()`改变工作目录，`FTPClient.storeFile()`或`FTPClient.retrieveFile()`进行文件上传和下载...

    Java-for-FTP-server.rar_ftp客户端_java ftp server

    Java for FTP server.docx文件可能包含了更具体的代码示例和实现细节，包括如何处理FTP命令、如何进行文件操作等，对于深入学习和实践会有很大帮助。在实际项目中，还可以考虑使用现有的开源FTP服务器库，如Apache ...

    SSH2环境搭建Jar包

    - 文件传输：使用`SftpChannel`或`ScpClient`进行上传和下载文件，需先打开SFTP或SCP会话。 - 远程命令执行：通过`Session`对象的`execCommand()`方法执行远程命令，然后读取输出流获取结果。 4. 示例代码（JSch...

    用Java实现FTP服务器 .rar_FTP服务器_ftp_java ftp_java ftp 服务器_java ftp服务器

    5. **目录和文件操作**：服务器需要处理客户端的目录浏览、文件上传和下载请求。这涉及到文件I/O操作，如读写文件、创建目录、删除文件等。 6. **多线程处理**：为了同时处理多个客户端连接，服务器通常会使用多...

    apache ftpserver笔记

    而“Apache FTP 实用代码.html”可能包含了一些示例代码，方便开发者快速上手。 总的来说，Apache FTPServer和Apache Commons Net是Java开发FTP应用的强大工具，它们提供了一整套解决方案，涵盖了从服务器端配置到...

    ssh2整合完整例子

    在这个“ssh2整合完整例子”中，我们很可能会找到一个关于如何在不同的开发环境中集成SSH2协议的详细示例。SSH2通常用于在服务器之间建立安全的连接，例如进行远程命令执行、文件传输、隧道ing等操作。下面，我们将...

    SSH2整合小案例

    7. **代码示例**： - 以下是一个简单的使用JSch连接并执行命令的Java代码片段： ```java JSch jsch = new JSch(); Session session = jsch.getSession("username", "hostname", 22); session.setPassword(...

    java 代码开发SFTP Drmo

    请注意，以上代码仅为示例，并不适用于生产环境，因为它们缺乏错误处理和安全性考虑。在实际应用中，需要对异常进行妥善处理，并确保遵循最佳安全实践，如使用密钥对认证而非密码。 总之，Java通过JSch库支持SFTP...

    Android开发 FTP服务器测试demo

    同时，可能还会有一个用于展示如何上传和下载文件的示例代码。 在实际应用中，可以扩展这个FTP服务器，例如添加日志记录、错误处理、多线程支持等功能，以满足更复杂的需求。同时，由于Android系统的安全性限制，...

    FTPServer API下载

    下载的"Apache FTPServer的配置与使用API.pdf"文档应该提供了详细的代码示例，包括如何初始化服务器、配置用户、设置监听器，以及如何使用API进行服务器操作。通过阅读这份文档，开发者可以快速理解和应用Apache ...

    java 新的SSH包

    Java SSH（Secure Shell）包通常指的是用于在Java应用程序中实现安全远程...学习新SSH包的文档、示例代码和最佳实践，可以帮助开发者充分利用其功能，避免潜在的问题。同时，定期更新SSH库以保持安全性也是非常必要的。

    java开源包8

    Java文件上传组件 COS FAT文件系统读写类库 fat32-lib fat32-lib 是一个用来读写 FAT 16/32 格式文件系统的纯 Java 类库（纯的）。 Eclipse的HTML格式化插件 Eclipse Tidy Eclipse HTML Tidy 是一款 Eclipse 的...

    java开源包10

    Java文件上传组件 COS FAT文件系统读写类库 fat32-lib fat32-lib 是一个用来读写 FAT 16/32 格式文件系统的纯 Java 类库（纯的）。 Eclipse的HTML格式化插件 Eclipse Tidy Eclipse HTML Tidy 是一款 Eclipse 的...

    SSH2 实例demo

    SSH2（Secure Shell 2）是一种网络协议，用于在不安全的网络上提供安全的远程登录和其他服务。在Java开发中，SSH2框架通常指的是Apache MINA或...记得在学习过程中，结合官方文档和示例代码，以确保理解和使用正确。

Magicbox
Global site tag (gtag.js) - Google Analytics