devbox
IT小白
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

Android基于WebSocket实现局域网互联_android websocket server

作者：IT小白 | 2024-06-26 05:40:29

赞

踩

android websocket server

记录一下Android 基于WebSoket局域网互联技术，大家互相交流

准备工作

1、导入依赖

implementation "org.java-websocket:Java-WebSocket:1.5.1"

2，配置权限

申请网络权限（必须）

  1. <uses-permission android:name="android.permission.INTERNET" />
  2. 申请wifi相关权限（必须）
  3. <uses-permission android:name="android.permission.ACCESS_WIFI_STATE"/>

工具类：IPToolsUtils 用于查询IP

  1. import com.tencent.mmkv.MMKV;
  2.  
  3. import java.net.InetAddress;
  4. import java.net.InetSocketAddress;
  5. import java.net.NetworkInterface;
  6. import java.net.Socket;
  7. import java.net.SocketException;
  8. import java.util.Enumeration;
  9. import java.util.Random;
  10. import java.util.regex.Matcher;
  11. import java.util.regex.Pattern;
  12.  
  13. public class IPToolsUtils {
  14.  
  15.     //匹配C类地址的IP
  16.     public static final String regexCIp = "^192\\.168\\.(\\d{1}|[1-9]\\d|1\\d{2}|2[0-4]\\d|25\\d)\\.(\\d{1}|[1-9]\\d|1\\d{2}|2[0-4]\\d|25\\d)$";
  17.     //匹配A类地址
  18.     public static final String regexAIp = "^10\\.(\\d{1}|[1-9]\\d|1\\d{2}|2[0-4]\\d|25\\d)\\.(\\d{1}|[1-9]\\d|1\\d{2}|2[0-4]\\d|25\\d)\\.(\\d{1}|[1-9]\\d|1\\d{2}|2[0-4]\\d|25\\d)$";
  19.     //匹配B类地址
  20.     public static final String regexBIp = "^172\\.(1[6-9]|2\\d|3[0-1])\\.(\\d{1}|[1-9]\\d|1\\d{2}|2[0-4]\\d|25\\d)\\.(\\d{1}|[1-9]\\d|1\\d{2}|2[0-4]\\d|25\\d)$";
  21.  
  22.  
  23.     public static String getHostIp() {
  24.         String hostIp;
  25.         Pattern ip = Pattern.compile("(" + regexAIp + ")|" + "(" + regexBIp + ")|" + "(" + regexCIp + ")");
  26.         Enumeration<NetworkInterface> networkInterfaces = null;
  27.         try {
  28.             networkInterfaces = NetworkInterface.getNetworkInterfaces();
  29.         } catch (SocketException e) {
  30.             e.printStackTrace();
  31.         }
  32.         InetAddress address;
  33.         while (networkInterfaces.hasMoreElements()) {
  34.             NetworkInterface networkInterface = networkInterfaces.nextElement();
  35.             Enumeration<InetAddress> inetAddresses = networkInterface.getInetAddresses();
  36.             while (inetAddresses.hasMoreElements()) {
  37.                 address = inetAddresses.nextElement();
  38.                 String hostAddress = address.getHostAddress();
  39.                 Matcher matcher = ip.matcher(hostAddress);
  40.                 if (matcher.matches()) {
  41.                     hostIp = hostAddress;
  42.                     return hostIp;
  43.                 }
  44.  
  45.             }
  46.         }
  47.         return null;
  48.     }
  49.     private static void bindPort(String host, int port) throws Exception{
  50.         Socket s = new Socket();
  51.         s.bind(new InetSocketAddress(host, port));
  52.         s.close();
  53.     }
  54.     public static int getFreePort(){//判断端口是否可用
  55.         int port=MMKV.defaultMMKV().decodeInt("port",8888);
  56.         try{
  57.             bindPort("0.0.0.0", port);
  58.             bindPort(InetAddress.getLocalHost().getHostAddress(),port);
  59.         }
  60.         catch (Exception e)
  61.         {
  62.             port=new Random().nextInt(65535);
  63.             MMKV.defaultMMKV().encode("port",port);
  64.             getFreePort();
  65.         }
  66.         return port;
  67.     }
  68.     public static boolean isIssued(int port){//判断端口是否可用
  69.         try{
  70.             bindPort("0.0.0.0", port);
  71.             bindPort(InetAddress.getLocalHost().getHostAddress(),port);
  72.             return true;
  73.         }
  74.         catch (Exception e)
  75.         {
  76.             return false;
  77.         }
  78.     }
  79.  
  80. }

服务端WEbSoketClient代码实现

  1. import android.util.Log;
  2.  
  3. import org.greenrobot.eventbus.EventBus;
  4. import org.java_websocket.WebSocket;
  5. import org.java_websocket.handshake.ClientHandshake;
  6. import java.net.InetSocketAddress;
  7.  
  8. import static com.tuosi.websocketchartdemo.MainActivity.isServer;
  9.  
  10. /**
  11.  * guguangxian
  12.  */
  13. public class WebSocketServer extends org.java_websocket.server.WebSocketServer{
  14.  
  15.     private static WebSocketServer websocketServer;
  16.     WebSocketServer(InetSocketAddress host){
  17.         super(host);
  18.     }
  19.     @Override
  20.     public void onOpen(WebSocket conn, ClientHandshake handshake) {
  21.         Log.d("WebSocketServer","onOpen()：连接到: "+getRemoteSocketAddress(conn));
  22.         EventBus.getDefault().post(new MessageEvent(1,"onOpen："+getRemoteSocketAddress(conn)));
  23.         isServer=true;
  24.     }
  25.     @Override
  26.     public void onClose(WebSocket conn, int code, String reason, boolean remote) {
  27.         Log.d("WebSocketServer","onClose");
  28.         EventBus.getDefault().post(new MessageEvent(1,"onClose："+reason));
  29.     }
  30.     @Override
  31.     public void onMessage(WebSocket conn, String message) {
  32.         Log.d("WebSocketServer","onMessage"+message);
  33.         EventBus.getDefault().post(new MessageEvent(2,getRemoteSocketAddress(conn)+message));
  34.     }
  35.     @Override
  36.     public void onError(WebSocket conn, Exception ex) {
  37.         Log.d("WebSocketServer","onError"+ex.toString());
  38.         EventBus.getDefault().post(new MessageEvent(1,"onError："+ex.toString()));
  39.     }
  40.     @Override
  41.     public void onStart() {
  42.         Log.d("WebSocketServer","onStart:"+websocketServer.getAddress());
  43.         EventBus.getDefault().post(new MessageEvent(1,"onStart：服务器已就绪"+websocketServer.getAddress()));
  44.  
  45.     }
  46.     public static void ready(){
  47.         String ip = IPToolsUtils.getHostIp();
  48.         InetSocketAddress myHost = new InetSocketAddress(ip, 8080);
  49.         WebSocketServer websocketServer = new WebSocketServer(myHost);
  50.         try {
  51.             websocketServer.start();
  52.         } catch (Exception e) {
  53.             e.printStackTrace();
  54.         }
  55.         WebSocketServer.websocketServer = websocketServer;
  56.     }
  57.  
  58.     public static void Stop() {
  59.         try {
  60.             websocketServer.stop();
  61.         } catch (Exception e) {
  62.             e.printStackTrace();
  63.         }
  64.     }
  65.     public static void Send(String string) {
  66.         try {
  67.             websocketServer.broadcast(string);
  68.             //websocketServer.broadcast(string,clients);//Collection<WebSocket> clients,指定发送到哪个客户端
  69.         } catch (Exception e) {
  70.             e.printStackTrace();
  71.         }
  72.     }
  73.  
  74.  
  75. }

客户端代码实现

  1. import android.os.Looper;
  2. import android.util.Log;
  3.  
  4. import org.greenrobot.eventbus.EventBus;
  5. import org.java_websocket.exceptions.WebsocketNotConnectedException;
  6. import org.java_websocket.handshake.ServerHandshake;
  7. import java.net.URI;
  8.  
  9. import static com.tuosi.websocketchartdemo.MainActivity.isClient;
  10.  
  11. /**
  12.  * guguangxian
  13.  */
  14. public class WebSocketClient extends org.java_websocket.client.WebSocketClient {
  15.     public WebSocketClient(URI serverUri) {
  16.         super(serverUri);
  17.     }
  18.     @Override
  19.     public void onOpen(ServerHandshake handshakedata) {
  20.         Log.d("WebSocketClient","onOpen"+"成功连接到："+getRemoteSocketAddress());
  21.         EventBus.getDefault().post(new MessageEvent(1,"onOpen："+getRemoteSocketAddress()));
  22.         isClient=true;
  23.  
  24.     }
  25.     @Override
  26.     public void onMessage(String message) {
  27.         Log.d("WebSocketClient","onMessage"+message);
  28.         EventBus.getDefault().post(new MessageEvent(2,getRemoteSocketAddress()+"："+message));
  29.  
  30.     }
  31.     @Override
  32.     public void onClose(int code, String reason, boolean remote) {
  33.         Log.d("WebSocketClient","onClose");
  34.         EventBus.getDefault().post(new MessageEvent(1,"onClose："+reason));
  35.  
  36.     }
  37.     @Override
  38.     public void onError(Exception ex) {
  39.         Log.d("WebSocketClient","onError");
  40.         EventBus.getDefault().post(new MessageEvent(505,"onError："+ex.toString()));
  41.  
  42.     }
  43.     private static WebSocketClient webSocketClient;
  44.  
  45.     public static   boolean connect(String ip) {
  46.         if (webSocketClient != null) {
  47.             Release();
  48.         }
  49.         if (webSocketClient == null ) {
  50.             URI uri = URI.create("ws://"+ip+":8080/");
  51.             webSocketClient = new WebSocketClient(uri);
  52.         }
  53.         try {
  54.             webSocketClient.connect();
  55.             return true;
  56.         } catch (Exception e) {
  57.             e.printStackTrace();
  58.             return false;
  59.         }
  60.     }
  61.     public static void Release() {
  62.         Close();
  63.         webSocketClient = null;
  64.     }
  65.     public static void Close() {
  66.         if (webSocketClient == null) return;
  67.         if (!webSocketClient.isOpen()) return;
  68.         try {
  69.             webSocketClient.connect();
  70.         } catch (Exception e) {
  71.             e.printStackTrace();
  72.         }
  73.     }
  74.     public static void Send(String string) {
  75.         if (webSocketClient == null) return;
  76.         if (!webSocketClient.isOpen())
  77.             Reconnect();
  78.         try {
  79.             webSocketClient.send(string);
  80.         } catch (WebsocketNotConnectedException e) {
  81.             e.printStackTrace();
  82.         }
  83.     }
  84.     public static boolean Reconnect() {
  85.         if (webSocketClient == null) return false;
  86.         if (webSocketClient.isOpen()) return true;
  87.         try {
  88.             webSocketClient.connect();
  89.             return true;
  90.         } catch (Exception e) {
  91.             e.printStackTrace();
  92.             return false;
  93.         }
  94.     }
  95. }

使用案例

  1. import androidx.appcompat.app.AppCompatActivity;
  2. import androidx.core.app.ActivityCompat;
  3.  
  4. import android.Manifest;
  5. import android.content.Context;
  6. import android.content.pm.PackageManager;
  7. import android.net.wifi.WifiInfo;
  8. import android.net.wifi.WifiManager;
  9. import android.os.Build;
  10. import android.os.Bundle;
  11. import android.util.Log;
  12. import android.view.View;
  13. import android.view.ViewGroup;
  14. import android.widget.Button;
  15. import android.widget.EditText;
  16. import android.widget.LinearLayout;
  17. import android.widget.TextView;
  18. import android.widget.Toast;
  19.  
  20. import com.tencent.mmkv.MMKV;
  21.  
  22. import org.greenrobot.eventbus.EventBus;
  23. import org.greenrobot.eventbus.Subscribe;
  24. import org.greenrobot.eventbus.ThreadMode;
  25.  
  26. import java.net.URI;
  27. import java.util.concurrent.ExecutorService;
  28. import java.util.concurrent.Executors;
  29.  
  30. public class MainActivity extends AppCompatActivity {
  31.     Button ready;
  32.     Button connect;
  33.     Button send;
  34.     LinearLayout linearLayout;
  35.     TextView textView;
  36.     EditText editText;
  37.     public static boolean isServer = false;
  38.     public static boolean isClient = false;
  39.     public static int index = 191;
  40.     @Override
  41.     protected void onCreate(Bundle savedInstanceState) {
  42.         super.onCreate(savedInstanceState);
  43.         setContentView(R.layout.activity_main);
  44.         linearLayout = findViewById(R.id.linearLayout);
  45.         textView = findViewById(R.id.TextView2);
  46.         ready = findViewById(R.id.ready);
  47.         connect = findViewById(R.id.connect);
  48.         editText = findViewById(R.id.editText);
  49.         ready.setOnClickListener(v -> WebSocketServer.ready());
  50.         connect.setOnClickListener(v -> {
  51. //            String ip = NetWorkUtil.getHostIp();
  52. //            WebSocketClient.connect("192.168.1.193");
  53. //            executorService.execute(thread);
  54.             thread=new SessionThread();
  55.             thread.start();
  56.         });
  57.         send = findViewById(R.id.send);
  58.         send.setOnClickListener(v -> {
  59.             String message = editText.getText().toString();
  60.             if (message.equals("")) {
  61.                 Toast.makeText(MainActivity.this, "禁止发送空消息", Toast.LENGTH_SHORT).show();
  62.                 return;
  63.             }
  64.             if (isServer) {
  65.                 WebSocketServer.Send(message);
  66.                 addText("我：" + message);
  67.  
  68.             } else if (isClient) {
  69.                 WebSocketClient.Send(message);
  70.                 addText("我：" + message);
  71.             } else {
  72.                 Toast.makeText(MainActivity.this, "未连接", Toast.LENGTH_SHORT).show();
  73.             }
  74.         });
  75.         MMKV.initialize(this);
  76.  
  77.         EventBus.getDefault().register(this);
  78.     }
  79.     SessionThread thread;
  80.  
  81.     @Subscribe(threadMode = ThreadMode.MAIN)
  82.     public synchronized void MessageEventBusa(MessageEvent messageEvent) {
  83.         String string = messageEvent.getString();
  84.         switch (messageEvent.getCode()) {
  85.             case 1://
  86.                 textView.setText(string);
  87.                 break;
  88.             case 2:
  89.                 addText(string);
  90.             case 505:
  91.                 if (isClient) {
  92.                     return;
  93.                 }
  94.                 textView.setText(string);
  95.                 ++index;
  96.                 thread=null;
  97.                 thread = new SessionThread();
  98.                 thread.start();
  99. //                executorService.execute(thread);
  100.                 break;
  101.         }
  102.     }
  103.  
  104.     private void addText(String string) {
  105.         TextView textView = new TextView(this);
  106.         LinearLayout.LayoutParams lllp = new LinearLayout.LayoutParams(ViewGroup.LayoutParams.WRAP_CONTENT, ViewGroup.LayoutParams.WRAP_CONTENT);
  107.         textView.setText(string);
  108.         linearLayout.addView(textView, lllp);
  109.     }
  110.  
  111.     @Override
  112.     protected void onDestroy() {
  113.         super.onDestroy();
  114.         EventBus.getDefault().unregister(this);
  115.     }
  116.  
  117.  
  118.     /* 发送进程 */
  119.     private class SessionThread extends Thread {
  120.         @Override
  121.         public void run() {
  122.  
  123.             synchronized (this) {
  124.                 Log.e("wifiInfo", "index="+index);
  125.                 if (index > 255) {
  126.                     return;
  127.                 }
  128.                 try {
  129.                     String ipStart = "", ipEnd = "";
  130.                     //获取wifi服务
  131.                     WifiManager wifiManager = (WifiManager) getApplicationContext().getSystemService(Context.WIFI_SERVICE);
  132.                     if (wifiManager != null) {
  133.                         if (!wifiManager.isWifiEnabled())
  134.                             wifiManager.setWifiEnabled(true);
  135.  
  136.                         WifiInfo wifiInfo = wifiManager.getConnectionInfo();
  137.                         int ipAddress = wifiInfo.getIpAddress();
  138.                         String str = intToIp(ipAddress);
  139.                         String[] ip = str.split("\\.");
  140.                         if (ip.length == 4) {
  141.                             ipStart = (ip[0] + "." + ip[1] + "." + ip[2] + ".2");
  142.                             ipEnd = (ip[0] + "." + ip[1] + "." + ip[2] + ".255");
  143.                         }
  144.                     }
  145.                     Log.e("wifiInfo", "startIP=" + ipStart);
  146.                     String[] startStr = ipStart.split("\\.");
  147.                     String[] endStr = ipEnd.split("\\.");
  148.  
  149.                     // 扫描设备
  150.                     int startInt = Integer.parseInt(startStr[3]);
  151.                     int endInt = Integer.parseInt(endStr[3]);
  152.  
  153.                     if (startStr.length == endStr.length && startStr[0].equals(endStr[0]) && startStr[1].equals(endStr[1]) && startStr[2].equals(endStr[2])) {
  154.                         int num = endInt - startInt;
  155.                         if (num > -1) {
  156.  
  157.                             WebSocketClient[] websocket = new WebSocketClient[endInt - startInt + 1];
  158.                             String ipAddress = startStr[0] + "." + startStr[1] + "." + startStr[2] + ".";
  159.                             Log.e("wifiInfo", "ipAddress=" + ipAddress);
  160.                             String ipServer = ipAddress + index;
  161.                             WebSocketClient.connect(ipServer);
  162.                             Log.e("wifiInfo", "ipServer=" + ipServer);
  163.                         }
  164.                     }
  165.  
  166.                 } catch (Exception e) {
  167.                     e.printStackTrace();
  168.                 }
  169.  
  170.             }
  171.             }
  172.  
  173.     }
  174.  
  175.     private String intToIp(int i) {
  176.         return (i & 0xFF) + "." +
  177.                 ((i >> 8) & 0xFF) + "." +
  178.                 ((i >> 16) & 0xFF) + "." +
  179.                 (i >> 24 & 0xFF);
  180.     }
  181. }

xml

  1. <?xml version="1.0" encoding="utf-8"?>
  2. <androidx.constraintlayout.widget.ConstraintLayout xmlns:android="http://schemas.android.com/apk/res/android"
  3.     xmlns:app="http://schemas.android.com/apk/res-auto"
  4.     xmlns:tools="http://schemas.android.com/tools"
  5.     android:layout_width="match_parent"
  6.     android:layout_height="match_parent"
  7.     tools:context=".MainActivity">
  8.  
  9.     <Button
  10.         android:id="@+id/ready"
  11.         android:layout_width="wrap_content"
  12.         android:layout_height="wrap_content"
  13.         android:layout_marginTop="8dp"
  14.         android:text="等待连接"
  15.         app:layout_constraintBottom_toBottomOf="parent"
  16.         app:layout_constraintHorizontal_bias="0.359"
  17.         app:layout_constraintLeft_toLeftOf="parent"
  18.         app:layout_constraintRight_toRightOf="parent"
  19.         app:layout_constraintTop_toTopOf="parent"
  20.         app:layout_constraintVertical_bias="0.011" />
  21.  
  22.     <Button
  23.         android:id="@+id/connect"
  24.         android:layout_width="wrap_content"
  25.         android:layout_height="wrap_content"
  26.         android:text="发起连接"
  27.         app:layout_constraintBottom_toBottomOf="parent"
  28.         app:layout_constraintHorizontal_bias="0.049"
  29.         app:layout_constraintLeft_toLeftOf="parent"
  30.         app:layout_constraintRight_toRightOf="parent"
  31.         app:layout_constraintTop_toTopOf="parent"
  32.         app:layout_constraintVertical_bias="0.023" />
  33.  
  34.     <TextView
  35.         android:id="@+id/TextView2"
  36.         android:layout_width="match_parent"
  37.         android:layout_height="50dp"
  38.         android:layout_marginTop="8dp"
  39.         android:text="连接到xxx"
  40.         app:layout_constraintTop_toBottomOf="@+id/ready">
  41.  
  42.     </TextView>
  43.     <LinearLayout
  44.         android:id="@+id/linearLayout"
  45.         android:layout_width="match_parent"
  46.         android:layout_height="300dp"
  47.         android:layout_marginTop="8dp"
  48.         android:layout_marginBottom="8dp"
  49.         android:orientation="vertical"
  50.         app:layout_constraintBottom_toBottomOf="parent"
  51.         app:layout_constraintTop_toBottomOf="@+id/TextView2"
  52.         app:layout_constraintVertical_bias="0.0"
  53.         tools:layout_editor_absoluteX="0dp">
  54.     </LinearLayout>
  55.  
  56.     <EditText
  57.         android:singleLine="true"
  58.         android:id="@+id/editText"
  59.         android:layout_width="match_parent"
  60.         android:layout_height="100dp"
  61.         android:layout_marginTop="8dp"
  62.         app:layout_constraintTop_toBottomOf="@+id/linearLayout"
  63.         tools:layout_editor_absoluteX="16dp" />
  64.  
  65.     <Button
  66.         android:id="@+id/send"
  67.         android:layout_width="match_parent"
  68.         android:layout_height="50dp"
  69.         android:layout_marginTop="8dp"
  70.         app:layout_constraintTop_toBottomOf="@+id/editText"
  71.         android:text="发送"
  72.         tools:layout_editor_absoluteX="0dp" />
  73.  
  74. </androidx.constraintlayout.widget.ConstraintLayout>

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/IT小白/article/detail/758367
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号