Android Sokect 一对多~ 服务端对多个客户端(个人笔记)

最近公司要求做个小工具要求三台手机同时操作做某个事情——Sokect就简单粗暴可实现

一个服务端两个客户端就欧了

服务端：

import android.content.Context;
import android.util.Log;
import android.widget.Toast;

import com.eggplant.virgo.features.main.FaceMainNewActivity;

import org.greenrobot.eventbus.EventBus;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Timer;
import java.util.TimerTask;

import static com.eggplant.virgo.features.sokect.tcp.SockeState.SERVICE_ADDCLIENT;
import static com.eggplant.virgo.features.sokect.tcp.SockeState.SERVICE_DISCONNECT;
import static com.eggplant.virgo.features.sokect.tcp.SockeState.STARTSERVICE;
import static com.eggplant.virgo.features.sokect.tcp.SockeState.STARTSERVIC_ERROR;

public class ServerListener {
    private static ServerListener minstace;
    private ServerListener () {}
    public static ServerListener getInstance() {
        if (minstace == null) {
            synchronized (ServerListener.class) {
                if (minstace == null) {
                    minstace = new ServerListener();
                }
            }
        }
        return minstace;

}
private static ServerSocket serverSocket;
    public boolean isOpen() {
        if (serverSocket != null) {
            return !serverSocket.isClosed();
        }
        return false;
    }

//启动服务端

public void startService() {
        new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    serverSocket = new ServerSocket(8080);
                    while (true) {
                        Log.d("skj", "========:启动服务"+ serverSocket);
                        EventBus.getDefault().post(new SockeState(STARTSERVICE));
                        Socket socket = serverSocket.accept();
                        ChartSocket cs = new ChartSocket(socket);
                        cs.start();
                        ChatManager.getChatManager().add(cs);
                        EventBus.getDefault().post(new SockeState(SERVICE_ADDCLIENT));

}
                } catch (IOException e) {
                    Log.d("skj", "========:服务开启异常");
                    EventBus.getDefault().post(new SockeState(STARTSERVIC_ERROR, e.toString()));
                    e.printStackTrace();
                }
            }
        }).start();
    }

}

-------------------------------------------------------------------------------------------------------------

import android.util.Log;import java.util.Timer;
import java.util.TimerTask;
import java.util.Vector;import static com.eggplant.virgo.features.main.FaceMainNewActivity.HEART;public class ChatManager {/*** @param*/private ChatManager() {}private static final ChatManager cm = new ChatManager();public static ChatManager getChatManager() {return cm;}Vector<ChartSocket> vector = new Vector<ChartSocket>();public void add(ChartSocket cs) {vector.add(cs);cs.out(HEART);//连接进来第一时间发送心跳包sendBeatData();}public void publish(ChartSocket cs, String out) {for (int i = 0; i < vector.size(); i++) {//遍历所有de chartsocketChartSocket csChartSocket = vector.get(i);//获取循环中的第I个对象  telnet localhost 12345if (!cs.equals(csChartSocket)) {//除了本身csChartSocket.out(out);System.out.println("将信息发送给所有客户 调用pulish:  " + out);}}}/*** 服务器给所有用户发送信息*/public void servicePublish(String out) {for (int i = 0; i < vector.size(); i++) {//遍历所有de chartsocketChartSocket csChartSocket = vector.get(i);//获取循环中的第I个对象  telnet localhost 12345csChartSocket.out(out);}}/*倒计时Timer发送心跳包*/private Timer timer;private TimerTask task;private int heartCycle = 10;/*定时发送数据*/private void sendBeatData() {if (timer == null) {timer = new Timer();}if (task == null) {task = new TimerTask() {@Overridepublic void run() {try {Log.i("skj", "服务器发送心跳包");servicePublish(HEART);} catch (Exception e) {e.printStackTrace();}}};timer.schedule(task, 0, 1000 * heartCycle);}}}

---------------------------------------------------------------------------------------------------------------------------------------------------------------------

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.UnsupportedEncodingException;
import java.net.Socket;
public class ChartSocket extends Thread {Socket socket;BufferedWriter bw;BufferedReader br;public ChartSocket(Socket s) {this.socket = s;try {bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream(), "utf-8"));br = new BufferedReader(new InputStreamReader(socket.getInputStream(), "utf-8"));} catch (IOException e) {e.printStackTrace();}}public void out(String out) {try {bw.write(out + "\n");// 必须要加换行符号,不然数据发不出去bw.flush();} catch (UnsupportedEncodingException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();}}public void run(){try {
//          BufferedReader br=new BufferedReader(new InputStreamReader(socket.getInputStream(),"UTF-8"));String line=null;while((line=br.readLine())!=null){//reaadline是个阻塞函数  没有读取到会一直处于阻塞状态System.out.println("读取到了信息");System.out.println("客户端发来数据："+line);
//                ChatManager.getChatManager().publish(this, line);System.out.println("写入了信息");}br.close();} catch (UnsupportedEncodingException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}}
}

==========================================================================

客户端代码：

import android.content.Context;
import android.os.AsyncTask;
import android.util.Log;
import android.widget.Toast;import org.greenrobot.eventbus.EventBus;import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Timer;
import java.util.TimerTask;import static com.eggplant.virgo.features.main.FaceMainNewActivity.HEART;
import static com.eggplant.virgo.features.sokect.tcp.SockeState.SERVICE_DISCONNECT;public class SokectClient {private static SokectClient minstace;private int heartCycle = 10;public static SokectClient getInstance() {if (minstace == null) {synchronized (SokectClient.class) {if (minstace == null) {minstace = new SokectClient();}}}return minstace;}Socket socket = null;BufferedReader reader = null;BufferedWriter writer = null;AsyncTask<Void, String, Void> read;private Listener mListener;private long lastService;private boolean isClose = true;private Context mContext;private String mIp;public void setListener(Listener listener, Context context) {this.mListener = listener;this.mContext = context;}/*** 连接服务端*/public void connect(final String ip) {this.mIp = ip;if (read!=null){recovery();}read = new AsyncTask<Void, String, Void>() {protected Void doInBackground(Void... params) {try {socket = new Socket(ip, 8080);writer = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream(), "utf-8"));Log.e("skj", "writerwriterwriterwriter");reader = new BufferedReader(new InputStreamReader(socket.getInputStream(), "utf-8"));Log.e("skj", "dream......................");publishProgress("@Sucess");sendBeatData();} catch (UnknownHostException e1) {Log.d("skj", "=====:无法建立链接");mListener.dataListener("103");EventBus.getDefault().post(new SockeState(103, e1.toString()));e1.printStackTrace();} catch (IOException e1) {Log.d("skj", "=====:无法建立链接");EventBus.getDefault().post(new SockeState(103, e1.toString()));mListener.dataListener("103");e1.printStackTrace();}try {String line;while ((reader != null) && (line = reader.readLine()) != null) {publishProgress(line);Log.e("skj", " readling()");}} catch (IOException e) {e.printStackTrace();}return null;}@Overrideprotected void onProgressUpdate(String... values) {mListener.dataListener(values[0]);if (values[0].equals("@Sucess")) {isClose = false;lastService = System.currentTimeMillis();Toast.makeText(mContext, "建立链接",Toast.LENGTH_SHORT).show();} else {isClose = false;
//                    Toast.makeText(context, "收到数据！",
//                            Toast.LENGTH_SHORT).show();Log.d("skj", "服务器信息:" + values[0] + "\n");if (values[0] != null && values[0].equals(HEART)) {Log.d("skj", "收到心跳包:" + values[0] + "\n");lastService = System.currentTimeMillis();}}}};read.execute();}public boolean isClose() {if (socket != null) {if (socket.isClosed()) {return socket.isClosed();} else {return isClose;}} else {return isClose;}}/*倒计时Timer发送心跳包*/private Timer timer;private TimerTask task;/*定时发送数据*/private void sendBeatData() {if (timer == null) {timer = new Timer();}if (task == null) {task = new TimerTask() {@Overridepublic void run() {try {Log.i("skj", "发送心跳包");/*这里的编码方式根据你的需求去改*/writer.write("heart" + "\n");writer.flush();if ((System.currentTimeMillis() - lastService) > 2000 * heartCycle) {EventBus.getDefault().post(new SockeState(SERVICE_DISCONNECT));Log.e("skj", "服务器连接断开，正在重连");isClose = true;recovery();connect(mIp);}} catch (Exception e) {/*发送失败说明socket断开了或者出现了其他错误*/EventBus.getDefault().post(new SockeState(SERVICE_DISCONNECT));isClose = true;Log.e("skj", "连接断开，正在重连");/*重连*/recovery();connect(mIp);e.printStackTrace();}}};}timer.schedule(task, 0, 1000 * heartCycle);}private void recovery() {if (timer != null) {timer.cancel();timer = null;}if (task != null) {task.cancel();task = null;}if (socket != null) {try {socket.close();} catch (IOException e) {e.printStackTrace();}}if (writer != null) {try {writer.close();} catch (IOException e) {e.printStackTrace();}}if (reader != null) {try {reader.close();} catch (IOException e) {e.printStackTrace();}}if (read.getStatus() == AsyncTask.Status.RUNNING ||read.getStatus() == AsyncTask.Status.PENDING) {read.cancel(true);read = null;}}public interface Listener {void dataListener(String l);}}

获取本机IP地址：

public class IPUtil {public static String formatIpAddress(int ipAdress) {return (ipAdress & 0xFF) + "." + ((ipAdress >> 8) & 0xFF) + "." + ((ipAdress >> 16) & 0xFF) + "."+ (ipAdress >> 24 & 0xFF);}//获取本地IP函数public static String getLocalIPAddress() {//获取wifi服务  WifiManager wifiManager = (WifiManager) VirgoApp.getInstance().getApplicationContext().getSystemService(Context.WIFI_SERVICE);//判断wifi是否开启  if (!wifiManager.isWifiEnabled()) {wifiManager.setWifiEnabled(true);}WifiInfo wifiInfo = wifiManager.getConnectionInfo();int ipAddress = wifiInfo.getIpAddress();return formatIpAddress(ipAddress);}
}

UI比较简单

转载：https://blog.csdn.net/Larry_794204525/article/details/53842951