Android利用JNI通过Socket与服务器进行通信

2024-06-14 14:48

本文主要是介绍Android利用JNI通过Socket与服务器进行通信,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

不多说,先上代码。记得点击star哦,代码地址是:SocketDemo

上一篇文章写了如何通过Java层实现Socket和服务器的Socket进行通信,这一篇继续深究,写个如何通过native层实现socket和服务器进行通信。服务器端代码和前一篇博客 代码一致,主要看下Android端的代码。首先看下Main2Activity的代码:

Main2Activity.java

 

 
  1. package com.zqc.socketdemo;

  2.  
  3. import android.app.Activity;

  4. import android.content.Context;

  5. import android.os.Bundle;

  6. import android.os.Handler;

  7. import android.os.Looper;

  8. import android.view.View;

  9. import android.widget.Button;

  10. import android.widget.TextView;

  11.  
  12. public class Main2Activity extends Activity implements View.OnClickListener {

  13.  
  14. private TextView tv;

  15. private Button bt;

  16. Handler handler;

  17. private Context mContext;

  18.  
  19. @Override

  20. protected void onCreate(Bundle savedInstanceState) {

  21. super.onCreate(savedInstanceState);

  22. setContentView(R.layout.activity_main2);

  23. tv = (TextView) findViewById(R.id.textView);

  24. bt = (Button) findViewById(R.id.button);

  25. bt.setOnClickListener(this);

  26. mContext = this;

  27. handler = new Handler(Looper.getMainLooper());

  28. }

  29.  
  30. @Override

  31. public void onClick(View v) {

  32. switch (v.getId()) {

  33. case R.id.button:

  34. new Thread(){//网络连接需要在线程中实现

  35. @Override

  36. public void run() {

  37. SocketJNI.connect(mContext, "10.18.73.62", 6868);//和服务器进行socket通信

  38. }

  39. }.start();

  40. break;

  41. }

  42. }

  43.  
  44. }

对应的xml布局是

 

activity_main2.xml

 

 
  1. <?xml version="1.0" encoding="utf-8"?>

  2. <RelativeLayout xmlns:android="http://schemas.android.com/apk/res/android"

  3. xmlns:tools="http://schemas.android.com/tools"

  4. android:id="@+id/activity_main2"

  5. android:layout_width="match_parent"

  6. android:layout_height="match_parent"

  7. tools:context="com.zqc.socketdemo.Main2Activity">

  8.  
  9. <TextView

  10. android:text="TextView"

  11. android:layout_width="wrap_content"

  12. android:layout_height="wrap_content"

  13. android:layout_below="@+id/button"

  14. android:layout_alignStart="@+id/button"

  15. android:layout_marginTop="69dp"

  16. android:id="@+id/textView" />

  17.  
  18. <Button

  19. android:text="Button"

  20. android:layout_width="wrap_content"

  21. android:layout_height="wrap_content"

  22. android:layout_marginTop="11dp"

  23. android:id="@+id/button"

  24. android:layout_marginStart="27dp"

  25. android:layout_alignParentTop="true"

  26. android:layout_alignParentStart="true" />

  27. </RelativeLayout>

其中SocketJNI.java的代码很简单,代码如下:

 

 

 
  1. package com.zqc.socketdemo;

  2.  
  3. import android.content.Context;

  4.  
  5. /**

  6. * Created by zhangqianchu on 2017/8/2.

  7. */

  8.  
  9. public class SocketJNI {

  10. static {

  11. System.loadLibrary("mysocket");

  12. }

  13. public native static void connect(Context mContext, String ip, int port);//这里定义了一个jni方法,在native层实现socket连接

  14. }

在SocketJNI.java类中定义了一个jni方法,即提供一个Java层的调用,具体代码在native层实现。下面看看native层的代码

 

 

 
  1. #include <jni.h>

  2. #include <string.h>

  3. #include "socketutil.h"

  4.  
  5.  
  6. void showToast(JNIEnv *env, jobject context, jstring str) {

  7. jclass tclss = (*env)->FindClass(env,"android/widget/Toast");

  8. jmethodID mid = (*env)->GetStaticMethodID(env,tclss,"makeText","(Landroid/content/Context;Ljava/lang/CharSequence;I)Landroid/widget/Toast;");

  9. jobject job = (*env)->CallStaticObjectMethod(env,tclss,mid,context,str);

  10. jmethodID showId = (*env)->GetMethodID(env,tclss,"show","()V");

  11. (*env)->CallVoidMethod(env,job,showId,context,str);

  12. }

  13.  
  14. JNIEXPORT void JNICALL Java_com_zqc_socketdemo_SocketJNI_connect

  15. (JNIEnv *env, jclass jcz, jobject context, jstring addr, jint port) {

  16. jstring msg = (*env)->NewStringUTF(env,"start");

  17. //showToast(env,context,msg);//show的时候会出现暂时卡顿,原因不明

  18. LOGI("connect socket.");

  19. const char* response = connectRemote("10.18.73.62", 6868); //response就是服务端传给客户端的内容

  20. release();

  21. LOGI("connect socket end.");

  22. //msg = (*env)->NewStringUTF(env,response);

  23. //showToast(env,context,msg);/

  24. }

这里将socket的具体实现放到socketutil.h里面进行实现,避免代码耦合。

 

socketutil.h

 
  1. #ifndef SOCKET_UTIL

  2. #define SOCKET_UTIL

  3. #include <jni.h>

  4. #include <android/log.h>

  5.  
  6. #define LOG_TAG "mysocket"

  7. #define LOGI(...) __android_log_print(ANDROID_LOG_INFO,LOG_TAG,__VA_ARGS__)

  8.  
  9. void release();

  10. const char* connectRemote(const char*,const int);

  11. #endif

socketutil.c 

 
  1. #include <jni.h>

  2. #include <stdio.h>

  3. #include <string.h>

  4. #include <android/log.h>

  5. #include "socketutil.h"

  6. #include <sys/socket.h>

  7. #include <netinet/in.h>

  8. #include <stdlib.h>

  9. #include <android/log.h>

  10.  
  11. #define MAXSIZE 4096

  12. struct sockaddr_in sock_add;

  13. struct sockaddr_in server_addr;

  14. int sockfd = 0;

  15.  
  16. void release(){

  17. close(sockfd);

  18. }

  19.  
  20. const char* connectRemote(const char* addr,const int port) {

  21. sockfd = socket(AF_INET, SOCK_STREAM, 0); //ipv4,TCP数据连接

  22. LOGI("step1");

  23. if (sockfd < 0) {

  24. return "socket error";

  25. }

  26. //服务器地址

  27. bzero(&server_addr,sizeof(server_addr));

  28. server_addr.sin_family = AF_INET;

  29. server_addr.sin_port = htons(port);

  30. LOGI("step2");

  31. if( inet_pton(AF_INET, addr, &server_addr.sin_addr) < 0){ //设置ip地址

  32. LOGI("address error");

  33. return "address error";

  34. }

  35. socklen_t server_addr_length = sizeof(server_addr);

  36. int connfd = connect(sockfd, (struct sockaddr*)&server_addr, sizeof(server_addr)); //连接到服务器

  37. LOGI("step3");

  38. if (connfd < 0) {

  39. return "connect error";

  40. }

  41. //发送数据

  42. char *msg = "i send a data to server. \n";

  43. int sdf = send(sockfd, msg , strlen(msg), 0); //发送一行数据到服务器

  44. LOGI("step4.");

  45. char buff[4096];

  46. int n = recv(sockfd, buff, MAXSIZE ,0); //这地方应该需要循环获取数据,目前服务器只响应了一条很短的字符串。

  47. buff[n] = 0;

  48. LOGI("step5.");

  49. return buff;

  50. }

这里的socket连接使用的是最基本的Socket连接方法,首先设置协议(IPV4协议),然后设置ip地址和port端口号,之后便尝试连接服务器,调用的连接方法是sys/socket.h库中的函数,连接成功后会返回一个int值,若该值小于0则表示连接出错。 
上述代码编写好之后,再编写个Android.mk,然后利用ndk-build命令将c代码编译为so库,放入到工程的libs目录下。其中Android.mk代码如下:

 

Android.mk

 

 
  1. LOCAL_PATH := $(call my-dir)

  2.  
  3. include $(CLEAR_VARS)

  4. LOCAL_CPP_EXTENSION :=cpp #针对C++的支持,标记c++文件的扩展名名称

  5. LOCAL_MODULE := mysocket

  6. LOCAL_SRC_FILES := socketutil.c \

  7. socketjni.c

  8. LOCAL_LDLIBS := -llog

  9. include $(BUILD_SHARED_LIBRARY)

为了少编译些版本,也可以加入一个Application.mk,代码如下:

 

Application.mk

 

 
  1. #APP_MODULES := mysocket //so库的名称,在Android.mk里面设置了

  2. #APP_STL:=stlport_static

  3. APP_ABI := armeabi #编译的版本有哪些

  4. #APP_OPIM :=debug

利用ndk-build命令进行编译,ndk-build命令会直接将so库放入到libs目录下,然后运行工程,点击里面的Button按钮,即可查看连接结果。注意,手机要和服务端在同一个局域网里面,而且在运行的时候要修改下代码里面的ip地址。

 

运行后输出的Log如下:


上面的step1到step5表示运行到了哪一步,方便查看具体是在哪一步出错了。

服务端输出如下:

 

 

这篇关于Android利用JNI通过Socket与服务器进行通信的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1060704

相关文章

Android Paging 分页加载库使用实践

《AndroidPaging分页加载库使用实践》AndroidPaging库是Jetpack组件的一部分,它提供了一套完整的解决方案来处理大型数据集的分页加载,本文将深入探讨Paging库... 目录前言一、Paging 库概述二、Paging 3 核心组件1. PagingSource2. Pager3.

Python实现MQTT通信的示例代码

《Python实现MQTT通信的示例代码》本文主要介绍了Python实现MQTT通信的示例代码,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一... 目录1. 安装paho-mqtt库‌2. 搭建MQTT代理服务器(Broker)‌‌3. pytho

Android kotlin中 Channel 和 Flow 的区别和选择使用场景分析

《Androidkotlin中Channel和Flow的区别和选择使用场景分析》Kotlin协程中,Flow是冷数据流,按需触发,适合响应式数据处理;Channel是热数据流,持续发送,支持... 目录一、基本概念界定FlowChannel二、核心特性对比数据生产触发条件生产与消费的关系背压处理机制生命周期

Android ClassLoader加载机制详解

《AndroidClassLoader加载机制详解》Android的ClassLoader负责加载.dex文件,基于双亲委派模型,支持热修复和插件化,需注意类冲突、内存泄漏和兼容性问题,本文给大家介... 目录一、ClassLoader概述1.1 类加载的基本概念1.2 android与Java Class

如何在Ubuntu 24.04上部署Zabbix 7.0对服务器进行监控

《如何在Ubuntu24.04上部署Zabbix7.0对服务器进行监控》在Ubuntu24.04上部署Zabbix7.0监控阿里云ECS服务器,需配置MariaDB数据库、开放10050/1005... 目录软硬件信息部署步骤步骤 1:安装并配置mariadb步骤 2:安装Zabbix 7.0 Server

Android DataBinding 与 MVVM使用详解

《AndroidDataBinding与MVVM使用详解》本文介绍AndroidDataBinding库,其通过绑定UI组件与数据源实现自动更新,支持双向绑定和逻辑运算,减少模板代码,结合MV... 目录一、DataBinding 核心概念二、配置与基础使用1. 启用 DataBinding 2. 基础布局

Android ViewBinding使用流程

《AndroidViewBinding使用流程》AndroidViewBinding是Jetpack组件,替代findViewById,提供类型安全、空安全和编译时检查,代码简洁且性能优化,相比Da... 目录一、核心概念二、ViewBinding优点三、使用流程1. 启用 ViewBinding (模块级

如何解决Druid线程池Cause:java.sql.SQLRecoverableException:IO错误:Socket read timed out的问题

《如何解决Druid线程池Cause:java.sql.SQLRecoverableException:IO错误:Socketreadtimedout的问题》:本文主要介绍解决Druid线程... 目录异常信息触发场景找到版本发布更新的说明从版本更新信息可以看到该默认逻辑已经去除总结异常信息触发场景复

Android学习总结之Java和kotlin区别超详细分析

《Android学习总结之Java和kotlin区别超详细分析》Java和Kotlin都是用于Android开发的编程语言,它们各自具有独特的特点和优势,:本文主要介绍Android学习总结之Ja... 目录一、空安全机制真题 1:Kotlin 如何解决 Java 的 NullPointerExceptio

RabbitMQ工作模式中的RPC通信模式详解

《RabbitMQ工作模式中的RPC通信模式详解》在RabbitMQ中,RPC模式通过消息队列实现远程调用功能,这篇文章给大家介绍RabbitMQ工作模式之RPC通信模式,感兴趣的朋友一起看看吧... 目录RPC通信模式概述工作流程代码案例引入依赖常量类编写客户端代码编写服务端代码RPC通信模式概述在R