wifisocketandroid,androidwifi热点socket通信

1.首先建立wifi热点服务器  wifi客户端连接

2.开启一个子线程循环监听某个端口&＃xff0c;进行数据流输入输出

/* 服务器 接收数据 */

class Receiver extends Thread {

public String receiverContent;

public boolean flag &＃61; true;

public ServerSocket serverSocket &＃61; null;

public void run() {

try {

// 创建ServerSocket

serverSocket &＃61; new ServerSocket(3358);

while (flag) {

// 接受客户端请求

Socket client &＃61; serverSocket.accept();

System.out.println("accept");

try {

// 接收客户端消息

BufferedReader in &＃61; new BufferedReader(

new InputStreamReader(client.getInputStream()));

receiverContent &＃61; in.readLine();

System.out.println("read:" &＃43; receiverContent);

handler.sendEmptyMessage(0);

// 向客戶端发送消息

PrintWriter out &＃61; new PrintWriter(

new BufferedWriter(new OutputStreamWriter(

client.getOutputStream())), true);

out.println("server message");

// 关闭流

out.close();

in.close();

} catch (Exception e) {

System.out.println(e.getMessage());

e.printStackTrace();

} finally {

// 关闭

client.close();

System.out.println("close");

}

}

} catch (Exception e) {

System.out.println(e.getMessage());

}

}

public void close() {

flag &＃61; false;

if (serverSocket !&＃61; null) {

try {

serverSocket.close();

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

}

}

/* 客户端发送数据 */

class Sender extends Thread {

String serverIp;

String message;

Sender(String serverAddress, String message) {

super();

serverIp &＃61; serverAddress;

this.message &＃61; message;

}

public void run() {

Socket sock &＃61; null;

PrintWriter out;

try {

// 声明sock&＃xff0c;其中参数为服务端的IP地址与自定义端口

sock &＃61; new Socket(serverIp, 3358);

Log.w("WifiConnection", "I am try to writer" &＃43; sock);

} catch (UnknownHostException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

try {

// 向服务器端发送消息

out &＃61; new PrintWriter(new BufferedWriter(

new OutputStreamWriter(sock.getOutputStream())), true);

out.println(message);

// 接收来自服务器端的消息

BufferedReader br &＃61; new BufferedReader(new InputStreamReader(

sock.getInputStream()));

String msg &＃61; br.readLine();

Message m &＃61; handler.obtainMessage();

m.what &＃61; 1;

m.obj &＃61; msg;

handler.sendMessage(m);

// 关闭流

out.close();

out.flush();

br.close();

// 关闭Socket

sock.close();

} catch (Exception e) {

LogUtil.e("发送错误:[Sender]run()" &＃43; e.getMessage());

}

}

}

原文&＃xff1a;http://www.cnblogs.com/lzh-Linux/p/4589946.html