android即时通讯demo开源（android studio实现聊天功能）
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地址
“android即时通讯demo开源（android studio实现聊天功能）” 的相关文章
乌克兰安全局宣称逮捕了协助俄军开展通讯中继服务的黑客
Vice 报道称，在最近一次行动中，乌克兰安全局（SBU）声称抓获了一名在乌境内为俄军提供通信服务的黑客。在当天上午 10 点发布的推文和电报消息中，SBU 分享了本次行动的诸多细节。尽管尚未得到另一独立消息源的证实，但我们已经看到了面部打码的黑客、以及所谓的通信系统照片。 电报帖子指出，黑客...
Microsoft Defender 又一次误将 Google Chrome 更新视作可疑活动
近日，我们在 Twitter 和 Reddit 等平台上见到了不少系统管理员报告，可知问题主要集中在被 Microsoft Defender for Endpoint 安全防护软件标记为“可疑”的 Google Chrome 更新上。由于谷歌更新服务（GoogleUpdate.exe）没有给“goo...
美政府提醒区块链行业警惕 Lazarus Group 加密货币木马应用程序
在周一发布的联合公告中，美国网络与基础设施安全局（CISA）、联邦调查局（FBI）和财政部指出 —— 被称作 Lazarus Group 的黑客组织，正在使用被植入木马的加密货币应用程序，向区块链行业的各个组织发起攻击。据说受害者中包括加密货币交易所、风投、持有大量加密货币 / 非同质化代币（NFT...
BlackMatter 勒索软件营运者称因地方当局压力而停业
BlackMatter勒索软件背后的犯罪集团今天宣布计划关闭其业务，理由是来自地方当局的压力。该组织在其 “勒索软件即服 “门户后台发布的一条信息中宣布了其计划，其他犯罪集团通常在这里注册，以获得BlackMatter勒索软件的使用权。 这条消息是由vx-underground信息安全小组的一名成员...
英国监管机构要求运营商关闭加密货币 ATM 机
在英国，购买比特币最简单、最匿名的方式之一是前往选定的商店，使用比特币自动取款机，你只需存入现金，然后将比特币发送到你的比特币钱包。英国金融行为监管局（FCA）现在正命令经营这些自动取款机的公司关闭它们，因为它们没有实施旨在防止洗钱的KYC措施。 要在英国运营，加密货币自动取款机应在FCA注册，并...
三星手机被曝重大漏洞 运行 Android 9 至 12 的所有机型均受影响
4月6日消息，安全公司Kryptowire警告说，三星的各种设备都容易受到重大安全漏洞的影响，该漏洞允许黑客接管设备。Kryptowire制作移动应用安全测试(MAST)，这是一种扫描漏洞以及安全和隐私问题的工具。 据该公司称，它发现了一个漏洞（CVE-2022-22292），该漏洞可能允许黑客采...
评论列表
发表评论
