我正在向 Apache Mina Tcp 服务器和 java.net.Socket 客户端编写一个网络程序
服务器代码
SimpleIoProcessorPool<NioSession> pool = new SimpleIoProcessorPool<NioSession>(NioProcessor.class, 20);
SocketAcceptor acceptor = new NioSocketAcceptor(pool);
acceptor.setReuseAddress(true);
// Add two filters : a logger and a codec
acceptor.getFilterChain().addLast( "logger", new LoggingFilter() );
acceptor.getFilterChain().addLast( "codec", new ProtocolCodecFilter( new TextLineCodecFactory( Charset.forName( "UTF-8" ))));
acceptor.setHandler( new TimeServerHandler() );
// Configurate the buffer size and the iddle time
acceptor.getSessionConfig().setReadBufferSize( 2048 );
acceptor.getSessionConfig().setIdleTime( IdleStatus.BOTH_IDLE, 1 );
acceptor.bind( new InetSocketAddress(8001) );
我的服务器处理程序是，
public class TimeServerHandler extends IoHandlerAdapter{
@Override
public void messageReceived( IoSession session, Object message ) throws Exception
{
System.out.println("messagereceived");
String str = message.toString();
System.out.println(str);
if( str.trim().equalsIgnoreCase("quit") ) {
session.close(true);
return;
}
Date date = new Date();
System.out.println("Writing to client");
session.write( date);
}
}
我的套接字客户端是
InetAddress inetAddress = InetAddress.getByName("localhost");
Socket socket = new Socket(inetAddress, 8001);
BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
bufferedWriter.write("Test");
bufferedWriter.flush();
System.out.println(bufferedReader.readLine());
System.out.println("Done....");
bufferedWriter.close();
bufferedReader.close();
问题是服务器套接字不与 java.net.socket 通信。有人能说听错是什么吗..