JNI+Netlink+Netfilter+Java多线程(毕设进行中)

C__J

是不是nf_conntrack模块与上层通讯的方式只有 "proc“呢？   如果真那样的话，貌似就只能用“cat的方式”获取了，除非自己改源码加netlink吧


貌似现在的思路越来越明朗了：

关于链接跟踪

1，通过"proc"与nf_conntrack内核模块通讯，获取连接信息


2，通过之前自己已实现ip包过滤模块的hook,来获得ip头，tcp,udp头信息并通过netlink获取连接信息

   类似“ipv4     2 tcp      6 5 TIME_WAIT src=192.168.0.25 dst=221.238.249.178 sport=39027 dport=80 packets=6 bytes=1119 src=221.238.249.178 dst=192.168.0.25 sport=80 dport=39027 packets=5 bytes=2474 [ASSURED] mark=0 secmark=0 use=1"

只是里面的bytes  mark secmark use  TIME_WAIT 这几个信息是从哪拿过来的。

ip包消息头： struct iphdr { #if defined(__LITTLE_ENDIAN_BITFIELD) &nbsp;&nbsp;&nbsp;&nbsp;__u8&nbsp;&nbsp;&nbsp;&nbsp;ihl:4, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;version:4; #elif defined (__BIG_ENDIAN_BITFIELD) &nbsp;&nbsp;&nbsp;&nbsp;__u8&nbsp;&nbsp;&nbsp;&nbsp;version:4, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ihl:4; #else #error&nbsp;&nbsp;&nbsp;&nbsp;"Please fix <asm/byteorder.h>" #endif &nbsp;&nbsp;&nbsp;&nbsp;__u8&nbsp;&nbsp;&nbsp;&nbsp;tos; &nbsp;&nbsp;&nbsp;&nbsp;__be16&nbsp;&nbsp;&nbsp;&nbsp;tot_len; &nbsp;&nbsp;&nbsp;&nbsp;__be16&nbsp;&nbsp;&nbsp;&nbsp;id; &nbsp;&nbsp;&nbsp;&nbsp;__be16&nbsp;&nbsp;&nbsp;&nbsp;frag_off; &nbsp;&nbsp;&nbsp;&nbsp;__u8&nbsp;&nbsp;&nbsp;&nbsp;ttl; &nbsp;&nbsp;&nbsp;&nbsp;__u8&nbsp;&nbsp;&nbsp;&nbsp;protocol;  __u8是unsigned char类型 &nbsp;&nbsp;&nbsp;&nbsp;__sum16&nbsp;&nbsp;&nbsp;&nbsp;check; &nbsp;&nbsp;&nbsp;&nbsp;__be32&nbsp;&nbsp;&nbsp;&nbsp;saddr; &nbsp;&nbsp;&nbsp;&nbsp;__be32&nbsp;&nbsp;&nbsp;&nbsp;daddr; &nbsp;&nbsp;&nbsp;&nbsp;/*The options start here. */ }; struct udphdr { &nbsp;&nbsp;&nbsp;&nbsp;__be16&nbsp;&nbsp;&nbsp;&nbsp;source; &nbsp;&nbsp;&nbsp;&nbsp;__be16&nbsp;&nbsp;&nbsp;&nbsp;dest; &nbsp;&nbsp;&nbsp;&nbsp;__be16&nbsp;&nbsp;&nbsp;&nbsp;len; &nbsp;&nbsp;&nbsp;&nbsp;__sum16&nbsp;&nbsp;&nbsp;&nbsp;check; }; struct tcphdr { &nbsp;&nbsp;&nbsp;&nbsp;__be16&nbsp;&nbsp;&nbsp;&nbsp;source; &nbsp;&nbsp;&nbsp;&nbsp;__be16&nbsp;&nbsp;&nbsp;&nbsp;dest; &nbsp;&nbsp;&nbsp;&nbsp;__be32&nbsp;&nbsp;&nbsp;&nbsp;seq; &nbsp;&nbsp;&nbsp;&nbsp;__be32&nbsp;&nbsp;&nbsp;&nbsp;ack_seq; #if defined(__LITTLE_ENDIAN_BITFIELD) &nbsp;&nbsp;&nbsp;&nbsp;__u16&nbsp;&nbsp;&nbsp;&nbsp;res1:4, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;doff:4, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;fin:1, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;syn:1, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;rst:1, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;psh:1, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ack:1, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;urg:1, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ece:1, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;cwr:1; #elif defined(__BIG_ENDIAN_BITFIELD) &nbsp;&nbsp;&nbsp;&nbsp;__u16&nbsp;&nbsp;&nbsp;&nbsp;doff:4, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;res1:4, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;cwr:1, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ece:1, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;urg:1,&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ack:1, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;psh:1, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;rst:1, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;syn:1, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;fin:1; #else #error&nbsp;&nbsp;&nbsp;&nbsp;"Adjust your <asm/byteorder.h> defines" #endif&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;__be16&nbsp;&nbsp;&nbsp;&nbsp;window; &nbsp;&nbsp;&nbsp;&nbsp;__sum16&nbsp;&nbsp;&nbsp;&nbsp;check; &nbsp;&nbsp;&nbsp;&nbsp;__be16&nbsp;&nbsp;&nbsp;&nbsp;urg_ptr; };

[ 本帖最后由 C__J 于 2009-4-27 02:55 编辑 ]

Godbach

是不是nf_conntrack模块与上层通讯的方式只有 "proc“呢？

因为这里就是提供给用户空间读的，所以就用proc。这个方式比较常用，至于有没别的，我这里暂时没用到过。
对于显示出来的连接信息中各个字段的意思，你可以网上搜一下，或者就看代码好了。其实主要就是TCP协议的状态比较多一些。

C__J

ok,谢谢，我先试试。

目前连接状态 我先用"proc"方式读到JAVA那层

然后还是改进下以前的netlink，同时也实现个netlink获取连接状态的。

这几天做出来再分享出来！

C__J

连接状态信息获取出来了，用的另一种思路，不依附以前的netlink，而直接通过系统的proc文件系统获取的信息，这样不要考虑同步异步问题，也提高了多线程的效率。



不过一下午都纠结在如何分解这些字符串中，但后来还是省去了这种繁琐的分解上面。

实现很简单：

while(len_c>0)      {          len_c--;                   jobject objTemp = (*env)->AllocObject(env,objectClass);          if(getline(&line, &length, fp) != -1)                  {          (*env)->SetObjectField(env,objTemp,jmessage, (*env)->NewStringUTF(env,line));                  }          (*env)->SetObjectArrayElement(env,args, len_c, objTemp);               }

不过功能有待提高！

[ 本帖最后由 C__J 于 2009-4-28 00:49 编辑 ]

dreamice

如果从内核传大量数据到用户空间的话，一定要注意效率，否则很容易出问题。

C__J

连接跟踪那块，我就用的一个线程读取 /proc/net/nf_conntrack 数据，读完后进入睡眠状态

[ 本帖最后由 C__J 于 2009-4-29 17:56 编辑 ]