0

私のアプリケーションは、次の構成でリッスンする Apache Mina Server にデータを送信します。


        IoAcceptor acceptor = new NioSocketAcceptor();
        acceptor.getFilterChain().addLast( "logger", new LoggingFilter() );
        //acceptor.getFilterChain().addLast( "logger1", new TempFilter());
        acceptor.getFilterChain().addLast( "codec", new ProtocolCodecFilter( new TextLineCodecFactory( Charset.forName( "UTF-8" ))));
        acceptor.setHandler( new TimeServerHandler() );
        acceptor.getSessionConfig().setReadBufferSize( 2048 );
        acceptor.getSessionConfig().setIdleTime( IdleStatus.BOTH_IDLE, 10 );
        acceptor.bind( new InetSocketAddress(PORT) );

これがnet.Socketで書かれた私のクライアントコードです


OutputStream oStrm = socket.getOutputStream();
byte[] byteSendBuffer = (requests[clientNo][j]).getBytes(Charset.forName("UTF-8"));


oStrm.write(byteSendBuffer);
oStrm.flush();

ロガーの表示メッセージは受信されましたが、サーバー ハンドラmessageRecieved()は呼び出されません。hlp してください。

4

2 に答える 2

1

メッセージが行区切りで終わることを期待するプロトコルコーデックとしてTextLineCodecFactoryを使用しています。System.lineSeparator()これは、UNIXでは「\ n」 、Javaでは取得できるWindowsでは「\ r\n」です。

もちろん、TextLineCodecFactoryの使いやすさは、メッセージの内容によって異なります。メッセージの内容に行区切り文字が含まれている場合、TextLineCodecFactoryを使用することはできません。その場合、区切り文字、固定サイズのメッセージ、またはtype-length-value構造として特殊文字を使用する独自のコーデックファクトリを実装することをお勧めします。

于 2012-12-05T13:50:53.720 に答える
1

これを試して：

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.CharBuffer;
import java.nio.channels.SocketChannel;
import java.nio.charset.Charset;
import java.nio.charset.CharsetEncoder;

public class JavaNetClient {

    public static void main(String[] args) throws IOException {

        Charset charset = Charset.forName("UTF-8");
        CharsetEncoder encoder = charset.newEncoder();

        SocketChannel socketChannel = SocketChannel.open(new InetSocketAddress(
                        "localhost", 1071));
        socketChannel.configureBlocking(false);
        CharBuffer charBuffer = CharBuffer.wrap("Hi\r\n");
        ByteBuffer buf = encoder.encode(charBuffer);
        socketChannel.write(buf);

        socketChannel.close();

    }
}
于 2012-12-05T00:27:56.137 に答える