如果服务器需要知道应用当前的连接状态,包括手机网络状态的切换(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{
System.out.println("断开连接********ip:"+socket);
SaveSocketMap.getMap().remove(Integer.parseInt(str));
System.err.println("#####################---"+SaveSocketMap.getMap().size());
break;
} catch (Exception e) {
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...