当前位置：文江博客话题详情

Mina2.0的上传文件时如何实现的请各位大侠指导下

发布于 2021-11-09 21:34:58 字数 425 浏览 818 评论 7

譬如我A主机要传输一个 teacher.rmvb文件去 B主机 B是服务端请问这个代码如何能写呢谢谢各位大侠了

我的邮箱qyhdt@sina.com

还有就是在传输对象过程中我设定了

factory.setDecoderMaxLineLength(Integer.MAX_VALUE);

factory.setEncodeMaxLineLength(Integer.MAX_VALUE);

有时候还是报异常 bufferdateexception 这个事怎么回事呢

谢谢各位阅读了最近弄这个弄的好辛苦啊

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

你曾走过我的故事 2021-11-16 04:00:29

请看这个例子：

mina的 StreamIoHandler

文章分类:Java编程

最近看上了mina,其性能多多，完全不用说了。。,本来是想搞个file+msg传输的，结果。。被这个handler给 block 了，不知道这个东西扎用。。。按其Iohandler interface implement methods+ processStreamIo abstract method 写了一个sample，发现死活发不了包。。。哥怒了。

没办法，开源的东西还是有好处地，可以深入，下了源码，发现其结构真的很不错，IoService(类似与和customer communication 的一个接口: session )<==IoProcessor(这个好象在code business 的时候没看到，后来才知道是用于处理IoFilter 的)<===IoFilter（*） ,IoHandler（business handler）。

原来，StreamIoHandler 的里面wrap 了两个内部out,in,并且对IoHandler 的每个method 都做了实现，迷底马上揭晓了。。。see the blew:

Java代码

@Override
public void sessionOpened(IoSession session) {
// Set timeouts
session.getConfig().setWriteTimeout(writeTimeout);
session.getConfig().setIdleTime(IdleStatus.READER_IDLE, readTimeout);
// Create streams
InputStream in = new IoSessionInputStream();
OutputStream out = new IoSessionOutputStream(session);
session.setAttribute(KEY_IN, in);
session.setAttribute(KEY_OUT, out);
processStreamIo(session, in, out);
}

    @Override
    public void sessionOpened(IoSession session) {
        // Set timeouts
        session.getConfig().setWriteTimeout(writeTimeout);
        session.getConfig().setIdleTime(IdleStatus.READER_IDLE, readTimeout);

        // Create streams
        InputStream in = new IoSessionInputStream();
        OutputStream out = new IoSessionOutputStream(session);
        session.setAttribute(KEY_IN, in);
        session.setAttribute(KEY_OUT, out);
        processStreamIo(session, in, out);
    }

划克，把processStreamIo template method 了。。（PS：曾经偶在写portal 里用到过这种pattern）

然后其他的iohandler 的method 里面也全写满了io logic....最后session closed 才把in ,out stream close .

我想，这样一来应该每传一个文件就回connect 一次了。。

费话说完了。。code ==>

Java代码

回复收藏 0