客户端:
package com.android.settings;
import java.io.IOException;
import java.io.PrintStream;
import java.net.Socket;
import java.net.UnknownHostException;
import android.app.Activity;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.Toast;
public class BogoclientActivity extends Activity {
private final String SERVER_HOST_IP = "10.0.0.158";
private final int SERVER_HOST_PORT = 9400;
private Button btnConnect;
private Button btnSend;
private EditText editSend;
private Socket socket;
private PrintStream output;
public void toastText(String message) {
Toast.makeText(this, message, Toast.LENGTH_LONG).show();
}
public void handleException(Exception e, String prefix) {
e.printStackTrace();
//toastText(prefix + e.toString());
}
@Override
public void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.xml.client_socket_layout);
initView();
btnConnect.setOnClickListener(new Button.OnClickListener() {
@Override
public void onClick(View v) {
client client = new client();
new Thread(client).start();
}
});
btnSend.setOnClickListener(new Button.OnClickListener() {
@Override
public void onClick(View v) {
sendMessage(editSend.getText().toString());
}
});
}
public void initView() {
btnConnect = (Button) findViewById(R.id.btnConnect);
btnConnect.setText("connect");
btnSend = (Button) findViewById(R.id.btnSend);
btnSend.setText("send");
editSend = (EditText) findViewById(R.id.sendMsg);
editSend.setText("editSend");
btnSend.setEnabled(false);
editSend.setEnabled(false);
}
public void closeSocket() {
try {
output.close();
socket.close();
} catch (IOException e) {
handleException(e, "close exception: ");
}
}
private void initClientSocket() {
try {
socket = new Socket(SERVER_HOST_IP, SERVER_HOST_PORT);
output = new PrintStream(socket.getOutputStream(), true, "utf-8");
Message message = mHandler.obtainMessage();
message.arg1 =1;
mHandler.sendMessage(message);
} catch (UnknownHostException e) {
handleException(e, "unknown host exception: " + e.toString());
} catch (IOException e) {
handleException(e, "io exception: " + e.toString());
}
}
private void sendMessage(String msg) {
output.print(msg);
}
class client implements Runnable{
@Override
public void run() {
// TODO Auto-generated method stub
initClientSocket();
}
}
final Handler mHandler = new Handler(){
@Override
public void handleMessage(Message msg) {
// TODO Auto-generated method stub
super.handleMessage(msg);
btnConnect.setEnabled(false);
editSend.setEnabled(true);
btnSend.setEnabled(true);
}
};
}
服务器端package com.android.settings;
import java.io.IOException;
import java.io.PrintStream;
import java.net.Socket;
import java.net.UnknownHostException;
import android.app.Activity;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.Toast;
public class BogoclientActivity extends Activity {
private final String SERVER_HOST_IP = "10.0.0.158";
private final int SERVER_HOST_PORT = 9400;
private Button btnConnect;
private Button btnSend;
private EditText editSend;
private Socket socket;
private PrintStream output;
public void toastText(String message) {
Toast.makeText(this, message, Toast.LENGTH_LONG).show();
}
public void handleException(Exception e, String prefix) {
e.printStackTrace();
//toastText(prefix + e.toString());
}
@Override
public void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.xml.client_socket_layout);
initView();
btnConnect.setOnClickListener(new Button.OnClickListener() {
@Override
public void onClick(View v) {
client client = new client();
new Thread(client).start();
}
});
btnSend.setOnClickListener(new Button.OnClickListener() {
@Override
public void onClick(View v) {
sendMessage(editSend.getText().toString());
}
});
}
public void initView() {
btnConnect = (Button) findViewById(R.id.btnConnect);
btnConnect.setText("connect");
btnSend = (Button) findViewById(R.id.btnSend);
btnSend.setText("send");
editSend = (EditText) findViewById(R.id.sendMsg);
editSend.setText("editSend");
btnSend.setEnabled(false);
editSend.setEnabled(false);
}
public void closeSocket() {
try {
output.close();
socket.close();
} catch (IOException e) {
handleException(e, "close exception: ");
}
}
private void initClientSocket() {
try {
socket = new Socket(SERVER_HOST_IP, SERVER_HOST_PORT);
output = new PrintStream(socket.getOutputStream(), true, "utf-8");
Message message = mHandler.obtainMessage();
message.arg1 =1;
mHandler.sendMessage(message);
} catch (UnknownHostException e) {
handleException(e, "unknown host exception: " + e.toString());
} catch (IOException e) {
handleException(e, "io exception: " + e.toString());
}
}
private void sendMessage(String msg) {
output.print(msg);
}
class client implements Runnable{
@Override
public void run() {
// TODO Auto-generated method stub
initClientSocket();
}
}
final Handler mHandler = new Handler(){
@Override
public void handleMessage(Message msg) {
// TODO Auto-generated method stub
super.handleMessage(msg);
btnConnect.setEnabled(false);
editSend.setEnabled(true);
btnSend.setEnabled(true);
}
};
}
服务器端: