如果服务器需要知道应用当前的连接状态,包括手机网络状态的切换(Wifi和数据的转换),断开网络或者切换VPN网络等,那么这些情况,socket连接该如何处理?
下面简单说一下我的想法和遇到的坑!

Java Web服务器

①首先一个线程类,用来接收客户端连过来的socket:
ThreadSocket.java

import java.io.IOException;
import java.io.InputStream;
import java.net.Socket;
public class ThreadSocket implements Runnable {
    private Socket socket;
    private String ip;
    @SuppressWarnings("all")
    public void run() {
        String str=null;
        while (true) {
            try {
                socket.setSoTimeout(5000);
                InputStream is = socket.getInputStream(); 
                 // 设定读取的字节数   
                byte buffer[] = new byte[512]; 
                // 读取输入流   
                if ((is.read(buffer, 0, buffer.length) != -1)) { 
                    if(str == null){
                        System.err.println("------------------"+ip);
                        str = new String(buffer).split(",")[0];
                        if(SaveSocketMap.getMap().get(str)==null){
                            SaveSocketMap.getMap().put(Integer.parseInt(str), socket);
                            System.err.println("#####################---"+SaveSocketMap.getMap().size());
                }else{
                //这种情况是客户端socket关闭
                    System.out.println("断开连接********ip:"+socket);
                    SaveSocketMap.getMap().remove(Integer.parseInt(str));
                    System.err.println("#####################---"+SaveSocketMap.getMap().size());
                    break;
            } catch (Exception e) {
            //捕捉到SocketTimeOutException,说明客户端断开网络
                System.out.println("客户端断开网络********ip:"+ip);    
                SaveSocketMap.getMap().remove(Integer.parseInt(str));
                System.err.println("#####################---"+SaveSocketMap.getMap().size());
                try {
                    socket.close();
                    break;
                } catch (IOException e1) {
    public ThreadSocket(Socket socket,String Ip) {
        this.socket = socket;
        this.ip = Ip;

在这个线程类里边,首先while(true)一直接收来自客户端的socket连接,设置超时,是用来判断客户端是否断开网络,一个map用来保存用户连过来的socket,用来做具体的逻辑处理,这里就不提了,跟本话题无关!如果接收不到客户端发过来的数据,说明客户端的socket关闭!
②一个Map类:SaveSocketMap.java

import java.net.Socket;
import java.util.concurrent.ConcurrentHashMap;
public class SaveSocketMap {
    private static ConcurrentHashMap<Integer, Socket> map;
    public synchronized static ConcurrentHashMap<Integer, Socket> getMap(){
        if(map==null){
            map=new ConcurrentHashMap<Integer, Socket>();
        return map;

使用ConcurrentHashMap,是因为它是线程安全的,key为客户端发过来id,value为连过来的socket!
关于ConcurrentHashMap的原理,可以参考下面两篇文章:
Java集合—ConcurrentHashMap原理分析
HashMap与ConcurrentHashMap的区别
③然后写一个监听,使服务器在启动的时候就去执行:
InitListener.java

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import javax.servlet.ServletContextEvent;
 * 系统初始化监听器,在系统启动时运行,进行一些初始化工作
 * @author mars
public class InitListener implements javax.servlet.ServletContextListener {
    public void contextDestroyed(ServletContextEvent arg0) {
    public void contextInitialized(ServletContextEvent event) {
        new Thread(new Runnable() {
            public void run() {
                getSocket();
        }).start();
    @SuppressWarnings("resource")
    public void getSocket(){
        try {
            ServerSocket serverSocket = new ServerSocket(10000);
            while (true) {
                System.out.println("等待客户端连接");
                Socket socket = serverSocket.accept();
                System.out.println("服务器接收到客户端的连接IP="+socket.getInetAddress().getHostAddress());
                // 读取客户端数据
                new Thread(new ThreadSocket(socket,socket.getInetAddress().getHostAddress())).start();
        } catch (IOException e) {
            e.printStackTrace();

④最后在web.xml中声明一下就可以了!

<listener>
        <listener-class>com.XXXX.util.InitListener</listener-class>
</listener>

Android客户端

在客户端是用广播来监听当前网络的,包括连接VPN也是用广播来监听的,关于广播的问题之后再说!
然后要明确两个问题:第一个问题是手机网络的变化wifi和数据的切换,我们要重新建立socket连接。断开网络是连接超时。第二个问题手机连接VPN,此时手机是有网络的,但是之前的socket连接已经断了,因为我们换了VPN,这时也要重新建立socket连接!

private void connectServer() {
        new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    socket = new Socket("192.168.1.125", 10000);
                    while (true) {
                        socket.getOutputStream().write((1 + ",").getBytes());
                        socket.getOutputStream().flush();
                } catch (UnknownHostException e) {
                    e.printStackTrace();
                } catch (IOException e) {
                    e.printStackTrace();
        }).start();

之后我们在广播该建立连接的时候调用该方法即可。
需要注意的一点是:当情况属于连接超时的时候,因为服务器端设置的5s,那么我们在重连的时候就要在这个超时之后,可以用Handler来处理:

handler.postDelayed(new Runnable() {
                        @Override
                        public void run() {
                            connectServer();
                    }, 6000);

好了,先这样吧!

前言如果服务器需要知道应用当前的连接状态,包括手机网络状态的切换(Wifi和数据的转换),断开网络或者切换VPN网络等,那么这些情况,socket连接该如何处理? 下面简单说一下我的想法和遇到的坑!Java Web服务器①首先一个线程类,用来接收客户端连过来的socket: ThreadSocket.javaimport java.io.IOException;import java.io.I private $port = 80; private $_sockets; public function __construct($address = '', $port='')
 这种功能实际上就是数据同步,同时要考虑手机本身、电量、网络流量等等限制因素,所以通常在移动上有一下两个解决方案:   1.一种是定时去server查询数据,通常是使用HTTP协议来访问web服务器,称Polling(轮询);   2.还有一种是移动服务器建立长连接,使用XMPP长连接,称Push(推送)。   从耗费的电量、流量和数据延迟性各方面来说,Push有明显的优势。但是使用Pu...