package aw.com.wifi_connect_server;
import android.app.Activity;
import android.content.Context;
import android.net.ConnectivityManager;
import android.net.NetworkInfo;
import android.net.wifi.WifiInfo;
import android.net.wifi.WifiManager;
import android.os.Handler;
import android.os.Message;
import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.view.View;
import android.widget.EditText;
import android.widget.TextView;
import android.widget.Toast;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class MainActivity extends AppCompatActivity {
private TextView server_ip_port;
private TextView client_ip_port;
private TextView sendData;
private String msg_send;
private EditText message;
private ServerSocket serverSocket = null;
StringBuffer stringBuffer = new StringBuffer();
private InputStream inputStream;
private String IP=null;
private int Port=0;
private String clientIp;
private int clientPort;
private Socket socket = null;
public Handler handler = new Handler(){
@Override
public void handleMessage(Message msg) {
//super.handleMessage(msg);
switch (msg.what){
case 1:
server_ip_port.setText(msg.obj.toString());
break;
case 2:
message.setText(msg.obj.toString());
stringBuffer.setLength(0);
break;
case 3:
client_ip_port.setText(msg.obj.toString());
break;
}
}
};
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
server_ip_port = (TextView) findViewById(R.id.server);
client_ip_port = (TextView) findViewById(R.id.client);
message = (EditText) findViewById(R.id.message_get);
sendData = (EditText) findViewById(R.id.send_data);
receiveData();
}
/*
服务器端接收数据
需要注意以下一点：
服务器端应该是多线程的，因为一个服务器可能会有多个客户端连接在服务器上；
*/
private void receiveData() {
Thread thread = new Thread(){
@Override
public void run() {
super.run();
/*指明服务器端的端口号*/
try {
serverSocket = new ServerSocket(8091);
} catch (IOException e) {
e.printStackTrace();
}
if (serverSocket!=null && !serverSocket.isClosed()){
Port = serverSocket.getLocalPort();
}
WifiManager wifiManager = (WifiManager) getSystemService(Context.WIFI_SERVICE);
int state = wifiManager.getWifiState();
if (state == 3) {
WifiInfo info = wifiManager.getConnectionInfo();
IP = intIP2StringIP(info.getIpAddress());
Message message_1 = handler.obtainMessage();
message_1.what = 1;
message_1.obj = "IP:" + IP + " PORT: " + Port;
handler.sendMessage(message_1);
while (true) {
try {
if (serverSocket != null && !serverSocket.isClosed()) {
socket = serverSocket.accept();
clientIp = socket.getInetAddress().toString();
clientIp = clientIp.substring(1,clientIp.length());
clientPort = socket.getPort();
Message message_3 = handler.obtainMessage();
message_3.what = 3;
message_3.obj = "IP:" + clientIp + " PORT:" + clientPort;
handler.sendMessage(message_3);
inputStream = socket.getInputStream();
new ServerThread(socket, inputStream).start();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
};
thread.start();
}
private String intIP2StringIP(int ip) {
return (ip & 0xFF) + "." + ((ip >> 8) & 0xFF) + "." + ((ip >> 16) & 0xFF) + "." + ((ip >> 24) & 0xFF);
}
public void send(View view){
msg_send = sendData.getText().toString();
if (msg_send.isEmpty()){
Toast.makeText(MainActivity.this, "Please input Sending data", Toast.LENGTH_SHORT).show();
}
msg_send = msg_send + "\0";
Thread thread = new Thread() {
@Override
public void run() {
super.run();
try {
OutputStream outputStream = socket.getOutputStream();
outputStream.write(msg_send.getBytes());
} catch (IOException e) {
e.printStackTrace();
}
}
};
thread.start();
}
class ServerThread  extends Thread{
private Socket socket;
private InputStream   inputStream;
private StringBuffer stringBuffer = MainActivity.this.stringBuffer;
public ServerThread(Socket socket,InputStream inputStream){
this.socket = socket;
this.inputStream = inputStream;
}
@Override
public void run() {
int len;
byte[] bytes = new byte[20];
boolean isString = false;
try {
//在这里需要明白一下什么时候其会等于 -1，其在输入流关闭时才会等于 -1，
//并不是数据读完了，再去读才会等于-1，数据读完了，最结果也就是读不到数据为0而已；
while ((len = inputStream.read(bytes)) != -1) {
for(int i=0; i