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

安卓websocket（客服端和服务端写在app端） 案例_android websockect 服务端

作者：正经夜光杯 | 2024-06-26 05:39:05

赞

踩

android websockect 服务端

废话不多说直接上代码

首选导入

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

  1. package com.zx.qnncpds.androidwbsocket;
  2.  
  3. import android.content.Intent;
  4. import android.os.Bundle;
  5. import android.view.View;
  6. import android.widget.Button;
  7.  
  8. import androidx.appcompat.app.AppCompatActivity;
  9.  
  10. import com.zx.qnncpds.androidwbsocket.client.ClientActivity;
  11. import com.zx.qnncpds.androidwbsocket.service.ServiceActivity;
  12.  
  13. public class MainActivity extends AppCompatActivity implements View.OnClickListener {
  14.     private Button btn1;
  15.     private Button btn2;
  16.  
  17.  
  18.     @Override
  19.     protected void onCreate(Bundle savedInstanceState) {
  20.         super.onCreate(savedInstanceState);
  21.         setContentView(R.layout.activity_main);
  22.  
  23.         btn1 = findViewById(R.id.btn1);
  24.         btn2 = findViewById(R.id.btn2);
  25.         btn1.setOnClickListener(this);
  26.         btn2.setOnClickListener(this);
  27.     }
  28.  
  29.     @Override
  30.     public void onClick(View v) {
  31.         switch (v.getId()) {
  32.             case R.id.btn1://客户端
  33.  
  34.                 startActivity(new Intent(MainActivity.this, ClientActivity.class));
  35.                 break;
  36.             case R.id.btn2://服务端
  37.                 startActivity(new Intent(MainActivity.this, ServiceActivity.class));
  38.  
  39.                 break;
  40.  
  41.             default:
  42.                 break;
  43.         }
  44.     }
  45. }

布局

  1. <?xml version="1.0" encoding="utf-8"?>
  2. <LinearLayout 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.     android:orientation="vertical"
  8.     tools:context=".MainActivity">
  9.  
  10.     <Button
  11.         android:id="@+id/btn1"
  12.         android:layout_width="match_parent"
  13.         android:layout_height="wrap_content"
  14.         android:text="客服端" />
  15.  
  16.  
  17.     <Button
  18.         android:id="@+id/btn2"
  19.         android:layout_width="match_parent"
  20.         android:layout_height="wrap_content"
  21.         android:text="服务端" />
  22. </LinearLayout>

客服端

  1. package com.zx.qnncpds.androidwbsocket.client;
  2.  
  3. import androidx.appcompat.app.AppCompatActivity;
  4.  
  5. import android.os.Bundle;
  6. import android.view.View;
  7. import android.widget.Button;
  8.  
  9. import com.zx.qnncpds.androidwbsocket.R;
  10.  
  11. import java.net.URI;
  12. import java.net.URISyntaxException;
  13.  
  14. public class ClientActivity extends AppCompatActivity implements ClientWebSocketListener {
  15.     private WebSocketClient webSocketClient;
  16.  
  17.    private Button btn_send;
  18.     @Override
  19.     protected void onCreate(Bundle savedInstanceState) {
  20.         super.onCreate(savedInstanceState);
  21.         setContentView(R.layout.activity_client);
  22.         btn_send=findViewById(R.id.btn_send);
  23.         btn_send.setOnClickListener(v -> sendMessage("测试消息"));
  24.         try {
  25.             // 替换为你的WebSocket服务器URI
  26.             URI uri = new URI("ws://10.10.10.104:9007");
  27.             webSocketClient = new WebSocketClient(uri, this);
  28.             webSocketClient.connect();
  29.         } catch (URISyntaxException e) {
  30.             e.printStackTrace();
  31.         }
  32.     }
  33.  
  34.     /**
  35.      * @param message 当WebSocket接收到消息时调用此方法
  36.      */
  37.     @Override
  38.     public void onMessage(final String message) {
  39.  
  40.     }
  41.  
  42.     /**
  43.      * @param message 连接打开
  44.      */
  45.     @Override
  46.     public void onOpen(String message) {
  47.  
  48.     }
  49.  
  50.     /**
  51.      * @param message 连接关闭
  52.      */
  53.     @Override
  54.     public void onClose(String message) {
  55.  
  56.     }
  57.  
  58.     /**
  60.      * @param message 出现错误
  61.      */
  62.     @Override
  63.     public void onError(String message) {
  64.  
  65.     }
  66.  
  67.     public void sendMessage(String message) {
  68.         // 发送一个消息到WebSocket服务器
  69.         if (webSocketClient != null && webSocketClient.isOpen()) {
  70.             webSocketClient.send(message);
  71.         }
  72.     }
  73.  
  74.  
  75.     @Override
  76.     protected void onDestroy() {
  77.         super.onDestroy();
  78.         // 关闭WebSocket连接以避免内存泄露
  79.         if (webSocketClient != null) {
  80.             webSocketClient.close();
  81.         }
  82.     }
  83. }

  1. package com.zx.qnncpds.androidwbsocket.client;
  2.  
  3. public interface ClientWebSocketListener {
  4.     /**
  5.      * @param message 当WebSocket接收到消息时调用此方法
  6.      */
  7.     void onMessage(final String message);
  8.  
  9.     /**
  10.      * @param message 连接打开
  11.      */
  12.     void onOpen(final String message);
  13.  
  14.     /**
  15.      * @param message 连接关闭
  16.      */
  17.     void onClose(final String message);
  18.  
  19.     /**
  20.      * @param message 出现错误
  21.      */
  22.     void onError(final String message);
  23. }

  1. package com.zx.qnncpds.androidwbsocket.client;
  2.  
  3. import org.java_websocket.handshake.ServerHandshake;
  4.  
  5. import java.net.URI;
  6.  
  7. public class WebSocketClient extends org.java_websocket.client.WebSocketClient {
  8.  
  9.     private ClientWebSocketListener webSocketListener;
  10.  
  11.     public WebSocketClient(URI serverUri, ClientWebSocketListener listener) {
  12.         super(serverUri);
  13.         this.webSocketListener = listener;
  14.     }
  15.  
  16.     @Override
  17.     public void onOpen(ServerHandshake handshakeData) {
  18.         System.out.println("WebSocket 连接打开");
  19.         if (webSocketListener != null) {
  20.             webSocketListener.onOpen("WebSocket 连接打开");
  21.         }
  22.     }
  23.  
  24.     @Override
  25.     public void onMessage(String message) {
  26.         if (webSocketListener != null) {
  27.             webSocketListener.onMessage(message);
  28.         }
  29.     }
  30.  
  31.     @Override
  32.     public void onClose(int code, String reason, boolean remote) {
  33.         System.out.println("WebSocket 连接关闭");
  34.         if (webSocketListener != null) {
  35.             webSocketListener.onClose("WebSocket 连接关闭");
  36.         }
  37.  
  38.     }
  39.  
  40.     @Override
  41.     public void onError(Exception ex) {
  42.         System.out.println("WebSocket 出现错误: " + ex.getMessage());
  43.         if (webSocketListener != null) {
  44.             webSocketListener.onError("WebSocket 出现错误: " + ex.getMessage());
  45.         }
  46.     }
  47. }

服务端

  1. package com.zx.qnncpds.androidwbsocket.service;
  2.  
  3. import android.app.Activity;
  4. import android.os.Bundle;
  5. import android.widget.TextView;
  6.  
  7. import com.zx.qnncpds.androidwbsocket.R;
  8.  
  9. import org.java_websocket.WebSocket;
  10.  
  11. import java.io.IOException;
  12.  
  13. public class ServiceActivity extends Activity implements ServiceWebSocketListener {
  14.     // WebSocket服务器的实例
  15.     private AndroidWebSocketServer server;
  16.     private TextView tv_state;
  17.  
  18.     @Override
  19.     protected void onCreate(Bundle savedInstanceState) {
  20.         super.onCreate(savedInstanceState);
  21.         setContentView(R.layout.activity_service);
  22.  
  23.         tv_state=findViewById(R.id.tv_state);
  24.         // 创建并启动WebSocket服务器
  25.         server = new AndroidWebSocketServer(8887, this);
  26.         server.start();
  27.     }
  28.  
  29.     @Override
  30.     public void onClientOpen(WebSocket conn, String address) {
  31.         runOnUiThread(() -> {
  32.             // 更新UI显示连接的客户端的地址
  33.             // 例如：更新一个文本视图来显示已连接
  34.             tv_state.setText(address);
  35.         });
  36.     }
  37.  
  38.     @Override
  39.     public void onClientClose(WebSocket conn, int code, String reason, boolean remote) {
  40.         runOnUiThread(() -> {
  41.             // 更新UI以表示客户端断开连接
  42.             // 例如：更新列表视图中的项目
  43.             tv_state.setText("客户端以断开");
  44.         });
  45.     }
  46.  
  47.     @Override
  48.     public void onClientMessage(WebSocket conn, String message) {
  49.         runOnUiThread(() -> {
  50.             // 在UI上展示收到的消息
  51.             // 例如：将消息添加到聊天窗口
  52.             tv_state.setText(message);
  53.         });
  54.     }
  55.  
  56.     @Override
  57.     public void onClientError(WebSocket conn, Exception ex) {
  58.         runOnUiThread(() -> {
  59.             // 在UI上展示错误信息
  60.             // 例如：展示一个错误弹窗
  61.         });
  62.     }
  63.  
  64.     @Override
  65.     public void onServerStart() {
  66.         runOnUiThread(() -> {
  67.             // 更新UI表示服务器已经启动
  68.             // 例如：改变一个文本视图的文本
  69.             tv_state.setText("服务器已启动");
  70.         });
  71.     }
  72.  
  73.     @Override
  74.     protected void onDestroy() {
  75.         super.onDestroy();
  76.         if (server != null) {
  77.             try {
  78.                 server.stop();
  79.             } catch (IOException | InterruptedException e) {
  80.                 throw new RuntimeException(e);
  81.             }
  82.         }
  83.     }
  84.  
  85.  
  86.     // 广播消息给所有WebSocket客户端
  87.     public void broadcastToAll(String message) {
  88.         server.broadcastMessage(message);
  89.     }
  90.  
  91.     // 发送消息给特定的WebSocket客户端
  92.     public void sendToClient(WebSocket client, String message) {
  93.         server.sendMessageToClient(client, message);
  94.     }
  95. }

  1. package com.zx.qnncpds.androidwbsocket.service;
  2.  
  3.  
  4. import org.java_websocket.WebSocket;
  5. import org.java_websocket.handshake.ClientHandshake;
  6. import org.java_websocket.server.WebSocketServer;
  7.  
  8. import java.net.InetSocketAddress;
  9.  
  10. public class AndroidWebSocketServer extends WebSocketServer {
  11.     // 事件监听器，用于将事件通知给ServiceActivity
  12.     private ServiceWebSocketListener serviceWebSocketListener;
  13.     /**
  14.      * 构造函数。
  15.      * @param port 服务器侦听的端口号。
  16.      * @param serviceWebSocketListener 事件发生时的回调监听器。
  17.      */
  18.     public AndroidWebSocketServer(int port, ServiceWebSocketListener serviceWebSocketListener) {
  19.         super(new InetSocketAddress(port));
  20.         this.serviceWebSocketListener = serviceWebSocketListener;
  21.     }
  22.  
  23.     public AndroidWebSocketServer(int port) {
  24.         super(new InetSocketAddress(port));
  25.     }
  26.  
  27.     @Override
  28.     public void onOpen(WebSocket conn, ClientHandshake handshake) {
  29.         // 客户端连接打开时调用监听器的onClientOpen方法
  30.         String address = conn.getRemoteSocketAddress().getAddress().getHostAddress();
  31.         serviceWebSocketListener.onClientOpen(conn, address);
  32.     }
  33.  
  34.     @Override
  35.     public void onClose(WebSocket conn, int code, String reason, boolean remote) {
  36.         // 客户端连接关闭时调用监听器的onClientClose方法
  37.         String address = conn.getRemoteSocketAddress().getAddress().getHostAddress();
  38.         serviceWebSocketListener.onClientClose(conn, code, reason, remote);
  39.     }
  40.  
  41.     @Override
  42.     public void onMessage(WebSocket conn, String message) {
  43.         // 接收到客户端消息时调用监听器的onClientMessage方法
  44.         serviceWebSocketListener.onClientMessage(conn, message);
  45.     }
  46.  
  47.     @Override
  48.     public void onError(WebSocket conn, Exception ex) {
  49.         // 连接发生错误时调用监听器的onClientError方法
  50.         serviceWebSocketListener.onClientError(conn, ex);
  51.     }
  52.  
  53.     @Override
  54.     public void onStart() {
  55.         // WebSocket服务器启动时调用监听器的onServerStart方法
  56.         serviceWebSocketListener.onServerStart();
  57.     }
  58.  
  59.     // 发送消息到所有连接的WebSocket客户端
  60.     public void broadcastMessage(String message) {
  61.         broadcast(message);
  62.     }
  63.  
  64.     // 发送消息到特定的WebSocket客户端
  65.     public void sendMessageToClient(WebSocket conn, String message) {
  66.         if (conn != null) {
  67.             conn.send(message);
  68.         }
  69.     }
  70. }

  1. package com.zx.qnncpds.androidwbsocket.service;
  2.  
  3. import org.java_websocket.WebSocket;
  4.  
  5. public interface ServiceWebSocketListener {
  6.     /**当客户端连接打开时调用
  7.      * @param conn
  8.      * @param address
  9.      */
  10.     void onClientOpen(WebSocket conn, String address);
  11.     // 当客户端连接关闭时调用
  12.  
  13.     /** 当客户端连接关闭时调用
  14.      * @param conn
  15.      * @param code
  16.      * @param reason
  17.      * @param remote
  18.      */
  19.     void onClientClose(WebSocket conn, int code, String reason, boolean remote);
  20.  
  21.     /**当接收到客户端消息时调用
  22.      * @param conn
  23.      * @param message
  24.      */
  25.     void onClientMessage(WebSocket conn, String message);
  26.  
  27.     /**
  28.      *  当客户端连接发生错误时调用
  29.      * @param conn
  30.      * @param ex
  31.      */
  32.     void onClientError(WebSocket conn, Exception ex);
  33.  
  34.     /**
  35.      *当WebSocket服务器启动时调用
  36.      */
  37.     void onServerStart();
  38. }

布局加一个文本这就不写了（服务端和客服端都一样）

项目案例 https://download.csdn.net/download/qq_41733851/88885469?spm=1001.2014.3001.5503

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

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

  

闽ICP备14008679号