当前位置：首页 > 网站入侵 > 正文内容

android即时通讯demo开源（android studio实现聊天功能）

访客3年前 (2022-01-26)网站入侵561

Android串口通信可以实现设备与设备之间通过设备线连接进行数据（消息）传递
（一）导入so库

（二）在moudle的build中添加jniLibs

buildTypes {
        sourceSets {
            main { jni.srcDirs = [] }
        }
    }
12345

（三）添加Google的SerialPort
添加的是Google的所以必须创建android_serialport_api包
如需要更改SerialPort、SerialPortFinder位置需要重新生成so库

（四）创建串口通信工具类SerialPortUtils

package com.demo.serialport;

import android.util.Log;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import android_serialport_api.SerialPort;

/**
 * @author  *** 
 */

public class SerialPortUtils {

    private final String TAG = "SerialPortUtils";
//    private String path = "/dev/ttyS1";
//    private int baudrate = 9600;
    public boolean serialPortStatus = false; //是否打开串口标志
    public String data_;
    public boolean threadStatus; //线程状态，为了安全终止线程

    public SerialPort serialPort = null;
    public InputStream inputStream = null;
    public OutputStream outputStream = null;
    public ChangeTool changeTool = new ChangeTool;


    /**
     * 打开串口
     * @return serialPort串口对象
     */
    public SerialPort openSerialPort(String path%2cint baudrate){
        try {
            serialPort = new SerialPort(new File(path)%2cbaudrate%2c0);
            this.serialPortStatus = true;
            threadStatus = false; //线程状态

            //获取打开的串口中的输入输出流，以便于串口数据的收发
            inputStream = serialPort.getInputStream;
            outputStream = serialPort.getOutputStream;

            new ReadThread.start; //开始线程监控是否有数据要接收
        } catch (IOException e) {
            Log.e(TAG%2c "openSerialPort: 打开串口异常：" + e.toString);
            return serialPort;
        }
        Log.d(TAG%2c "openSerialPort: 打开串口");
        return serialPort;
    }

    /**
     * 关闭串口
     */
    public void closeSerialPort{
        try {
            inputStream.close;
            outputStream.close;

            this.serialPortStatus = false;
            this.threadStatus = true; //线程状态
            serialPort.close;
        } catch (IOException e) {
            Log.e(TAG%2c "closeSerialPort: 关闭串口异常："+e.toString);
            return;
        }
        Log.d(TAG%2c "closeSerialPort: 关闭串口成功");
    }

    /**
     * 发送串口指令（字符串）
     * @param data String数据指令
     */
    public void sendSerialPort(String data){
        Log.d(TAG%2c "sendSerialPort: 发送数据");

        try {
            byte[] sendData = data.getBytes; //string转byte[]
            this.data_ = new String(sendData); //byte[]转string
            if (sendData.length > 0) {
                outputStream.write(sendData);
                outputStream.write('n');
                //outputStream.write('r'+'n');
                outputStream.flush;
                Log.d(TAG%2c "sendSerialPort: 串口数据发送成功");
            }
        } catch (IOException e) {
            Log.e(TAG%2c "sendSerialPort: 串口数据发送失败："+e.toString);
        }

    }

    /**
     * 单开一线程，来读数据
     */
    private class ReadThread extends Thread{
        @Override
        public void run {
            super.run;
            //判断进程是否在运行，更安全的结束进程
            while (!threadStatus){
                Log.d(TAG%2c "进入线程run");
                //64   1024
                byte[] buffer = new byte[64];
                int size; //读取数据的大小
                try {
                    size = inputStream.read(buffer);
                    if (size > 0){
                        Log.d(TAG%2c "run: 接收到了数据：" + changeTool.ByteArrToHex(buffer));
                        Log.d(TAG%2c "run: 接收到了数据大小：" + String.valueOf(size));
                        onDataReceiveListener.onDataReceive(buffer%2csize);
                    }
                } catch (IOException e) {
                    Log.e(TAG%2c "run: 数据读取异常：" +e.toString);
                }
            }

        }
    }

    //数据回调
    public OnDataReceiveListener onDataReceiveListener = null;
    public static interface OnDataReceiveListener {
        public void onDataReceive(byte[] buffer%2c int size);
    }
    public void setOnDataReceiveListener(OnDataReceiveListener dataReceiveListener) {
        onDataReceiveListener = dataReceiveListener;
    }

}

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131

package com.demo.serialport;

/**
 * @author  *** 
 */

public class ChangeTool {

    /**
     * byte数组转16进制字符串
     *
     * @param bytes byte数组
     * @return 16进制字符串
     */
    public String ByteArrToHex(byte[] bytes) {
        String strHex;
        StringBuilder  ***  = new StringBuilder;
        for (byte aByte : bytes) {
            strHex = Integer.toHexString(aByte & 0xFF);
             *** .append(" ").append((strHex.length == 1) ? "0" : "").append(strHex); // 每个字节由两个字符表示，位数不够，高位补0
        }
        return  *** .toString.trim;
    }

    /**
     * byte字节转int
     *
     * @param b byte字节
     * @return int
     */
    public static int byteToInt(byte b) {
        int x = b & 0xff;
        if (x == 127) {
            return 0;
        }
        return x;
    }
}

123456789101112131415161718192021222324252627282930313233343536373839

package com.demo.serialport;

import android.os.Bundle;
import android.util.Log;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;

import androidx.appcompat.app.AppCompatActivity;

/**
 * @author  *** 
 */

public class MainActivity extends AppCompatActivity implements View.OnClickListener {
    private EditText mMessage;
    private Button mOpen;
    private Button mSend;
    private Button mClose;
    private SerialPortUtils serialPortUtils;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        init;


        //串口数据监听事件
        serialPortUtils.setOnDataReceiveListener(new SerialPortUtils.OnDataReceiveListener {
            @Override
            public void onDataReceive(byte[] buffer%2c int size) {
                Log.d("TAG"%2c "进入数据监听事件中。。。" + new String(buffer));

            }
        });

    }

    private void init {
        initView;
        serialPortUtils = new SerialPortUtils;
    }

    private void initView {
        mMessage = (EditText) findViewById(R.id.message);
        mOpen = (Button) findViewById(R.id.open);
        mOpen.setOnClickListener(this);
        mSend = (Button) findViewById(R.id.send);
        mSend.setOnClickListener(this);
        mClose = (Button) findViewById(R.id.close);
        mClose.setOnClickListener(this);
    }

    @Override
    public void onClick(View v) {
        switch (v.getId) {
            case R.id.open:
                // TODO 20/12/28
                serialPortUtils.openSerialPort("/dev/ttyS9"%2c9600);
                break;
            case R.id.send:
                // TODO 20/12/28
                serialPortUtils.sendSerialPort(mSend.getText.toString);
                break;
            case R.id.close:
                serialPortUtils.closeSerialPort;
                // TODO 20/12/28
                break;
            default:
                break;
        }
    }
}
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374

Demo——github地址

扫描二维码推送至手机访问。

本文链接：http://w-123.com/90329.html

标签: 网站随笔

返回列表

上一篇：农信小额贷款有用吗_农商银行小额贷款条件

下一篇：苹果7现在多少钱一部（iphone7官网价格）

“android即时通讯demo开源（android studio实现聊天功能）” 的相关文章

哥斯达黎加政府部分网络系统因遭黑客攻击仍处于关闭状态

截至当地时间4月22日，因遭到国际黑客攻击，哥斯达黎加部分政府公共服务网络仍处于关闭状态。哥斯达黎加总统阿尔瓦拉多此前一天对此表示谴责。他表示，哥斯达黎加不会向国际黑客组织妥协，目前有关部门正在加紧网络管理技术升级，加固网络安全，同时评估泄漏数据的规模和损失，与国际组织和公司合作，加紧恢复受损系统。...

DLL 反制：安全研究人员提出阻止勒索软件加密文件的新策略

尽管恶意软件开发者擅长利用各种软硬件漏洞来达成目的，但他们散播的成品也并非毫无破绽。比如近日，安全研究人员 John Page（又名 hyp3rlinx）就介绍了一招反制勒索软件的新套路。由个人网站和 Twitter 账号上发布的内容可知，John Page 专精于找到恶意软件本身的漏洞，并于近日分...

美国联邦调查局通缉 23 岁俄罗斯黑客

Hackernews 编译，转载请注明出处：一名23岁的俄罗斯人在美国被起诉，并被列入美国联邦调查局网络通缉名单，因为他被指控是一家网络犯罪论坛 Marketplace A的管理员，该论坛出售被盗的登录凭证、个人信息和信用卡数据。伊戈尔 · 德赫蒂亚克(Igor Dekhty...

疫情期间网络犯罪分子加大了攻击力度首选支付方式是加密货币

利用新冠疫情，网络犯罪分子发起各种攻击而尽可能地牟利。欧盟网络安全机构 Enisa 强调，这类活动导致雇佣黑客在过去 15 个月中成为网络安全的最大威胁。 2020 年 4 月至 2021 年 7 月进行的研究的年度报告中，Enisa 表示 COVID-19 疫情期间观察到网络犯罪分子加大了针对潜在...

英国监管机构要求运营商关闭加密货币 ATM 机

在英国，购买比特币最简单、最匿名的方式之一是前往选定的商店，使用比特币自动取款机，你只需存入现金，然后将比特币发送到你的比特币钱包。英国金融行为监管局（FCA）现在正命令经营这些自动取款机的公司关闭它们，因为它们没有实施旨在防止洗钱的KYC措施。要在英国运营，加密货币自动取款机应在FCA注册，并...

三星手机被曝重大漏洞运行 Android 9 至 12 的所有机型均受影响

4月6日消息，安全公司Kryptowire警告说，三星的各种设备都容易受到重大安全漏洞的影响，该漏洞允许黑客接管设备。Kryptowire制作移动应用安全测试(MAST)，这是一种扫描漏洞以及安全和隐私问题的工具。据该公司称，它发现了一个漏洞（CVE-2022-22292），该漏洞可能允许黑客采...