Socket实现手机客户端和PC机服务端通信

手机客户端代码：

package com.example.socket;

import java.io.BufferedWriter;
import java.io.IOException;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.NetworkInterface;
import java.net.Socket;
import java.net.SocketException;
import java.net.UnknownHostException;
import java.util.Enumeration;

import android.app.Activity;
import android.os.Bundle;
import android.view.View;
import android.view.View.OnClickListener;
import android.widget.Button;
import android.widget.EditText;

public class Client extends Activity {
private EditText edittext = null;
private Button send = null;
Socket socket = null;
@Override
public void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.main);
edittext = (EditText) findViewById(R.id.edittext);
send = (Button) findViewById(R.id.send);
send.setOnClickListener(new OnClickListener() {
@Override
public void onClick(View v) {
new Thread(new Runnable() {
@Override
public void run() {
sendMsg();
}
}).start();
}
});
}

// 发送信息
public void sendMsg() {
try {
// 创建socket对象，指定服务器端地址和端口号
socket = new Socket("192.168.1.60", 10000);
// 获取 Client 端的输出流
PrintWriter out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())), true);
// 填充信息
out.println("我是手机用户端"+GetHostIp()+":"+edittext.getText());
System.out.println(GetHostIp()+":" + edittext.getText());
// 关闭

} catch (UnknownHostException e1) {
e1.printStackTrace();
} catch (IOException e1) {
e1.printStackTrace();
} finally {
try {
if(socket==null){
edittext.setText("连接失败");
}else {
socket.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}

}

/**
* @return获取手机ip
*/
private String GetHostIp() {
try {
for (Enumeration<NetworkInterface> en = NetworkInterface
.getNetworkInterfaces(); en.hasMoreElements();) {
NetworkInterface intf = en.nextElement();
for (Enumeration<InetAddress> ipAddr = intf.getInetAddresses(); ipAddr
.hasMoreElements();) {
InetAddress inetAddress = ipAddr.nextElement();
if (!inetAddress.isLoopbackAddress()) {
return inetAddress.getHostAddress();
}
}
}
} catch (SocketException ex) {
} catch (Exception e) {
}
return null;
}
}

权限

<uses-permission android:name="android.permission.INTERNET"></uses-permission>

布局

<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
android:layout_width="match_parent"
android:layout_height="match_parent"
android:orientation="vertical" >

<EditText
android:id="@+id/edittext"
android:layout_width="match_parent"
android:layout_height="wrap_content"
android:ems="10" >

<requestFocus />
</EditText>

<Button
android:id="@+id/send"
android:layout_width="wrap_content"
android:layout_height="wrap_content"
android:text="发送" />

</LinearLayout>

服务端代码：

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;

public class ServerSocketText {

public static void main(String[] args) {
new ServerThread().start();
}
}

// 创建一个线程在后台监听
class ServerThread extends Thread {
ServerSocket serversocket = null;
String msg;

public void run() {
try {
// 创建一个serversocket对象，并让他在Port端口监听
serversocket = new ServerSocket(10000);
while (true) {
// 调用serversocket的accept()方法，接收客户端发送的请求
Socket socket = serversocket.accept();
BufferedReader buffer = new BufferedReader(
new InputStreamReader(socket.getInputStream(), "utf-8"));
// 读取数据
msg = buffer.readLine();
System.out.println(msg);
}

} catch (IOException e) {
e.printStackTrace();
} finally {
try {
serversocket.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}

右键单击服务端ServerSocketText.java->run javaapplication开启服务

把客户端代码运行到手机和模拟器













源码：http://download.csdn.net/detail/gly742279097/8641249