0

クライアントがメッセージをサーバーに送信し、サーバーがメッセージを受信するアプリケーションを開発しています。しかし、メッセージを送信している私のアプリケーションでは、サーバーによって一度だけ受信されます。メッセージをサーバーに再度送信する必要がある場合は、アプリケーションを強制的に閉じてから、再度メッセージを送信する必要があります。継続的にサーバーにデータを送信する必要があることを意味します。以下は私のコードです。この問題を解決するのを手伝ってください。

import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.app.Activity;

import android.view.View;
import android.view.View.OnTouchListener;
import android.widget.EditText;
import android.widget.TextView;
import android.widget.TextView.OnEditorActionListener;

public class MainActivity extends Activity {
TextView serverMessage;
Thread m_objThreadClient;
Socket clientSocket;
private boolean connected = false;

EditText et;
    @Override
    public void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        serverMessage=(TextView)findViewById(R.id.textView1);
        et=(EditText)findViewById(R.id.editText1);

    }



  public void Start(View view)
{
     // m_objThreadClient.start();
    m_objThreadClient=new Thread(new Runnable() {
        public void run()
           {

              try
               {

                 clientSocket= new Socket("192.168.0.103",2000);
                 ObjectOutputStream oos = new ObjectOutputStream(clientSocket.getOutputStream());
                 oos.writeObject(et.getText().toString());
                 Message serverMessage= Message.obtain();
                 ObjectInputStream ois =new ObjectInputStream(clientSocket.getInputStream());
                 String strMessage = (String)ois.readObject();
                 serverMessage.obj=strMessage;
                 mHandler.sendMessage(serverMessage);

                 oos.close();
                 ois.close();

              }

              catch(Exception e)
                     {
                         e.printStackTrace();
                     }


          }
            });

    m_objThreadClient.start();
    //m_objThreadClient.resume();

}
Handler mHandler = new Handler() {
    @Override
    public void handleMessage(Message msg) {
        messageDisplay(msg.obj.toString());
    }
};
public void messageDisplay(String servermessage)
{
    serverMessage.setText(""+servermessage);
    m_objThreadClient.start();
}

}
4

2 に答える 2

0

start 関数を再度呼び出すと、ソケットをバインドできます。このケースを検証します。

 if(clientSocket != null && clientSocket.isConnected)clientSocket.close();
  clientSocket= new Socket("192.168.0.103",2000);
于 2013-01-10T06:41:21.640 に答える
0

最初にclientSocketオブジェクトをローカルにします。

次に、ループの問題を解決するには、これを試してください：

関数starteMessageThreadRunnerを呼び出すと、メッセージをサーバーに送信するスレッドが開始され、ランナブルがデータの送信を終了するとすぐに、ハンドラーが再び呼び出され、ハンドラーが再びスレッドを呼び出します。

    /**
         * start the thread and handler which will send the message
         */
        public void starteMessageThreadRunner() {

            Message message = handler.obtainMessage(1, "");
            handler.sendMessage(message);
        }

        /**
         * handler for calling the thread.
         */
        Handler handler = new Handler() {

            public void handleMessage(Message msg) {
                // do something with the response received (if you want to)
                 serverMessage.setText(msg.obj.toString());
                //this line will call runnable again and will send the message to the server.
                handler.post(runnable);

            };
        };


        /**
         * A runnable object for calling the handler.
         */
        private Runnable runnable = new Runnable() {

            @Override
            public void run() {

                // send the message to the server.

try
               {

                 Socket clientSocket= new Socket("192.168.0.103",2000);
                 ObjectOutputStream oos = new ObjectOutputStream(clientSocket.getOutputStream());
                 oos.writeObject(et.getText().toString());
                 Message serverMessage= Message.obtain();
                 ObjectInputStream ois =new ObjectInputStream(clientSocket.getInputStream());


                 String strMessage = (String)ois.readObject();
Message message = handler.obtainMessage(1, strMessage );

                 oos.close();
                 ois.close();
handler.sendMessage(message);
              }

              catch(Exception e)
                     {
                         e.printStackTrace();
                     }



            }
        };

そして、このプロセス呼び出しを終了したい場合:

handler.removeCallbacks(runnable);

メッセージ キューにある Runnable r の保留中の投稿を削除します。

お役に立てれば！

于 2013-01-10T06:41:32.087 に答える