apache mina框架

Question

========服务器端程序======
package com.mina.server;import java.net.InetSocketAddress;import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.transport.socket.SocketAcceptor;
import org.apache.mina.transport.socket.nio.NioSocketAcceptor;/**
 * 简单Mina Server示例
 * 
 */
public class SimpleServer { public static void main(String[] args) throws Exception {
// 创建一个非阻塞的Server端Socket,用NIO
SocketAcceptor acceptor = new NioSocketAcceptor();
// 创建接收数据的过滤器
DefaultIoFilterChainBuilder chain = acceptor.getFilterChain();
// 设定这个过滤器将一行一行(/r/n)的读取数据
chain.addLast("myChin", new ProtocolCodecFilter(
new TextLineCodecFactory()));
// 设定服务器端的消息处理器:一个SamplMinaServerHandler对象,
acceptor.setHandler(new SampleMinaServerHandler());
// 服务器端绑定的端口
//int bindPort = 9988;
int bindPort = 19988;
// 绑定端口,启动服务器
acceptor.bind(new InetSocketAddress(19988));
System.out.println("Mina Server is Listing on:= " + bindPort);
}}
package com.mina.server;import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IoSession;/**
 * 自定议的消息处理器,必须实现IoHandlerAdapter类
 * 
 */
public class SampleMinaServerHandler extends IoHandlerAdapter {
// 当一个客端端连结进入时
@Override
public void sessionOpened(IoSession session) throws Exception {
System.out.println("incomming client : " + session.getRemoteAddress());
} // 当一个客户端关闭时
@Override
public void sessionClosed(IoSession session) {
System.out.println("one Clinet Disconnect !");
} // 当客户端发送的消息到达时:
@Override
public void messageReceived(IoSession session, Object message)
throws Exception {
// 我们己设定了服务器解析消息的规则是一行一行读取,这里就可转为String:
String s = (String) message;
// Write the received data back to remote peer
System.out.println("收到客户机发来的消息: " + s);
// 测试将消息回送给客户端

session.write(s + count);
count++;
} private int count = 0;
}小弟刚刚接触mina，用mina官方提供的服务器、客户端成程序可以通信，但是我自己写了个客户端，与以上的服务器端通信，可以链接，但是 public void messageReceived(IoSession session, Object message) 不能触发，不能执行！着急啊 大哥们为什么啊？

Answer 1

我看了半天，请问下，你的messageReceived在什么地方调用的。
自动执行？也不是在你启动的那个类里面调用或者初始化过？？

Answer 2

// 设定服务器端的消息处理器:一个SamplMinaServerHandler对象,
acceptor.setHandler(new SampleMinaServerHandler());初始化SampleMinaServerHandler，客户端有消失时，mian自动触发messageReceived 

Answer 3

你打开CMD窗口,用telnet localhost 19988测试能不能连接服务器

Answer 4

...MINA很火么...LZ要是有官方文档的话发个给我 一起研究撒

Answer 5

tenlnet  我测试了 可以
 chain.addLast("myChin", new ProtocolCodecFilter(new TextLineCodecFactory()));
我知道了，传输的字符串必须以回车换行结束 \n 服务器端才能收到！
TextLineCodecFactory 这还得研究下啊 为什么呢？

Answer 6

Mina能发送和传输序列化的实体类吗？感觉跟MQ一类的消息中间件很像了

Answer 7

 mina有自带的按固定长度解码解码的么？

Answer 8

mina的编码filter，如果server运用了filter那么在Mina client端也要用到filter,也就是filter在server 和client需要成对出现，只是局限于server 和client都用的是mina技术。如果client不用mina技术的话，只需要在server用mina 应该怎么添加自己的filter ？？？？？？？？？？？？？？