0

私の問題は、1024バイトの区画でサーバーの例「カット」からデータを受信する方法です.2つの部分のようなパケットでサーバーから回答が来ると、それを解決する方法がわかりません。元。最初のパケットが到着したとき、サーバーから通知されたサイズは 1988 であり、受信したサイズは 1444 であり、問​​題ありませんが、2 番目のパケットが到着したとき、通知されたサイズは 808333347 のようなものであり、受信したサイズは 540 で、1444 + 540 = 1984 の合計です。 . この番号 808333347 がどこから来ているのかわかりません。私はこのソリューションをグーグルで検索しており、すべてがudpの使用を教えており、tcp/ip接続にはこれが必要です。私を助けてください、それを解決してください。

クラス：

public class Connection implements Runnable {
    private static  Connection     instance;
    private         SocketChannel  channel        = null;
    private         int            port           = 0;
    private         int            service        = 0;
    private final   int            SOCKET_TIMEOUT = 15 * 1000;
    private final   int            SOCKET_BYTES   = 16 * 1024;
    private final   Charset        CHARSET        = Charset.forName("ISO-8859-1");
    private         String         host           = null; 
    private         String         message        = "";

public Connection(String host, String port){
    this.host       = host;
    this.port       = Integer.parseInt(port);
}
public static Connection createConnection(String host, String port) {
     if(instance == null){
        instance = new Conexao(host, port);
     }
     return instance;
}
public void connect(){
    try{
        instance.channel = SocketChannel.open();
        instance.channel.socket().setSoTimeout(SOCKET_TIMEOUT);
        instance.channel.socket().setTcpNoDelay(false);
        instance.channel.socket().setKeepAlive(true);
        instance.channel.connect(new InetSocketAddress(host, port));
        instance.channel.configureBlocking(false);
    } catch (IOException ioe){
        Log.d(TAG, ioe.getMessage() + " " + ioe.toString());
    }
}
@Override public void run() {
    if(null != instance.channel){
        if(instance.channel.isConnected()){
            Log.d(TAG, "CHANNEL CONNECTED = TRUE");
        } else {
            Log.d(TAG, "CHANNEL CONNECTED = FALSE");
        }
    } else {
        instance.connect();
        Log.d(TAG, "CHANNEL CONNECTED");
    }
    sendMessage();
    while(true){
        receiveMessage();
    }
}
public void sendMessage() {
    int         size    = message.length();
    ByteBuffer  buffer  = ByteBuffer.allocate(4 + 4 + size);
    buffer.putInt(service).putInt(size).put(message.getBytes());
    buffer.flip();
    for(int i = 0; i < size; i++){
        try {
            instance.channel.write(buffer);
        } catch (IOException ioe) {
            Log.d(TAG, ioe.getMessage() + " " + ioe.toString());
        }
    }
}
public void receiveMessage(){
    ByteBuffer  buffer      = ByteBuffer.allocateDirect(SOCKET_BYTES);
    int         bytesReaded = 0;
    String      received    = "";
    buffer.clear();
    try {
        do {
            bytesReaded = instance.channel.read(buffer);
        } while (bytesReaded == 0);
    } catch (IOException ioe) {
        Log.d(TAG, ioe.getMessage() + " " + ioe.toString());
    }
    buffer.flip();
    int size    =  buffer.getInt();
    received    += CHARSET.decode(buffer);
    Log.d(TAG,"SERVIÇE: " + size + "/" + received.length() + " MSG: " + received);
}
public int getService() {
    return service;
}
public void setService(int service) {
    this.service = service;
}
public String getMessage() {
    return message;
}
public void setMessage(String message) {
    this.message = message;
}

私はこのように機能を変更しました：

public void receiveMessage(){
    ByteBuffer  buffer      = ByteBuffer.allocateDirect(SOCKET_BYTES);
    int         bytesReaded = 0;
    String      received    = "";
    buffer.clear();
    try {
        bytesReaded = instance.channel.read(buffer);
    } catch (IOException ioe) {
        Log.d(TAG, ioe.getMessage() + " " + ioe.toString());
    }
    buffer.flip();
    if(bytesReaded >= 4){
        if(size == 0 && size < 5000) size = buffer.getInt();
        received    += CHARSET.decode(buffer);
        answer      += received;
        if(size == answer.length()){
            Log.d(TAG,"SERVICE: " + size + "/" + answer.length() + " " + answer);
        }
    }
}

しかし、今はとても醜いです。

4

2 に答える 2

0

問題は、TCP ではデータの送信方法 (断片化) を制御できないことです。で読み取られるデータの量はわかりませんchannel.read(...)。

ループで呼び出しreceiveMessage()、そこで読み取ったデータをバッファーに入れます。

あなたはそれを確信することはできません

int size    =  buffer.getInt();

受信するメッセージのサイズです (少なくとも 4 バイトを受信する場合は、最初の呼び出しでのみ)。受信した最初の 4 バイトであるサイズを覚えておく必要があります ( を使用しているためgetInt())。次に、size バイトchannel.read(...)を受信するまで覚えておく必要があります。その後、次のメッセージを処理します。

また、バッファを再利用します。あなたはNIO（そしてノンブロッキング）を使用しているselect()ので、忙しい読書の代わりに を使用することもお勧めします。

于 2013-10-06T20:41:53.487 に答える