1

2 つのエミュレーター インスタンスを接続して、それらの間で簡単なチャット メッセージを送信できるようにしたいと考えています。このために、あるエミュレーターにサーバーをセットアップし、他のエミュレーターをクライアントにしました。そこで、エミュレータ 5554 でサーバーを実行し、5556 でクライアントを実行しました。

ポート 6000 でリッスンするサーバー側コード:

public class NewServerActivity extends Activity{
//private TextView tv; 
private Thread fst;
private ServerSocket ss;
public static final int SERVERPORT = 6000; 
String mClientMsg = "";
protected static final int MSG_ID = 0x1337;


@Override
protected void onCreate(Bundle savedInstanceState){
    super.onCreate(savedInstanceState);
    setContentView(R.layout.main);
    TextView tv= (TextView) findViewById(R.id.TextView01);
    tv.setText("Nothing from client yet");
    this.fst= new Thread(new RunThread()); 
    this.fst.start();
}

protected void onStop() {
      super.onStop();
      try {
         // make sure you close the socket upon exiting
         ss.close();
      } catch (IOException e) {
         e.printStackTrace();
      }
   }

Handler myUpdateHandler = new Handler() {
      public void handleMessage(Message msg) {
         switch (msg.what) {
         case MSG_ID:
            TextView tv = (TextView) findViewById(R.id.TextView01);
            tv.setText(mClientMsg);
            break;
         default:
            break;
         }
         super.handleMessage(msg);
      }
   };

class RunThread implements Runnable{
    public void run(){
        try{
            ss= new ServerSocket(); 
            Socket s= ss.accept();
            BufferedReader input = new BufferedReader(new InputStreamReader(s.getInputStream()));

            Message m = new Message();
            m.what = MSG_ID;
            String st = null;
            st = input.readLine();
            mClientMsg = st;
            myUpdateHandler.sendMessage(m);

        }catch(IOException ep){
            ep.printStackTrace();
        }       

    }       
}

}

ポート 5000 で接続を確立するクライアント側コード:

    public class NewClientActivity extends Activity {
private Button bt;
private TextView tv;
private Socket socket;
private Thread scd;
private String serverIpAddress = "10.0.2.2";
private static final int REDIRECTED_SERVERPORT = 5000;

@Override
public void onCreate(Bundle savedInstanceState){
    super.onCreate(savedInstanceState);
    setContentView(R.layout.main);      
     bt = (Button) findViewById(R.id.myButton);
     tv = (TextView) findViewById(R.id.myTextView);
     this.scd= new Thread(new RunThread1()); 
     this.scd.start();
}

class RunThread1 implements Runnable{
    public void run() {
        try {
             //InetAddress serverAddr = InetAddress.getByName(serverIpAddress);
             socket = new Socket(serverIpAddress, REDIRECTED_SERVERPORT);
          } catch (UnknownHostException e1) {
             e1.printStackTrace();
          } catch (IOException e1) {
             e1.printStackTrace();
          }

        bt.setOnClickListener(new OnClickListener() {

             public void onClick(View v) {
                try {
                   EditText et = (EditText) findViewById(R.id.EditText01);
                   String str = et.getText().toString();
                   PrintWriter out = new PrintWriter(new BufferedWriter(
                         new OutputStreamWriter(socket.getOutputStream())),
                         true);
                   out.println(str);
                   Log.d("Client", "Client sent message");                     

                } catch (UnknownHostException e) {
                   tv.setText("Error1");
                   e.printStackTrace();
                } catch (IOException e) {
                   tv.setText("Error2");
                   e.printStackTrace();
                } catch (Exception e) {
                   tv.setText("Error3");
                   e.printStackTrace();
                }
             }
          });
        }       
}

}

ポートを次のようにリダイレクトしました:

     telnet localhost 5554
     redir add tcp:5000:6000

すべて正常に動作し、両方のアプリが起動しますが、送信ボタンをクリックしてもサーバー側で応答がありません。

4

0 に答える 0