Android设备之间通过Wifi通信的示例代码

package com.example.socketserver;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
import android.app.Activity;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.util.Log;
import android.view.Menu;
import android.view.MenuItem;
import android.view.View;
import android.widget.Button;
import android.widget.Toast;
import com.koushikdutta.async.callback.CompletedCallback;
import com.koushikdutta.async.http.WebSocket;
import com.koushikdutta.async.http.WebSocket.StringCallback;
import com.koushikdutta.async.http.libcore.RequestHeaders;
import com.koushikdutta.async.http.server.AsyncHttpServer;
import com.koushikdutta.async.http.server.AsyncHttpServer.WebSocketRequestCallback;
import com.koushikdutta.async.http.server.AsyncHttpServerRequest;
import com.koushikdutta.async.http.server.AsyncHttpServerResponse;
import com.koushikdutta.async.http.server.HttpServerRequestCallback;
public class MainActivity extends Activity {
private Button btnStart;
private ServerSocket serverSocket;
private BufferedReader in;
private PrintWriter out;
private Handler hander = new Handler(){
@Override
public void handleMessage(Message msg) {
// TODO Auto-generated method stub
super.handleMessage(msg);
String s = (String)msg.obj;
Toast.makeText(MainActivity.this, s, Toast.LENGTH_LONG).show();
}
};
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
btnStart = (Button)findViewById(R.id.button1);
btnStart.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
// TODO Auto-generated method stub
new ServerThread().start();//在新线程中启动SocketServer...
}
});    
}
@Override
public boolean onCreateOptionsMenu(Menu menu) {
// Inflate the menu; this adds items to the action bar if it is present.
getMenuInflater().inflate(R.menu.main, menu);
return true;
}
@Override
public boolean onOptionsItemSelected(MenuItem item) {
// Handle action bar item clicks here. The action bar will
// automatically handle clicks on the Home/Up button, so long
// as you specify a parent activity in AndroidManifest.xml.
int id = item.getItemId();
if (id == R.id.action_settings) {
return true;
}
return super.onOptionsItemSelected(item);
}
@Override
protected void onStop() {
// TODO Auto-generated method stub
super.onStop();
}
private class ServerThread extends Thread{
@Override
public void run() {
// TODO Auto-generated method stub
super.run();
try {
//        serverSocket = new ServerSocket(50005);//默认的路由器地址为Address: 192.168.43.1
serverSocket = new ServerSocket(5000);
while (true) {
Socket clientSocket = serverSocket.accept();//阻塞等待处理...
String remoteIP = clientSocket.getInetAddress().getHostAddress();
int remotePort = clientSocket.getLocalPort();
System.out.println("A client connected. IP:" + remoteIP+ ", Port: " + remotePort);  
System.out.println("server: receiving.............");
// 获得 client 端的输入输出流，为进行交互做准备
in = new BufferedReader(new InputStreamReader(
clientSocket.getInputStream()));
out = new PrintWriter(clientSocket.getOutputStream(), false);
// 获得 client 端发送的数据
String tmp = in.readLine();
// String content = new String(tmp.getBytes("utf-8"));
System.out.println("Client message is: " + tmp);
// 向 client 端发送响应数据
out.println("Your message has been received successfully！.");
// 关闭各个流
out.close();
in.close();
Message message = hander.obtainMessage();
message.obj=tmp;
hander.sendMessage(message);
try {
Thread.sleep(100);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}      
}    
}
}

package com.example.serverclient;
import java.io.BufferedInputStream;
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.view.Menu;
import android.view.MenuItem;
import android.view.View;
import android.widget.Button;
public class MainActivity extends Activity {
private Button sendBtn,sendMessageBtn;
private Socket socket;
private PrintStream output;
private BufferedInputStream bufferedInputStream;
private ReadThread readThread;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
sendBtn = (Button) findViewById(R.id.button1);
sendMessageBtn = (Button) findViewById(R.id.button2);
sendBtn.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
// TODO Auto-generated method stub
new Thread(runnable).start();//开启线程
}
});
sendMessageBtn.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
// TODO Auto-generated method stub
sendMessage("hello,i am from client message");
}
});
}
Runnable runnable = new Runnable() {
@Override
public void run() {
// TODO Auto-generated method stub
initClientSocket();
readThread = new ReadThread();
readThread.start();
}
};
public void initClientSocket() {
try {
socket = new Socket("192.168.43.1", 5000);
output = new PrintStream(socket.getOutputStream(), true, "gbk");
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
System.out.println("请检查端口号是否为服务器IP");
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
System.out.println("服务器未开启");
e.printStackTrace();
}
output.println("this is the message from client");
}
public byte[] receiveData() {
if (socket == null || socket.isClosed()) {
try {
socket = new Socket("192.168.43.1", 5000);
} catch (Exception e) {
e.printStackTrace();
}
}
byte[] data = null;
if (socket.isConnected()) {
try {
bufferedInputStream = new BufferedInputStream(socket.getInputStream());
data = new byte[bufferedInputStream.available()];
bufferedInputStream.read(data);
} catch (IOException e) {
e.printStackTrace();
}
} else {
data = new byte[1];
}
return data;
}
private void sendMessage(String str) {
output.println(str);
}
public void closeSocket() {
try {
output.close();
socket.close();
} catch (IOException e) {
System.out.println("error"+e);
}
}
private class ReadThread extends Thread{
@Override
public void run() {
// TODO Auto-generated method stub
super.run();
while (true) {
byte[] data = receiveData();
if (data.length   1) {
System.out.println(new String(data));
}
}
}
}
@Override
public boolean onCreateOptionsMenu(Menu menu) {
// Inflate the menu; this adds items to the action bar if it is present.
getMenuInflater().inflate(R.menu.main, menu);
return true;
}
@Override
public boolean onOptionsItemSelected(MenuItem item) {
// Handle action bar item clicks here. The action bar will
// automatically handle clicks on the Home/Up button, so long
// as you specify a parent activity in AndroidManifest.xml.
int id = item.getItemId();
if (id == R.id.action_settings) {
return true;
}
return super.onOptionsItemSelected(item);
}
}