初识Android串口通信(一)

private Vector<Driver> mDrivers = null;

Vector<Driver> getDrivers() throws IOException {
	if (mDrivers == null) {
		mDrivers = new Vector<Driver>();
		LineNumberReader r = new LineNumberReader(new FileReader("/proc/tty/drivers"));
		String l;
		while((l = r.readLine()) != null) {
			// Issue 3:
			// Since driver name may contain spaces, we do not extract driver name with split()
			String drivername = l.substring(0, 0x15).trim();
			String[] w = l.split(" +");
			if ((w.length >= 5) && (w[w.length-1].equals("serial"))) {
				Log.d(TAG, "Found new driver " + drivername + " on " + w[w.length-4]);
				mDrivers.add(new Driver(drivername, w[w.length-4]));
			}
		}
		r.close();
	}
	return mDrivers;
}


public String[] getAllDevicesList() {
	Vector<String> devices = new Vector<String>();
	// Parse each driver
	Iterator<Driver> itdriv;
	try {
		itdriv = getDrivers().iterator();
		while(itdriv.hasNext()) {
			Driver driver = itdriv.next();
			for (File file : driver.getDevices()) {
				String device = file.getAbsolutePath();
				devices.add(device);
			}
		}
	} catch (IOException e) {
		e.printStackTrace();
	}
	return devices.toArray(new String[devices.size()]);
}

private List<String> getDevTtyList() {
	try {
		String getRes = performSuCommandAndGetRes("ls /dev/tty*");
		ArrayList<String> list = new ArrayList<>(Arrays.asList(getRes.split("/dev/")));
		list.remove("");
		return list;
	} catch (Exception e) {
		MyLogger.e(e, e.getMessage());
		return null;
	}
}

public static String performSuCommandAndGetRes(String cmd)
	throws InterruptedException {
	int repeatTimes = 5;
	for (int i = 0; i < repeatTimes; i++) {
		String result = "";
		DataOutputStream dos = null;
		DataInputStream dis = null;
		Process p = null;
		try {
			p = Runtime.getRuntime().exec("su");
			dos = new DataOutputStream(p.getOutputStream());
			dis = new DataInputStream(p.getInputStream());
			dos.writeBytes(cmd + "; echo \"suCmdRes=\"$?\n");
			dos.flush();
			dos.writeBytes("exit\n");
			dos.flush();

			String line = "";
			BufferedReader din = new BufferedReader(new InputStreamReader(
				dis));
			while ((line = din.readLine()) != null) {
				result += line;
			}
			p.waitFor();
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			if (dos != null) {
				try {
					dos.close();
				} catch (IOException e) {
					e.printStackTrace();
				}
			}
			if (dis != null) {
				try {
					dis.close();
				} catch (IOException e) {
					e.printStackTrace();
				}
			}
			if (p != null) {
				try {
					p.destroy();
				} catch (Exception e2) {
				}
			}
		}

		Log.i("sudo", cmd + " = " + result);
		if (result != null && result.contains("suCmdRes") == true) {
			for (int j = -5; j < 5; j++) {
				result = result.replace("suCmdRes=" + j, "");
			}
			return result;
		} else {
			if (i == repeatTimes - 1)
				break;
			Thread.sleep(1500);
		}
	}

	return null;
}

implementation 'com.github.licheedev:Android-SerialPort-API:2.0.0'

import android.serialport.SerialPort;
import android.serialport.SerialPortCallback;
import android.serialport.SerialPortFinder;

import java.io.IOException;

public class SerialPortDemo {

	private SerialPort mSerialPort;
	private SerialPortCallback mCallback;

	// 串口配置参数
	private String mDevicePath = "/dev/ttyS1";  // 串口设备路径
	private int mBaudRate = 9600;  // 波特率
	private int mDataBits = 8;  // 数据位
	private int mStopBits = 1;  // 停止位
	private int mParity = 0;  // 奇偶校验位

	public void openSerialPort() {
		try {
			// 打开串口
			mSerialPort = new SerialPort(mDevicePath, mBaudRate, mDataBits, mStopBits, mParity);
			// 创建串口回调
			mCallback = new SerialPortCallback() {
				@Override
				public void onDataReceived(byte[] buffer, int size) {
					// 处理接收到的数据
					String data = new String(buffer, 0, size);
					System.out.println("Received data: " + data);
				}

				@Override
				public void onSerialPortClosed() {
					// 串口已关闭
					System.out.println("Serial port closed.");
				}

				@Override
				public void onError(Exception e) {
					// 发生异常
					e.printStackTrace();
				}
			};
			// 设置串口回调
			mSerialPort.setCallback(mCallback);
			// 启动监听
			mSerialPort.start();
			System.out.println("Serial port opened.");
		} catch (IOException e) {
			e.printStackTrace();
		}
	}

	public void closeSerialPort() {
		if (mSerialPort != null) {
			// 关闭串口
			mSerialPort.stop();
			// 释放资源
			mSerialPort = null;
			mCallback = null;
		}
	}
}