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

Android串口通信可以实现设备与设备之间通过设备线连接进行数据（消息）传递（一）导入so库（二）在moudle的build中添加jniLibsbuildTypes{sourceSets{main{jni.srcDirs=[]}}}12345（三）添加Google的SerialPort添加的是Google的所以必须创建android_serialport_api包如需要更改SerialPort、

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 renquan */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,int baudrate){try {serialPort = new SerialPort(new File(path),baudrate,0);this.serialPortStatus = true;threadStatus = false; //线程状态//获取打开的串口中的输入输出流，以便于串口数据的收发inputStream = serialPort.getInputStream();outputStream = serialPort.getOutputStream();new ReadThread().start(); //开始线程监控是否有数据要接收} catch (IOException e) {Log.e(TAG, "openSerialPort: 打开串口异常：" + e.toString());return serialPort;}Log.d(TAG, "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, "closeSerialPort: 关闭串口异常："+e.toString());return;}Log.d(TAG, "closeSerialPort: 关闭串口成功");}/*** 发送串口指令（字符串）* @param data String数据指令*/public void sendSerialPort(String data){Log.d(TAG, "sendSerialPort: 发送数据");try {byte[] sendData = data.getBytes(); //string转byte[]this.data_ = new String(sendData); //byte[]转stringif (sendData.length > 0) {outputStream.write(sendData);outputStream.write('n');//outputStream.write('r'+'n');outputStream.flush();Log.d(TAG, "sendSerialPort: 串口数据发送成功");}} catch (IOException e) {Log.e(TAG, "sendSerialPort: 串口数据发送失败："+e.toString());}}/*** 单开一线程，来读数据*/private class ReadThread extends Thread{@Overridepublic void run() {super.run();//判断进程是否在运行，更安全的结束进程while (!threadStatus){Log.d(TAG, "进入线程run");//641024byte[] buffer = new byte[64];int size; //读取数据的大小try {size = inputStream.read(buffer);if (size > 0){Log.d(TAG, "run: 接收到了数据：" + changeTool.ByteArrToHex(buffer));Log.d(TAG, "run: 接收到了数据大小：" + String.valueOf(size));onDataReceiveListener.onDataReceive(buffer,size);}} catch (IOException e) {Log.e(TAG, "run: 数据读取异常：" +e.toString());}}}}//数据回调public OnDataReceiveListener onDataReceiveListener = null;public static interface OnDataReceiveListener {public void onDataReceive(byte[] buffer, int size);}public void setOnDataReceiveListener(OnDataReceiveListener dataReceiveListener) {onDataReceiveListener = dataReceiveListener;}}123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131
package com.demo.serialport;/** * @author renquan */public class ChangeTool {/*** byte数组转16进制字符串** @param bytes byte数组* @return 16进制字符串*/public String ByteArrToHex(byte[] bytes) {String strHex;StringBuilder sb = new StringBuilder();for (byte aByte : bytes) {strHex = Integer.toHexString(aByte & 0xFF);sb.append(" ").append((strHex.length() == 1) ? "0" : ").append(strHex); // 每个字节由两个字符表示，位数不够，高位补0}return sb.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 renquan */public class MainActivity extends AppCompatActivity implements View.OnClickListener {private EditText mMessage;private Button mOpen;private Button mSend;private Button mClose;private SerialPortUtils serialPortUtils;@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_main);init();//串口数据监听事件serialPortUtils.setOnDataReceiveListener(new SerialPortUtils.OnDataReceiveListener() {@Overridepublic void onDataReceive(byte[] buffer, int size) {Log.d("TAG", "进入数据监听事件中。。。" + 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);}@Overridepublic void onClick(View v) {switch (v.getId()) {case R.id.open:// TODO 20/12/28serialPortUtils.openSerialPort("/dev/ttyS9",9600);break;case R.id.send:// TODO 20/12/28serialPortUtils.sendSerialPort(mSend.getText().toString());break;case R.id.close:serialPortUtils.closeSerialPort();// TODO 20/12/28break;default:break;}}}1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374
Demo——github地址