串口通信

lambda

我仿android-serial-api做的串口通信APP，对ttyS0~3进行读写操作发现并不能对ttyS0~3存取数据。
jni的代码

1. JNIEXPORT jobject JNICALL Java_com_example_liangzhanpeng_urat_SerialPort_open
   
2.   (JNIEnv *env, jclass thiz, jstring path, jint baudrate){
   
3.     int fd;
   
4.     speed_t speed;
   
5.     jclass mFileDescriptor;
   
6.     {
   
7.     speed = getBaudrate(baudrate);
   
8.     if (speed == -1){
   
9.     LOGE("invalid baudrate");
   
10.     return NULL;
    
11.     }
    
12.     }
    
13. 
    
14.     {
    
15.         jboolean iscopy;
    
16.         const char *path_utf = (*env)->GetStringUTFChars(env, path, &iscopy);
    
17. 
    
18.         LOGE("OPENING SERIAL PORT %s",path_utf);
    
19. 
    
20.         fd = open(path_utf,O_RDWR | O_NOCTTY | O_NONBLOCK | O_NDELAY);
    
21.         LOGD("open() fd = %d", fd);
    
22.         (*env)->ReleaseStringUTFChars(env,path,path_utf);
    
23.         if(fd == -1)
    
24.         {
    
25.             LOGE("cannot open port");
    
26.             return NULL;
    
27.         }
    
28.     }
    
29. 
    
30.     {
    
31.         struct termios cfg;
    
32.         LOGD("Configuring serial port");
    
33.         if(tcgetattr(fd,&cfg))
    
34.         {
    
35.             LOGE("tcgetattr() failed");
    
36.             close(fd);
    
37.             return NULL;
    
38.         }
    
39. 
    
40.         cfmakeraw(&cfg);
    
41.         cfsetispeed(&cfg,speed);
    
42.         cfsetospeed(&cfg,speed);
    
43. 
    
44.         if(tcsetattr(fd,TCSANOW,&cfg))
    
45.         {
    
46.             LOGE("tcsetattr() failed");
    
47.             close(fd);
    
48.             return NULL;
    
49.         }
    
50.     }
    
51.     {
    
52.         jclass cFileDescriptor = (*env)->FindClass(env, "java/io/FileDescriptor");
    
53.         jmethodID iFileDescriptor = (*env)->GetMethodID(env, cFileDescriptor, "<init>", "()V");
    
54.         jfieldID descriptorID = (*env)->GetFieldID(env, cFileDescriptor, "descriptor", "I");
    
55.         mFileDescriptor = (*env)->NewObject(env, cFileDescriptor, iFileDescriptor);
    
56.         (*env)->SetIntField(env, mFileDescriptor, descriptorID, (jint)fd);
    
57.     }
    
58.     return mFileDescriptor;
    
59.   }

复制代码

串口操作代码为

1. private FileDescriptor mfd;
   
2.     private FileInputStream mFileInputStream;
   
3.     private FileOutputStream outputStreaml;
   
4. 
   
5.     public SerialPort(File device,int baudrate) throws SecurityException,IOException{
   
6.         if (!device.canRead() || !device.canWrite()){
   
7.             try{
   
8.                 Process su;
   
9.                 su = Runtime.getRuntime().exec("/system/xbin/su");
   
10. 
    
11.                 Log.i(TAG, "SerialPort: "+su.toString());
    
12.                 String cmd = "chmod 777 " + device.getAbsolutePath() + "\n" + "exit\n";
    
13.                 Log.i(TAG, "SerialPort: " + cmd.toString());
    
14.                 su.getOutputStream().write(cmd.getBytes());
    
15. 
    
16.                 if ((su.waitFor() != 0) || !device.canRead() || !device.canWrite()){
    
17.                     throw new SecurityException();
    
18.                 }
    
19.             }catch (Exception e){
    
20.                 e.printStackTrace();
    
21.                 throw new SecurityException();
    
22.             }
    
23.         }
    
24.         Log.i(TAG, "SerialPort is can read?"+device.canRead());
    
25.         Log.i(TAG,"SerialPort is can writter" + device.canWrite());
    
26.         mfd = open(device.getAbsolutePath(),baudrate);
    
27.         if(mfd == null){
    
28.             Log.e(TAG,"native open return null");
    
29. 
    
30.         }
    
31.         Log.i(TAG, "SerialPort>>>"+ mfd);
    
32.         mFileInputStream = new FileInputStream(mfd);
    
33.         outputStreaml = new FileOutputStream(mfd);
    
34.     }
    
35.     public InputStream getInputStream(){
    
36.         return mFileInputStream;
    
37.     }
    
38.     public OutputStream getOutputStream(){
    
39.         return outputStreaml;
    
40.     }
    
41.     private native static FileDescriptor open(String path, int baudrate);
    
42.     public native void close();
    
43.     static {
    
44.         System.loadLibrary("serialport");
    
45.     }

复制代码

MainActivity代码为

1. public void onClick(View view) {
   
2.         switch (view.getId()){
   
3.             case R.id.setup:
   
4. 
   
5.             try{
   
6.                 sp = new SerialPort(new File("/dev/ttyS0"),115200);
   
7.             }catch (SecurityException e){
   
8.                 e.printStackTrace();
   
9.             }catch (IOException e){
   
10.                 e.printStackTrace();
    
11.             }
    
12.                 fileInputStream = sp.getInputStream();
    
13.                 fileOutputStream = sp.getOutputStream();
    
14.                 break;
    
15.             case R.id.send:
    
16.                 try {
    
17.                     String str = "abc123";
    
18.                     byte[] a = str.getBytes();
    
19.                     byte b = 1;
    
20.                     Log.i(TAG, "send>>> "+a[0]+a[1]+a[2]);
    
21.                     fileOutputStream.write(a);
    
22.                     fileOutputStream.write('\n');
    
23.                 } catch (IOException e) {
    
24.                     e.printStackTrace();
    
25.                 }
    
26. 
    
27. 
    
28.                 Toast.makeText(getApplicationContext(), "send",
    
29.                         Toast.LENGTH_SHORT).show();
    
30.                 break;
    
31.             case R.id.recevicd:
    
32.                 int size;
    
33. 
    
34.                 try {
    
35.                     byte[] test = new byte[64];
    
36.                     fileInputStream.read(test);
    
37. 
    
38.                     byte[] buffer = new byte[64];
    
39.                     if (fileInputStream == null)
    
40.                         return;
    
41.                     Log.i(TAG, "onClick: "+ buffer.length);
    
42.                     Log.i(TAG, "recevied"+buffer.toString());
    
43.                     size = fileInputStream.read(buffer);
    
44.                     Log.i(TAG, "size>>>"+size);
    
45.                     if (size > 0) {
    
46.                         onDataReceived(buffer, size);
    
47. 
    
48.                     }
    
49.                 } catch (IOException e) {
    
50.                     e.printStackTrace();
    
51.                     return;
    
52.                 }
    
53. 
    
54.         }
    
55. 
    
56.     }
    
57.     void onDataReceived(final byte[] buffer, final int size) {
    
58.         runOnUiThread(new Runnable() {
    
59.             public void run() {
    
60.                 if (editText != null) {
    
61.                     Log.i(TAG, "run: "+new String(buffer, 0, size));
    
62.                     textView.setText(new String(buffer, 0, size));
    
63.                 }
    
64.             }
    
65.         });
    
66.     }

复制代码