java kafka 怎么传输对象

Posted 2023-04-13

参考技术A 1.zookeeper集群 搭建在110， 111,112

2.kafka使用3个节点110， 111,112
修改配置文件config/server.properties
broker.id=110
host.name=192.168.1.110
log.dirs=/usr/local/kafka_2.10-0.8.2.0/logs
复制到其他两个节点，然后修改对应节点上的config/server.pro

3.启动,在三个节点分别执行
bin/kafka-server-start.sh config/server.properties >/dev/null 2>&1 &

4 创建主题
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 3 --topic test

5 查看主题详细
bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test
--topic test
Topic:test PartitionCount:3 ReplicationFactor:3 Configs:
Topic: test Partition: 0 Leader: 110 Replicas: 110,111,112 Isr: 110,111,112
Topic: test Partition: 1 Leader: 111 Replicas: 111,112,110 Isr: 111,112,110
Topic: test Partition: 2 Leader: 112 Replicas: 112,110,111 Isr: 112,110,111

android jni与java之间数据传输时怎么转换

1.c中的jstring数据类型就是java传入的String对象，经过jni函数的转化就能成为c的char*。

Java	类型	本地c类型	说明
boolean	jboolean	无符号	8 位
byte	jbyte	无符号	8 位
char	jchar	无符号	16 位
short	jshort	有符号	16 位
int	jint	有符号	32 位
long	jlong	有符号	64 位
float	jfloat	有符号	32 位
double	jdouble	有符号	64 位

2.如何将java传入的String参数转换为c的char*，然后使用?

    java传入的String参数，在c文件中被jni转换为jstring的数据类型，在c文件中声明char* test，然后

    test = (char*)(*env)->GetStringUTFChars(env, jstring, NULL);

    注意：test使用完后，通知虚拟机平台相关代码无需再访问：

    (*env)->ReleaseStringUTFChars(env, jstring, test);

3.将c中获取的一个char*的buffer传递给java？

    这个char*如果是一般的字符串的话，作为string传回去就可以了。如果是含有’/0’的buffer，最好作为bytearray传出，因为可以制定copy的length，如果copy到string，可能到’/0’就截断了。

有两种方式传递得到的数据：

一种是在jni中直接new一个byte数组，然后调用函数

    (*env)->SetByteArrayRegion(env, bytearray, 0, len, buffer);

将buffer的值copy到bytearray中，函数直接return bytearray就可以了。

一种是return错误号，数据作为参数传出，但是java的基本数据类型是传值，对象是传递的引用，所以将这个需要传出的byte数组用某个类包一下，如下：

    class RetObj{

       public byte[] bytearray;

    }

这个对象作为函数的参数retobj传出，通过如下函数将retobj中的byte数组赋值便于传出。代码如下：

    jclass cls;

    jfieldID fid;

    jbyteArray bytearray;

    bytearray = (*env)->NewByteArray(env,len);

    (*env)->SetByteArrayRegion(env, bytearray, 0, len, buffer);

    cls = (*env)->GetObjectClass(env, retobj);

    fid = (*env)->GetFieldID(env, cls, "retbytes", "[B"]);

    (*env)->SetObjectField(env, retobj, fid, bytearray);

4.如何在c中返回String给java

    char charStr[50];

    jstring jstr;

   jstr = env -> NewStringUTF(charStr);

5. 不知道占用多少空间的buffer，如何传递出去呢？

    在jni的c文件中new出空间，传递出去。java的数据不初始化，指向传递出去的空间即可。

另:JNI中对JAVA传入数据的处理

    如果传入的是bytearray的话，作如下处理得到buffer：

    char *tmpdata = (char*)(*env)->GetByteArrayElements(env, bytearray, NULL);

    (*env)->ReleaseByteArrayElements(env, bytearray, tmpdata, 0);