我的服务器端是这样设置的:
IoAcceptor acceptor = new SocketAcceptor();
IoAcceptorConfig config = new SocketAcceptorConfig();
DefaultIoFilterChainBuilder chain = config.getFilterChain();
chain.addLast( "codec" , new StreamWriteFilter() );
chain.addLast( "threadPool" , new ExecutorFilter( Executors.newCachedThreadPool() ) );
acceptor.bind( new InetSocketAddress( port ) , new MyIoHandlerAdapter() , config );
MyIoHandlerAdapter的messageReceived是这样的:
ByteBuffer buf = (ByteBuffer)message;
byte[] sbuf = new byte[buf.limit()];
buf.get( sbuf );
log.debug( "\n Received Message:\n " + new String( sbuf ) );
我在做一个小型的HTTP代理服务器的时候,有时候发送较长的请求(cookie很长或手机模拟器发出的信息accept信息较长)的时候,messageReceived可能会执行两次,两次拼起来的数据才是完整的请求头。但是做Http代理的话,我得需要获取完整的请求头后才能解析请求头并链接相应的主机,其中也包含一些业务逻辑的处理。
第一次使用mina(1.1.7),请问各位高手mina有没有什么设置可以让其一次性读取完请求头。如果mina本身不能办到,也希望能给我点建议,用别的方法去达到这种效果。(先存起来,等到有两个回车换行就说明读完了。可是如果是多人在访问呢?会不会造成消息混乱呢?)
谢谢大家!
你好,mina本身提供一个textlinedecoder,如果你的消息是以/r/n结尾的话,这个decoder是会帮你截取一个完成消息的。但如果你的消息不是以/r/n结尾的话,需要你实现自己的decoder(实现ProtocolCodecFactory这个接口,然后把这个decoder加到filter里面。例如:cfg.getFilterChain().addLast("codec", new ProtocolCodecFilter(decoder));)
兄弟, 我没有搞过MINA. 但是, 从网络角度来说. 你就是一次发送数据, 也可能被拆包的. 你是不可能每次都一次性读到数据的. 所以, 一次请求过程中, 需要你自己识别HTTP请求的结束, 或者头的结束. HTTP协议一般要求你读完数据, 再进行整个数据的分析的. 你应该如果你实现HTTP的交互, 应该看看HTTP协议的实现. 自己瞎搞, 可能造成比较多的问题.
mina没有实现http协议的SERVER? 我记得好象有了吧. 如果有, 直接用他提供的实现好了. 这个我不是很清楚.
有点难呀,没做过
如果请求较长的话,可以将一个请求分成两次处理,处理结果放到session的attribute中,等到第二次messageReceived时,从session的attribute中取出前一次的结果,拼成一个完成的message,然后再处理你的业务逻辑。
这个需要你自己实现Codec的filter,或者用mina自带的http的codec。