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