webSocket编程实现与安卓、ios通信

你的名字 2022-06-06 12:47 312阅读 0赞

最经公司在写一个新项目，需要实时与APP端进行交互展示现有状态，用到了webSocket编程，觉得还可以应该可以帮助到大家，所以就写下这篇博客用以记录操作！

代码和步骤如下：

服务端代码：

1.首先创建一个用于操作连接池的类

import java.util.ArrayList;  
import java.util.Collection;  
import java.util.HashMap;  
import java.util.List;  
import java.util.Map;  
import java.util.Set;  
  
  
import org.java\_websocket.WebSocket;  
  
  
  
  
public class WsPool \{  
    private static final Map<WebSocket, String> wsUserMap = new HashMap<WebSocket, String>();  
  
  
    /\*\*  
     \* 通过websocket连接获取其对应的用户  
     \*   
     \* @param conn  
     \* @return  
     \*/  
    public static String getUserByWs(WebSocket conn) \{  
        return wsUserMap.get(conn);  
    \}  
  
  
    /\*\*  
     \* 根据userName获取WebSocket,这是一个list,此处取第一个  
     \* 因为有可能多个websocket对应一个userName（但一般是只有一个，因为在close方法中，我们将失效的websocket连接去除了）  
     \*   
     \* @param user  
     \*/  
    public static WebSocket getWsByUser(String userName) \{  
        Set<WebSocket> keySet = wsUserMap.keySet();  
        synchronized (keySet) \{  
            for (WebSocket conn : keySet) \{  
                String cuser = wsUserMap.get(conn);  
                if (cuser.equals(userName)) \{  
                    return conn;  
                \}  
            \}  
        \}  
        return null;  
    \}  
  
  
    /\*\*  
     \* 向连接池中添加连接  
     \*   
     \* @param inbound  
     \*/  
    public static void addUser(String userName, WebSocket conn) \{  
        wsUserMap.put(conn, userName); // 添加连接  
    \}  
  
  
    /\*\*  
     \* 获取所有连接池中的用户，因为set是不允许重复的，所以可以得到无重复的user数组  
     \*   
     \* @return  
     \*/  
    public static Collection<String> getOnlineUser() \{  
        List<String> setUsers = new ArrayList<String>();  
        Collection<String> setUser = wsUserMap.values();  
        for (String u : setUser) \{  
            setUsers.add(u);  
        \}  
        return setUsers;  
    \}  
  
  
    /\*\*  
     \* 移除连接池中的连接  
     \*   
     \* @param inbound  
     \*/  
    public static boolean removeUser(WebSocket conn) \{  
        if (wsUserMap.containsKey(conn)) \{  
            wsUserMap.remove(conn); // 移除连接  
            return true;  
        \} else \{  
            return false;  
        \}  
    \}  
  
  
    /\*\*  
     \* 向特定的用户发送数据  
     \*   
     \* @param user  
     \* @param message  
     \*/  
    public static void sendMessageToUser(WebSocket conn, String message) \{  
    System.out.println("开始发送----");  
    conn.send(message);  
        if (null != conn && null != wsUserMap.get(conn)) \{  
            conn.send(message);  
            System.out.println("发送成功----"+message);  
        \}  
    \}  
  
  
    /\*\*  
     \* 向所有的用户发送消息  
     \*   
     \* @param message  
     \*/  
    public static void sendMessageToAll(String message) \{  
        Set<WebSocket> keySet = wsUserMap.keySet();  
        synchronized (keySet) \{  
            for (WebSocket conn : keySet) \{  
                String user = wsUserMap.get(conn);  
                if (user != null) \{  
                    conn.send(message);  
                \}  
            \}  
        \}  
    \}  
      
    public static void main(String\[\] args) \{  
    Collection<String> aaList=getOnlineUser();  
    for (String string : aaList) \{  
System.out.println(string);  
\}  
\}  
  
  
\}

2.然后穿件一个启动服务和接收消息的类

import java.net.InetSocketAddress;  
  
  
import org.java\_websocket.WebSocket;  
import org.java\_websocket.WebSocketImpl;  
import org.java\_websocket.handshake.ClientHandshake;  
import org.java\_websocket.server.WebSocketServer;  
  
  
public class WsServer extends WebSocketServer \{  
    public WsServer(int port) \{  
        super(new InetSocketAddress(port));  
    \}  
  
  
    public WsServer(InetSocketAddress address) \{  
        super(address);  
    \}  
  
  
    @Override  
    public void onOpen(WebSocket conn, ClientHandshake handshake) \{  
        // ws连接的时候触发的代码，onOpen中我们不做任何操作  
  
  
    \}  
  
  
    @Override  
    public void onClose(WebSocket conn, int code, String reason, boolean remote) \{  
        //断开连接时候触发代码  
        userLeave(conn);  
        System.out.println(reason);  
    \}  
  
  
    @Override  
    public void onMessage(WebSocket conn, String message) \{  
        System.out.println(message+"ddddd");  
        WsPool.sendMessageToUser(conn, "你好");  
        if(null != message &&message.startsWith("online"))\{  
            String userName=message.replaceFirst("online", message);//用户名  
            userJoin(conn,userName);//用户加入  
        \}else if(null != message && message.startsWith("offline"))\{  
            userLeave(conn);  
        \}  
  
  
    \}  
  
  
    @Override  
    public void onError(WebSocket conn, Exception ex) \{  
        //错误时候触发的代码  
        System.out.println("on error");  
        ex.printStackTrace();  
    \}  
    /\*\*  
     \* 去除掉失效的websocket链接  
     \* @param conn  
     \*/  
    private void userLeave(WebSocket conn)\{  
        WsPool.removeUser(conn);  
    \}  
    /\*\*  
     \* 将websocket加入用户池  
     \* @param conn  
     \* @param userName  
     \*/  
    private void userJoin(WebSocket conn,String userName)\{  
        WsPool.addUser(userName, conn);  
    \}  
      
    public static void main(String args\[\])\{  
        WebSocketImpl.DEBUG = false;  
        int port = 8887; // 端口  
        WsServer s = new WsServer(port);  
        s.start();  
    \}  
  
  
\}

客户段代码就不用写了，我们有一个网址可以进行测试：http://www.blue-zero.com/WebSocket/

![Image 1][]

可以模拟发送，测试；

以上代码需要java\_websocket.jar的支持，附上下载地址：http://download.csdn.net/download/huxiangen/10111161

[Image 1]: