草庐IT

Android 网络通信WebSocket使用详解

android练习生 2023-08-07 原文

1.WebSocket 与HTTP区别

（1）HTTP是传统的请求响应式的网络通信方式，不能实现服务端主动向客户端发送消息。WebSocket可以实现服务端，客户端互发消息。

（2）WebSocket使用ws协议，HTTP使用http协议（使用的URL不同）

2.WebSocket 与Socket的异同

●相同点：服务端都能主动发消息给客户端
●不同点：1.socket基于TCP/IP协议，Websocket基于ws协议
                  2.Websocket只能面向链接
 
总结：socket更灵活，Websocket更简单

3.WebSocket实现步骤（客户端和服务端都为android程序）

客户端

第一步：权限和依赖

  <uses-permission android:name="android.permission.INTERNET"/>
implementation "org.java-websocket:Java-WebSocket:1.5.1"

第二步：本次使用EeventBus实现网络通信工具类与主活动的通信，数据类

package com.example.clientapplication;

public class MessageEvent {

    private String message; //网络数据内容
    private int number;  //网络数据分类

    public MessageEvent(int number, String message) {
        this.message = message;
        this.number = number;
    }

    public String getMessage() {
        return message;
    }

    public void setMessage(String message) {
        this.message = message;
    }

    public int getNumber() {
        return number;
    }

    public void setNumber(int number) {
        this.number = number;
    }
}

第三步：WebSocket客户端工具类继承org.java_websocket.client.WebSocketClient

使用EeventBus,将收到的消息传递给主活动。

package com.example.webclienttestapplication;

import android.util.Log;

import org.greenrobot.eventbus.EventBus;
import org.java_websocket.exceptions.WebsocketNotConnectedException;
import org.java_websocket.handshake.ServerHandshake;

import java.net.URI;

public class WebSocketClient extends org.java_websocket.client.WebSocketClient {
    public WebSocketClient(URI serverUri) {
        super(serverUri);
    }

    @Override
    public void onOpen(ServerHandshake handshakedata) {
        //开启连接
        Log.d("WebSocketClient","onOpen"+"成功连接到："+getRemoteSocketAddress());
        EventBus.getDefault().post(new MessageEvent(2,"onOpen："+getRemoteSocketAddress()));
        MainActivity.isClient=true;

    }
    @Override
    public void onMessage(String message) {
        //接受消息
        Log.d("WebSocketClient","onMessage"+message);
        EventBus.getDefault().post(new MessageEvent(1,getRemoteSocketAddress()+"："+message));

    }
    @Override
    public void onClose(int code, String reason, boolean remote) {
        //断开连接
        Log.d("WebSocketClient","onClose");
        EventBus.getDefault().post(new MessageEvent(2,"onClose："+reason));

    }
    @Override
    public void onError(Exception ex) {
        //发生错误
        Log.d("WebSocketClient","onError");
        EventBus.getDefault().post(new MessageEvent(2,"onError："+ex.toString()));

    }
    private static WebSocketClient webSocketClient;
    //发起连接
    public static boolean connect(String ip) {
        if (webSocketClient != null) {
            Release();
        }
        if (webSocketClient == null ) {
            URI uri = URI.create("ws://"+ip+":25211");
            webSocketClient = new WebSocketClient(uri);
        }
        try {
            webSocketClient.connectBlocking();
            return true;
        } catch (InterruptedException e) {
            e.printStackTrace();
            return false;
        }
    }
    public static void Release() {
        Close();
        webSocketClient = null;
    }
    public static void Close() {
        if (webSocketClient == null) return;
        if (!webSocketClient.isOpen()) return;
        try {
            webSocketClient.closeBlocking();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
    //发送消息
    public static void Send(String string) {
        if (webSocketClient == null) return;
        if (!webSocketClient.isOpen())
            Reconnect();
        try {
            webSocketClient.send(string);
        } catch (WebsocketNotConnectedException e) {
            e.printStackTrace();
        }
    }
    public static boolean Reconnect() {
        if (webSocketClient == null) return false;
        if (webSocketClient.isOpen()) return true;
        try {
            webSocketClient.reconnectBlocking();
            return true;
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        }
    }
}

第四步：主活动代码

package com.example.webclienttestapplication;

import androidx.appcompat.app.AppCompatActivity;

import android.os.Bundle;
import android.view.View;
import android.widget.Button;
import android.widget.TextView;
import android.widget.Toast;

import org.greenrobot.eventbus.EventBus;
import org.greenrobot.eventbus.Subscribe;
import org.greenrobot.eventbus.ThreadMode;

public class MainActivity extends AppCompatActivity {
    public static boolean isClient;
    private int mMessage = 10;
    private StringBuffer mShowBuffer = new StringBuffer();
    private StringBuffer mErrorBuffer = new StringBuffer();
    private TextView mTvShow,mTvError;
    private Button mBtnSend;
    private static final int TV_SHOW = 1; //消息内容
    private static final int TV_ERROR = 2; //异常信息
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        initUi();
        EventBus.getDefault().register(this); //EventBus注册
        mBtnSend.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View view) {
                if (isClient == true)
                    WebSocketClient.Send(mMessage++ + "");  //发送消息
                else Toast.makeText(MainActivity.this, "连接失败", Toast.LENGTH_SHORT).show();
            }
        });
        new Thread(new Runnable() {
            @Override
            public void run() {
                WebSocketClient.connect("192.168.91.149"); // 发起连接
            }
        }).start();

    }
    @Subscribe(threadMode = ThreadMode.MAIN)
    public void MessageEventBus(MessageEvent messageEvent){

        switch (messageEvent.getNumber()) {
            case TV_SHOW://
                mShowBuffer.append(messageEvent.getMessage());
                mTvShow.setText(mShowBuffer);
                break;
            case TV_ERROR:
                mErrorBuffer.append(messageEvent.getMessage());
                mTvError.setText(mErrorBuffer);
                break;
        }
    }

    private void initUi() {
        mBtnSend = findViewById(R.id.btn_send);
        mTvShow = findViewById(R.id.tv_show);
        mTvError = findViewById(R.id.tv_error);
    }
    @Override
    protected void onDestroy() {
        super.onDestroy();
        EventBus.getDefault().unregister(this); //取消注册
    }
}

XML代码

<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
    xmlns:app="http://schemas.android.com/apk/res-auto"
    xmlns:tools="http://schemas.android.com/tools"
    android:layout_width="match_parent"
    android:orientation="vertical"
    android:layout_height="match_parent"
    tools:context=".MainActivity">

    <TextView
        android:id="@+id/tv_show"
        android:layout_width="match_parent"
        android:layout_height="100dp"
        android:text="Hello World!"
        android:textSize="23sp"
        />
    <Button
        android:id="@+id/btn_send"
        android:layout_width="match_parent"
        android:layout_height="wrap_content"
        android:text="发送"
        android:textSize="23sp"/>
    <TextView
        android:id="@+id/tv_error"
        android:layout_marginTop="15dp"
        android:layout_width="match_parent"
        android:layout_height="100dp"
        android:textSize="23sp"
        />
</LinearLayout>

服务端

前两步与客户端相同

第三步：WebSocket服务端工具类继承org.java_websocket.server.WebSocketServer

package com.example.websockettestapplication;

import android.util.Log;

import org.greenrobot.eventbus.EventBus;
import org.java_websocket.WebSocket;
import org.java_websocket.handshake.ClientHandshake;

import java.net.InetSocketAddress;

public class WebSocketServer extends org.java_websocket.server.WebSocketServer{

    public static WebSocketServer websocketServer;
    WebSocketServer(InetSocketAddress host){
        super(host);
    }

    public static void ready(){
        InetSocketAddress myHost = new InetSocketAddress("192.168.91.149", 25211);
        WebSocketServer websocketServer = new WebSocketServer(myHost);
        try {
            websocketServer.start();

        } catch (Exception e) {
            e.printStackTrace();
        }
        WebSocketServer.websocketServer = websocketServer;
    }

    public static void Stop() {
        try {
            websocketServer.stop();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    public static void Send(String string) {
        try {
            websocketServer.broadcast(string);
            //websocketServer.broadcast(string,clients);//Collection<WebSocket> clients,指定发送到哪个客户端
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    @Override
    public void onOpen(WebSocket conn, ClientHandshake handshake) {
        Log.d("WebSocketServer","onOpen()：连接到: "+getRemoteSocketAddress(conn));
        EventBus.getDefault().post(new MessageEvent(1,"onOpen："+getRemoteSocketAddress(conn)));
        MainActivity.isServer=true;

    }

    @Override
    public void onClose(WebSocket conn, int code, String reason, boolean remote) {
        Log.d("WebSocketServer","onClose");
        EventBus.getDefault().post(new MessageEvent(2,"onClose："+reason));
        websocketServer = null;
    }

    @Override
    public void onMessage(WebSocket conn, String message) {
        Log.d("WebSocketServer","onMessage"+message);
        EventBus.getDefault().post(new MessageEvent(1,message));

    }

    @Override
    public void onError(WebSocket conn, Exception ex) {

        Log.d("WebSocketServer","onError"+ex.toString());
        EventBus.getDefault().post(new MessageEvent(2,"onError："+ex.toString()));
    }

    @Override
    public void onStart() {
        Log.d("WebSocketServer","onStart:"+websocketServer.getAddress().getHostName());
        EventBus.getDefault().post(new MessageEvent(2,"onStart：服务器已就绪"+websocketServer.getAddress().getHostName()));

    }
}

第四步：主活动代码

package com.example.websockettestapplication;

import androidx.appcompat.app.AppCompatActivity;

import android.os.Bundle;
import android.os.Message;
import android.view.View;
import android.widget.Button;
import android.widget.TextView;
import android.widget.Toast;

import org.greenrobot.eventbus.EventBus;
import org.greenrobot.eventbus.Subscribe;
import org.greenrobot.eventbus.ThreadMode;
import org.java_websocket.handshake.ServerHandshake;

import java.net.URI;
import java.util.Date;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class MainActivity extends AppCompatActivity {
public static boolean isServer;
private int mMessage = 0;
private StringBuffer mShowBuffer = new StringBuffer();
private StringBuffer mErrorBuffer = new StringBuffer();
private TextView mTvShow,mTvError;
private Button mBtnSend;
private static final int TV_SHOW = 1;
private static final int TV_ERROR = 2;
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        initUi();
        EventBus.getDefault().register(this);
        mBtnSend.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View view) {
                if (isServer == true)
                   WebSocketServer.Send("1111122222");
                else Toast.makeText(MainActivity.this, "连接失败", Toast.LENGTH_SHORT).show();
            }
        });
        ExecutorService fixedThreadPool = Executors.newFixedThreadPool(10);
        fixedThreadPool.execute(new Runnable() {
            @Override
            public void run() {
                WebSocketServer.ready();
            }
        });
    }
    @Subscribe(threadMode = ThreadMode.MAIN)
    public void MessageEventBusa(MessageEvent messageEvent){

        switch (messageEvent.getNumber()) {
            case TV_SHOW://
                mShowBuffer.append(messageEvent.getMessage());
                mTvShow.setText(mShowBuffer);
                break;
            case TV_ERROR:
                mErrorBuffer.append(messageEvent.getMessage());
                mTvError.setText(mErrorBuffer);
                break;
        }
    }

    private void initUi() {
        mBtnSend = findViewById(R.id.btn_send);
        mTvShow = findViewById(R.id.tv_show);
        mTvError = findViewById(R.id.tv_error   );
    }
    @Override
    protected void onDestroy() {
        super.onDestroy();

        EventBus.getDefault().unregister(this);
    }
}

XML代码

<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
    xmlns:app="http://schemas.android.com/apk/res-auto"
    xmlns:tools="http://schemas.android.com/tools"
    android:layout_width="match_parent"
    android:orientation="vertical"
    android:layout_height="match_parent"
    tools:context=".MainActivity">

    <TextView
        android:id="@+id/tv_show"
        android:layout_width="match_parent"
        android:layout_height="100dp"
        android:text="Hello World!"
        android:textSize="23sp"
        />
<Button
    android:id="@+id/btn_send"
    android:layout_width="match_parent"
    android:layout_height="wrap_content"
    android:text="发送"
    android:textSize="23sp"/>
    <TextView
        android:id="@+id/tv_error"
        android:layout_marginTop="15dp"
        android:layout_width="match_parent"
        android:layout_height="100dp"
        android:textSize="23sp"
        />
</LinearLayout>

注意看这里，本项目使用的版本信息，不是唯一正确，但是可以保证正确。还有就是ip地址和端口号请自行配置

2

Android Studio 2021.2.1 Patch1

开发工具

3

Gradle Version

7.3.3

4

Android Gradle Plugin Version

7.2.1

详解WebSocketandroid34public网络协议android studio

有关Android 网络通信WebSocket使用详解的更多相关文章

  1. ruby - 如何使用 Nokogiri 的 xpath 和 at_xpath 方法 - 2

    我正在学习如何使用Nokogiri，根据这段代码我遇到了一些问题:require'rubygems'require'mechanize'post_agent=WWW::Mechanize.newpost_page=post_agent.get('http://www.vbulletin.org/forum/showthread.php?t=230708')puts"\nabsolutepathwithtbodygivesnil"putspost_page.parser.xpath('/html/body/div/div/div/div/div/table/tbody/tr/td/div

  2. ruby - 使用 RubyZip 生成 ZIP 文件时设置压缩级别 - 2

    我有一个Ruby程序，它使用rubyzip压缩XML文件的目录树。gem。我的问题是文件开始变得很重，我想提高压缩级别，因为压缩时间不是问题。我在rubyzipdocumentation中找不到一种为创建的ZIP文件指定压缩级别的方法。有人知道如何更改此设置吗？是否有另一个允许指定压缩级别的Ruby库？ 最佳答案 这是我通过查看ruby​​zip内部创建的代码。level=Zlib::BEST_COMPRESSIONZip::ZipOutputStream.open(zip_file)do|zip|Dir.glob("**/*")d

  3. ruby - 为什么我可以在 Ruby 中使用 Object#send 访问私有(private)/ protected 方法？ - 2

    类classAprivatedeffooputs:fooendpublicdefbarputs:barendprivatedefzimputs:zimendprotecteddefdibputs:dibendendA的实例a=A.new测试a.foorescueputs:faila.barrescueputs:faila.zimrescueputs:faila.dibrescueputs:faila.gazrescueputs:fail测试输出failbarfailfailfail.发送测试[:foo,:bar,:zim,:dib,:gaz].each{|m|a.send(m)resc

  4. ruby-on-rails - 使用 Ruby on Rails 进行自动化测试 - 最佳实践 - 2

    很好奇，就使用ruby​​onrails自动化单元测试而言，你们正在做什么？您是否创建了一个脚本来在cron中运行rake作业并将结果邮寄给您？git中的预提交Hook？只是手动调用？我完全理解测试，但想知道在错误发生之前捕获错误的最佳实践是什么。让我们理所当然地认为测试本身是完美无缺的，并且可以正常工作。下一步是什么以确保他们在正确的时间将可能有害的结果传达给您？ 最佳答案 不确定您到底想听什么，但是有几个级别的自动代码库控制:在处理某项功能时，您可以使用类似autotest的内容获得关于哪些有效，哪些无效的即时反馈。要确保您的提

  5. ruby - 在 Ruby 中使用匿名模块 - 2

    假设我做了一个模块如下:m=Module.newdoclassCendend三个问题:除了对m的引用之外，还有什么方法可以访问C和m中的其他内容？我可以在创建匿名模块后为其命名吗(就像我输入“module...”一样)？如何在使用完匿名模块后将其删除，使其定义的常量不再存在？ 最佳答案 三个答案:是的，使用ObjectSpace.此代码使c引用你的类(class)C不引用m:c=nilObjectSpace.each_object{|obj|c=objif(Class===objandobj.name=~/::C$/)}当然这取决于

  6. ruby - 使用 ruby​​ 和 savon 的 SOAP 服务 - 2

    我正在尝试使用ruby​​和Savon来使用网络服务。测试服务为http://www.webservicex.net/WS/WSDetails.aspx?WSID=9&CATID=2require'rubygems'require'savon'client=Savon::Client.new"http://www.webservicex.net/stockquote.asmx?WSDL"client.get_quotedo|soap|soap.body={:symbol=>"AAPL"}end返回SOAP异常。检查soap信封，在我看来soap请求没有正确的命名空间。任何人都可以建议我

  7. python - 如何使用 Ruby 或 Python 创建一系列高音调和低音调的蜂鸣声？ - 2

    关闭。这个问题是opinion-based.它目前不接受答案。想要改进这个问题？更新问题，以便editingthispost可以用事实和引用来回答它.关闭4年前。Improvethisquestion我想在固定时间创建一系列低音和高音调的哔哔声。例如:在150毫秒时发出高音调的蜂鸣声在151毫秒时发出低音调的蜂鸣声200毫秒时发出低音调的蜂鸣声250毫秒的高音调蜂鸣声有没有办法在Ruby或Python中做到这一点？我真的不在乎输出编码是什么(.wav、.mp3、.ogg等等)，但我确实想创建一个输出文件。

  8. ruby-on-rails - 'compass watch' 是如何工作的/它是如何与 rails 一起使用的 - 2

    我在我的项目目录中完成了compasscreate.和compassinitrails。几个问题:我已将我的.sass文件放在public/stylesheets中。这是放置它们的正确位置吗？当我运行compasswatch时，它不会自动编译这些.sass文件。我必须手动指定文件:compasswatchpublic/stylesheets/myfile.sass等。如何让它自动运行？文件ie.css、print.css和screen.css已放在stylesheets/compiled。如何在编译后不让它们重新出现的情况下删除它们？我自己编译的.sass文件编译成compiled/t

  9. ruby - 使用 ruby​​ 将 HTML 转换为纯文本并维护结构/格式 - 2

    我想将html转换为纯文本。不过，我不想只删除标签，我想智能地保留尽可能多的格式。为插入换行符标签，检测段落并格式化它们等。输入非常简单，通常是格式良好的html(不是整个文档，只是一堆内容，通常没有anchor或图像)。我可以将几个正则表达式放在一起，让我达到80%，但我认为可能有一些现有的解决方案更智能。 最佳答案 首先，不要尝试为此使用正则表达式。很有可能你会想出一个脆弱/脆弱的解决方案，它会随着HTML的变化而崩溃，或者很难管理和维护。您可以使用Nokogiri快速解析HTML并提取文本:require'nokogiri'h

  10. ruby - 在 64 位 Snow Leopard 上使用 rvm、postgres 9.0、ruby 1.9.2-p136 安装 pg gem 时出现问题 - 2

    我想为Heroku构建一个Rails3应用程序。他们使用Postgres作为他们的数据库，所以我通过MacPorts安装了postgres9.0。现在我需要一个postgresgem并且共识是出于性能原因你想要pggem。但是我对我得到的错误感到非常困惑当我尝试在rvm下通过geminstall安装pg时。我已经非常明确地指定了所有postgres目录的位置可以找到但仍然无法完成安装:$envARCHFLAGS='-archx86_64'geminstallpg--\--with-pg-config=/opt/local/var/db/postgresql90/defaultdb/po

随机推荐