最近好多做安卓端跟硬件交互的，比如一些智能家居，贩卖机的。
而这些不管是485也好，232的板子也好，都会用到串口通讯，去往下位机发送指令操控。下面是我个人的一些理解，发送串口指令的方法都是一样的，各位用的时候直接拷贝过去，改一下波特率和串口号就可以测试了。
总代码：一个activity，两个工具类，一个声明全局变量的类，布局有一个edit发送指令，一个发送按钮，一个接收数据显示的textview
至于jni的一些文件夹和一些so文件就要自己去弄了，
activity的xml布局：
<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
android:layout_width="match_parent"
android:layout_height="match_parent"
android:orientation="vertical">
<EditText
android:id="@+id/et_main_input"
android:layout_width="match_parent"
android:layout_height="40dp"
android:background="@drawable/cycle_corner_border"
android:textSize="18sp"
android:layout_marginTop="10dp"
android:layout_marginLeft="20dp"
android:layout_marginRight="20dp"
android:paddingLeft="8dp"
android:hint="输入的指令"/>
<Button
android:id="@+id/btn_main_send"
android:layout_width="100dp"
android:layout_height="wrap_content"
android:layout_gravity="center_horizontal"
android:text="发送"/>
<TextView
android:id="@+id/tv_main_show"
android:layout_width="match_parent"
android:layout_height="wrap_content"
android:textSize="18sp"
android:layout_marginTop="10dp"
android:layout_marginLeft="20dp"
android:layout_marginRight="20dp"
android:hint="这里显示接收到的串口数据"/>
</LinearLayout>
MainActivity:
public class MainActivity extends Activity {
private EditText editInput;
private Button btnSend;
private static TextView textShow;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
init();
}
/**
* 初始化UI控件
*/
private void init() {
editInput = findViewById(R.id.et_main_input);
btnSend = findViewById(R.id.btn_main_send);
textShow = findViewById(R.id.tv_main_show);
//打开串口
SerialPortUtil.openSrialPort();
btnSend.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
onSend();//点击发送调用onSend
}
});
}
/**
* 发送串口数据
*/
private void onSend() {
String input = editInput.getText().toString();
if(TextUtils.isEmpty(input)){
editInput.setError("要发送的数据不能为空");
return;
}
//发送指令
SerialPortUtil.sendSerialPort(input);
}
/**
* 刷新UI界面
* @param data 接收到的串口数据
*/
public static void refreshTextView(String data){
Log.i(TAG, "refreshTextView: "+strTo16(data));//打印接收到的数据
textShow.setText(textShow.getText().toString()+";"+strTo16(data));
}
/**
* 字符串转化成为16进制字符串
* @param s
* @return
*/
public static String strTo16(String s) {
String str = "";
for (int i = 0; i < s.length(); i++) {
int ch = (int) s.charAt(i);
String s4 = Integer.toHexString(ch);
str = str + s4;
}
return str;
}
}
SerialPortUtil工具类
public class SerialPortUtil {
public static SerialPort serialPort = null;
public static InputStream inputStream = null;
public static OutputStream outputStream = null;
public static Thread receiveThread = null;
public static boolean flag = false;
public static Handler handler = new Handler() {
@Override
public void handleMessage(Message msg) {
}
};
/**
* 打开串口的方法
*/
public static void openSrialPort(){
Log.i("test","打开串口");
try {
serialPort = new SerialPort(new File("/dev/"+ IConstant.PORT),IConstant.BAUDRATE,0);
//获取打开的串口中的输入输出流，以便于串口数据的收发
inputStream = serialPort.getInputStream();
outputStream = serialPort.getOutputStream();
flag = true;
receiveSerialPort();
} catch (IOException e) {
e.printStackTrace();
}
}
/**
*关闭串口的方法
* 关闭串口中的输入输出流
* 然后将flag的值设为flag，终止接收数据线程
*/
public static void closeSerialPort(){
Log.i("test","关闭串口");
try {
if(inputStream != null) {
inputStream.close();
}
if(outputStream != null){
outputStream.close();
}
flag = false;
} catch (IOException e) {
e.printStackTrace();
}
}
/**
* 发送串口数据的方法
* @param data 要发送的数据
*/
public static void sendSerialPort(String data){
Log.i("test","发送串口数据");
try {
byte[] sendData = data.getBytes();
outputStream.write(sendData);
outputStream.flush();
Log.i(TAG, "sendSerialPort: "+sendData);
Log.i("test","串口数据发送成功");
} catch (IOException e) {
e.printStackTrace();
Log.i("test","串口数据发送失败");
}
}
/**
* 接收串口数据的方法
*/
public static void receiveSerialPort(){
Log.i("test","接收串口数据");
if(receiveThread != null)
return;
/*定义一个handler对象要来接收子线程中接收到的数据
并调用Activity中的刷新界面的方法更新UI界面
*/
final Handler handler = new Handler(){
@Override
public void handleMessage(Message msg) {
MainActivity.refreshTextView(msg.getData().getString("data"));
}
};
/*创建子线程接收串口数据
*/
receiveThread = new Thread(){
@Override
public void run() {
while (flag) {
try {
byte[] readData = new byte[1024];
if (inputStream == null) {
return;
}
int size = inputStream.read(readData);
if (size>0 && flag) {
String recinfo = new String(readData,0,size);
Log.i("test", "接收到串口数据:" + recinfo);
/*将接收到的数据封装进Message中，然后发送给主线程
*/
Message message = new Message();
Bundle bundle = new Bundle();
bundle.putString("data",recinfo);
message.setData(bundle);
handler.sendMessage(message);
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
};
//启动接收线程
receiveThread.start();
}
}
SerialPort类
public class SerialPort {
private static final String TAG = "SerialPort";
private FileDescriptor mFd;
private FileInputStream mFileInputStream;
private FileOutputStream mFileOutputStream;
public SerialPort(File device, int baudrate, int flags) throws SecurityException, IOException {
//检查访问权限，如果没有读写权限，进行文件操作，修改文件访问权限
if (!device.canRead() || !device.canWrite()) {
try {
//通过挂载到linux的方式，修改文件的操作权限
Process su = Runtime.getRuntime().exec("/system/xbin/su");
String cmd = "chmod 777 " + device.getAbsolutePath() + "\n" + "exit\n";
su.getOutputStream().write(cmd.getBytes());
if ((su.waitFor() != 0) || !device.canRead() || !device.canWrite()) {
throw new SecurityException();
}
} catch (Exception e) {
e.printStackTrace();
throw new SecurityException();
}
}
mFd = open(device.getAbsolutePath(), baudrate, flags);
if (mFd == null) {
Log.e(TAG, "native open returns null");
throw new IOException();
}
mFileInputStream = new FileInputStream(mFd);
mFileOutputStream = new FileOutputStream(mFd);
}
// Getters and setters
public InputStream getInputStream() {
return mFileInputStream;
}
public OutputStream getOutputStream() {
return mFileOutputStream;
}
// JNI(调用java本地接口，实现串口的打开和关闭)
/**串口有五个重要的参数：串口设备名，波特率，检验位，数据位，停止位
其中检验位一般默认位NONE,数据位一般默认为8，停止位默认为1*/
/**
* @param path 串口设备的据对路径
* @param baudrate 波特率
* @param flags 校验位
*/
private native static FileDescriptor open(String path, int baudrate, int flags);
public native void close();
static {//加载jni下的C文件库
System.loadLibrary("serial_port");
}
}
IConstant
public interface IConstant {
String PORT = "填写你那边需要连接的串口号";//串口号
int BAUDRATE = ;//波特率
}
网友评论