- 浏览: 951662 次
文章分类
- 全部博客 (428)
- Hadoop (2)
- HBase (1)
- ELK (1)
- ActiveMQ (13)
- Kafka (5)
- Redis (14)
- Dubbo (1)
- Memcached (5)
- Netty (56)
- Mina (34)
- NIO (51)
- JUC (53)
- Spring (13)
- Mybatis (17)
- MySQL (21)
- JDBC (12)
- C3P0 (5)
- Tomcat (13)
- SLF4J-log4j (9)
- P6Spy (4)
- Quartz (12)
- Zabbix (7)
- JAVA (9)
- Linux (15)
- HTML (9)
- Lucene (0)
- JS (2)
- WebService (1)
- Maven (4)
- Oracle&MSSQL (14)
- iText (11)
- Development Tools (8)
- UTILS (4)
- LIFE (8)
最新评论
-
Donald_Draper:
Donald_Draper 写道刘落落cici 写道能给我发一 ...
DatagramChannelImpl 解析三(多播) -
Donald_Draper:
刘落落cici 写道能给我发一份这个类的源码吗Datagram ...
DatagramChannelImpl 解析三(多播) -
lyfyouyun:
请问楼主,执行消息发送的时候,报错:Transport sch ...
ActiveMQ连接工厂、连接详解 -
ezlhq:
关于 PollArrayWrapper 状态含义猜测:参考 S ...
WindowsSelectorImpl解析一(FdMap,PollArrayWrapper) -
flyfeifei66:
打算使用xmemcache作为memcache的客户端,由于x ...
Memcached分布式客户端(Xmemcached)
DatagramChannelImpl 解析一(初始化):http://donald-draper.iteye.com/blog/2373245
DatagramChannelImpl 解析二(报文发送与接收):http://donald-draper.iteye.com/blog/2373281
引言:
上一篇看了报文的发送和接收,先来回顾一下,
send(发送报文)方法,首先同步写锁,确保通道打开,然后检查地址,如果系统安全管理器不为null,则更具地址类型检查相应的权限,如果地址为多播地址,则检查多播权限,否则检查连接到socketaddress的权限;如果发送的buffer为direct类型,则直接发送,否则从当前线程缓冲区获取一个临时DirectByteBuffer,并将buffer中的数据写到临时DirectByteBuffer中,然后发送,发送后,释放临时DirectByteBuffer,即添加到当前线程缓存区以便重用。
receive(接收报文)方法,首先同步读锁,确保通道打开,如果本地地址为null,则绑定local地址,并初始化报文通道的localAddress;获取buffer当前可用空间remaining,如果buffer为direct类型,则直接接收报文,否则,从当前线程缓冲区获取临时DirectByteBuffer,接收报文,写到临时缓冲区临时DirectByteBuffer,读取临时DirectByteBuffer,写到buffer中,释放临时DirectByteBuffer,即添加DirectByteBuffer到当前线程缓存区,以便重用。
send(发送报文)和receive(接收报文)方法不需要通道已经处于连接状态,而read和write需要通道建立连接状态,这种方式与SocketChannel的读写操作相同,这样与SocketChannel无异,如果需要不如使用SocketChannel。如果使用DatagramChannel,建议使用send和recieve方法进行报文的发送和接收。
今天我们来看一下多播相关的方法为drop,block,unblock,join。
先看join方法
从上面可以看出加入多播组实际上的操作是由innerJoin来完成
以上方法有两点要关注
1.
//Inet4Address
//InetAddress
2.
//Net
//Net
从上面可以看出,报文通道加入多播组,首先检查加入的多播组地址是否正确,然后校验源地址,检查多播成员关系注册器中是否存在多播地址为inetaddress,网络接口为networkinterface,源地址为inetaddress1的多播成员关系key,有则直接返回,否则根据网络协议族family,网络接口,源地址构造多播成员关系MembershipKeyImpl,添加到注册器MembershipRegistry。
再来看block方法
上面一个方法需要关注的为
1.
//Net
2.
//Net
再来看unblock方法
上面方法我们需要关注的是
1.
//Net
2.
//Net
从上面可以看出阻塞源地址报文与解除源地址报文阻塞,首先检查源地址,再将实际的阻塞与解除阻塞工作委托给Net完成。
再来看drop方法
//drop报文通道多播成员关系key
drop方法需要关注的为:
1.
//Net
2.
//Net
从上面可以看出drop方法,首先判断多播成员关系key是否有效,如果有效,判断多播组为ip4还是ip6,然后委托给Net完成实际的drop工作。
总结:
join(报文通道加入多播组)方法,首先检查加入的多播组地址是否正确,然后校验源地址,检查多播成员关系注册器中是否存在多播地址为inetaddress,网络接口为networkinterface,源地址为inetaddress1的多播成员关系key,有则直接返回,否则根据网络协议族family,网络接口,源地址构造多播成员关系MembershipKeyImpl,添加到注册器MembershipRegistry。
阻塞源地址报文与解除源地址报文阻塞,首先检查源地址,再将实际的阻塞与解除阻塞工作委托给Net完成。
drop方法,首先判断多播成员关系key是否有效,如果有效,判断多播组为ip4还是ip6,然后委托给Net完成实际的drop工作。
DatagramChannelImpl 解析四(地址绑定,关闭通道等):http://donald-draper.iteye.com/blog/2373519
https://github.com/Donaldhan/netty
java nio 反编译即可
https://github.com/Donaldhan/netty
DatagramChannelImpl 解析二(报文发送与接收):http://donald-draper.iteye.com/blog/2373281
引言:
上一篇看了报文的发送和接收,先来回顾一下,
send(发送报文)方法,首先同步写锁,确保通道打开,然后检查地址,如果系统安全管理器不为null,则更具地址类型检查相应的权限,如果地址为多播地址,则检查多播权限,否则检查连接到socketaddress的权限;如果发送的buffer为direct类型,则直接发送,否则从当前线程缓冲区获取一个临时DirectByteBuffer,并将buffer中的数据写到临时DirectByteBuffer中,然后发送,发送后,释放临时DirectByteBuffer,即添加到当前线程缓存区以便重用。
receive(接收报文)方法,首先同步读锁,确保通道打开,如果本地地址为null,则绑定local地址,并初始化报文通道的localAddress;获取buffer当前可用空间remaining,如果buffer为direct类型,则直接接收报文,否则,从当前线程缓冲区获取临时DirectByteBuffer,接收报文,写到临时缓冲区临时DirectByteBuffer,读取临时DirectByteBuffer,写到buffer中,释放临时DirectByteBuffer,即添加DirectByteBuffer到当前线程缓存区,以便重用。
send(发送报文)和receive(接收报文)方法不需要通道已经处于连接状态,而read和write需要通道建立连接状态,这种方式与SocketChannel的读写操作相同,这样与SocketChannel无异,如果需要不如使用SocketChannel。如果使用DatagramChannel,建议使用send和recieve方法进行报文的发送和接收。
今天我们来看一下多播相关的方法为drop,block,unblock,join。
先看join方法
//添加到多播组inetaddress public MembershipKey join(InetAddress inetaddress, NetworkInterface networkinterface) throws IOException { return innerJoin(inetaddress, networkinterface, null); } //添加到多播组,只接受源地址为inetaddress1的报文 public MembershipKey join(InetAddress inetaddress, NetworkInterface networkinterface, InetAddress inetaddress1) throws IOException { if(inetaddress1 == null) throw new NullPointerException("source address is null"); else return innerJoin(inetaddress, networkinterface, inetaddress1); }
从上面可以看出加入多播组实际上的操作是由innerJoin来完成
private MembershipKey innerJoin(InetAddress inetaddress, NetworkInterface networkinterface, InetAddress inetaddress1) throws IOException { //非多播地址抛出异常 if(!inetaddress.isMulticastAddress()) throw new IllegalArgumentException("Group not a multicast address"); //如果地址为ip6,但加入的多播组地址为ip4,则抛出参数异常 if(inetaddress instanceof Inet4Address) { if(family == StandardProtocolFamily.INET6 && !Net.canIPv6SocketJoinIPv4Group()) throw new IllegalArgumentException("IPv6 socket cannot join IPv4 multicast group"); } else if(inetaddress instanceof Inet6Address) { //如果多播地址为ip6,协议非INET6,抛出异常 if(family != StandardProtocolFamily.INET6) throw new IllegalArgumentException("Only IPv6 sockets can join IPv6 multicast group"); } else { throw new IllegalArgumentException("Address type not supported"); } //如果多播组源地址不为空,则校验源地址 if(inetaddress1 != null) { if(inetaddress1.isAnyLocalAddress())//源地址含通配符,address == 0; throw new IllegalArgumentException("Source address is a wildcard address"); if(inetaddress1.isMulticastAddress())//源地址为多播地址 throw new IllegalArgumentException("Source address is multicast address"); if(inetaddress1.getClass() != inetaddress.getClass())//源地址与多播地址类型不同 throw new IllegalArgumentException("Source address is different type to group"); } SecurityManager securitymanager = System.getSecurityManager(); if(securitymanager != null) //检查多播地址权限,接受和连接权限 securitymanager.checkMulticast(inetaddress); Object obj = stateLock; JVM INSTR monitorenter ; Object obj1; if(!isOpen())//确保通道打开 throw new ClosedChannelException(); if(registry == null) { //多播关系注册器为null,则创建 registry = new MembershipRegistry(); break MISSING_BLOCK_LABEL_229; } //检查多播成员关系注册器中是否存在多播地址为inetaddress,网络接口为networkinterface, //源地址为inetaddress1,多播成员关系key obj1 = registry.checkMembership(inetaddress, networkinterface, inetaddress1); if(obj1 != null) //有则直接返回 return ((MembershipKey) (obj1)); //否则根据网络协议族family,网络接口,源地址构造MembershipKeyImpl if(family == StandardProtocolFamily.INET6 && ((inetaddress instanceof Inet6Address) || Net.canJoin6WithIPv4Group())) {//Ip6 int i = networkinterface.getIndex(); if(i == -1) throw new IOException("Network interface cannot be identified"); byte abyte0[] = Net.inet6AsByteArray(inetaddress); byte abyte1[] = inetaddress1 != null ? Net.inet6AsByteArray(inetaddress1) : null; //加入多播组 int l = Net.join6(fd, abyte0, i, abyte1); if(l == -2) throw new UnsupportedOperationException(); obj1 = new MembershipKeyImpl.Type6(this, inetaddress, networkinterface, inetaddress1, abyte0, i, abyte1); } else {//Ip4 Inet4Address inet4address = Net.anyInet4Address(networkinterface); if(inet4address == null) throw new IOException("Network interface not configured for IPv4"); int j = Net.inet4AsInt(inetaddress); int k = Net.inet4AsInt(inet4address); int i1 = inetaddress1 != null ? Net.inet4AsInt(inetaddress1) : 0; //加入多播组 int j1 = Net.join4(fd, j, k, i1); if(j1 == -2) throw new UnsupportedOperationException(); obj1 = new MembershipKeyImpl.Type4(this, inetaddress, networkinterface, inetaddress1, j, k, i1); } //添加多播成员关系key到注册器 registry.add(((MembershipKeyImpl) (obj1))); obj1; obj; JVM INSTR monitorexit ; return; Exception exception; exception; throw exception; }
以上方法有两点要关注
1.
if(inetaddress1.isAnyLocalAddress())//源地址含通配符,address == 0; throw new IllegalArgumentException("Source address is a wildcard address"); if(inetaddress1.isMulticastAddress())//源地址为多播地址 throw new IllegalArgumentException("Source address is multicast address");
//Inet4Address
public final class Inet4Address extends InetAddress { final static int INADDRSZ = 4; /**是否为多播地址 * Utility routine to check if the InetAddress is an * IP multicast address. IP multicast address is a Class D * address i.e first four bits of the address are 1110. * @return a <code>boolean</code> indicating if the InetAddress is * an IP multicast address * @since JDK1.1 */ public boolean isMulticastAddress() { return ((address & 0xf0000000) == 0xe0000000); } /** 是否为统配符地址 * Utility routine to check if the InetAddress in a wildcard address. * @return a <code>boolean</code> indicating if the Inetaddress is * a wildcard address. * @since 1.4 */ public boolean isAnyLocalAddress() { return address == 0; } /** * Utility routine to check if the InetAddress is a loopback address. *是否为环路地址 * @return a <code>boolean</code> indicating if the InetAddress is * a loopback address; or false otherwise. * @since 1.4 */ private static final int loopback = 2130706433; /* 127.0.0.1 */ public boolean isLoopbackAddress() { /* 127.x.x.x */ byte[] byteAddr = getAddress(); return byteAddr[0] == 127; } ... }
//InetAddress
public class InetAddress implements java.io.Serializable { /** * Specify the address family: Internet Protocol, Version 4 * @since 1.4 */ static final int IPv4 = 1; /** * Specify the address family: Internet Protocol, Version 6 * @since 1.4 */ static final int IPv6 = 2; /* Specify address family preference */ static transient boolean preferIPv6Address = false; /** * @serial */ String hostName; /** * Holds a 32-bit IPv4 address. * * @serial */ int address; /** * Specifies the address family type, for instance, '1' for IPv4 * addresses, and '2' for IPv6 addresses. * * @serial */ int family; }
2.
//加入多播组 int j1 = Net.join4(fd, j, k, i1);
//Net
static int join4(FileDescriptor filedescriptor, int i, int j, int k) throws IOException { return joinOrDrop4(true, filedescriptor, i, j, k); } private static native int joinOrDrop4(boolean flag, FileDescriptor filedescriptor, int i, int j, int k) throws IOException;
//加入多播组 int l = Net.join6(fd, abyte0, i, abyte1);
//Net
static int join6(FileDescriptor filedescriptor, byte abyte0[], int i, byte abyte1[]) throws IOException { return joinOrDrop6(true, filedescriptor, abyte0, i, abyte1); } private static native int joinOrDrop6(boolean flag, FileDescriptor filedescriptor, byte abyte0[], int i, byte abyte1[]) throws IOException;
从上面可以看出,报文通道加入多播组,首先检查加入的多播组地址是否正确,然后校验源地址,检查多播成员关系注册器中是否存在多播地址为inetaddress,网络接口为networkinterface,源地址为inetaddress1的多播成员关系key,有则直接返回,否则根据网络协议族family,网络接口,源地址构造多播成员关系MembershipKeyImpl,添加到注册器MembershipRegistry。
再来看block方法
void block(MembershipKeyImpl membershipkeyimpl, InetAddress inetaddress) throws IOException { //如果断言,开启,则判断多播关系key通道是否为本通道 if(!$assertionsDisabled && membershipkeyimpl.channel() != this) throw new AssertionError(); //断言源地址是否为null if(!$assertionsDisabled && membershipkeyimpl.sourceAddress() != null) throw new AssertionError(); synchronized(stateLock) { //如果多播成员关系无效 if(!membershipkeyimpl.isValid()) throw new IllegalStateException("key is no longer valid"); if(inetaddress.isAnyLocalAddress())//如果源地址为统配地址 throw new IllegalArgumentException("Source address is a wildcard address"); if(inetaddress.isMulticastAddress())//如果源地址为多播地址 throw new IllegalArgumentException("Source address is multicast address"); if(inetaddress.getClass() != membershipkeyimpl.group().getClass())//如果多播地址与源地址类型不同 throw new IllegalArgumentException("Source address is different type to group"); int i; //如果为多播组为IP6 if(membershipkeyimpl instanceof MembershipKeyImpl.Type6) { MembershipKeyImpl.Type6 type6 = (MembershipKeyImpl.Type6)membershipkeyimpl; //委托给net i = Net.block6(fd, type6.groupAddress(), type6.index(), Net.inet6AsByteArray(inetaddress)); } else { //如果为多播组为IP4 MembershipKeyImpl.Type4 type4 = (MembershipKeyImpl.Type4)membershipkeyimpl; //委托给net i = Net.block4(fd, type4.groupAddress(), type4.interfaceAddress(), Net.inet4AsInt(inetaddress)); } if(i == -2) throw new UnsupportedOperationException(); } }
上面一个方法需要关注的为
1.
i = Net.block4(fd, type4.groupAddress(), type4.interfaceAddress(), Net.inet4AsInt(inetaddress));
//Net
static int block4(FileDescriptor filedescriptor, int i, int j, int k) throws IOException { return blockOrUnblock4(true, filedescriptor, i, j, k); } private static native int blockOrUnblock4(boolean flag, FileDescriptor filedescriptor, int i, int j, int k) throws IOException;
2.
i = Net.block6(fd, type6.groupAddress(), type6.index(), Net.inet6AsByteArray(inetaddress));
//Net
static int block6(FileDescriptor filedescriptor, byte abyte0[], int i, byte abyte1[]) throws IOException { return blockOrUnblock6(true, filedescriptor, abyte0, i, abyte1); } static native int blockOrUnblock6(boolean flag, FileDescriptor filedescriptor, byte abyte0[], int i, byte abyte1[]) throws IOException;
再来看unblock方法
void unblock(MembershipKeyImpl membershipkeyimpl, InetAddress inetaddress) { //如果断言,开启,则判断多播关系key通道是否为本通道 if(!$assertionsDisabled && membershipkeyimpl.channel() != this) throw new AssertionError(); //断言源地址是否为null if(!$assertionsDisabled && membershipkeyimpl.sourceAddress() != null) throw new AssertionError(); synchronized(stateLock) { if(!membershipkeyimpl.isValid())//如果多播成员关系无效 throw new IllegalStateException("key is no longer valid"); try { if(membershipkeyimpl instanceof MembershipKeyImpl.Type6) { //如果为多播组为IP6 MembershipKeyImpl.Type6 type6 = (MembershipKeyImpl.Type6)membershipkeyimpl; Net.unblock6(fd, type6.groupAddress(), type6.index(), Net.inet6AsByteArray(inetaddress)); } else { //如果为多播组为IP4 MembershipKeyImpl.Type4 type4 = (MembershipKeyImpl.Type4)membershipkeyimpl; Net.unblock4(fd, type4.groupAddress(), type4.interfaceAddress(), Net.inet4AsInt(inetaddress)); } } catch(IOException ioexception) { throw new AssertionError(ioexception); } } }
上面方法我们需要关注的是
1.
Net.unblock4(fd, type4.groupAddress(), type4.interfaceAddress(), Net.inet4AsInt(inetaddress));
//Net
static void unblock4(FileDescriptor filedescriptor, int i, int j, int k) throws IOException { blockOrUnblock4(false, filedescriptor, i, j, k); }
2.
Net.unblock6(fd, type6.groupAddress(), type6.index(), Net.inet6AsByteArray(inetaddress));
//Net
static void unblock6(FileDescriptor filedescriptor, byte abyte0[], int i, byte abyte1[]) throws IOException { blockOrUnblock6(false, filedescriptor, abyte0, i, abyte1); }
从上面可以看出阻塞源地址报文与解除源地址报文阻塞,首先检查源地址,再将实际的阻塞与解除阻塞工作委托给Net完成。
再来看drop方法
//drop报文通道多播成员关系key
void drop(MembershipKeyImpl membershipkeyimpl) { label0: { //如果断言,开启,则判断多播关系key通道是否为本通道 if(!$assertionsDisabled && membershipkeyimpl.channel() != this) throw new AssertionError(); synchronized(stateLock) { //如果多播成员关系key无效,调到label0 if(membershipkeyimpl.isValid()) break label0; } return; } try { if(membershipkeyimpl instanceof MembershipKeyImpl.Type6) { //如果为多播组为IP6 MembershipKeyImpl.Type6 type6 = (MembershipKeyImpl.Type6)membershipkeyimpl; Net.drop6(fd, type6.groupAddress(), type6.index(), type6.source()); } else { //如果为多播组为IP6 MembershipKeyImpl.Type4 type4 = (MembershipKeyImpl.Type4)membershipkeyimpl; Net.drop4(fd, type4.groupAddress(), type4.interfaceAddress(), type4.source()); } } catch(IOException ioexception) { throw new AssertionError(ioexception); } //使多播成员关系key无效 membershipkeyimpl.invalidate(); //从报文通道注册器移除多播成员关系key registry.remove(membershipkeyimpl); obj; JVM INSTR monitorexit ; goto _L1 exception; throw exception; _L1: }
drop方法需要关注的为:
1.
Net.drop4(fd, type4.groupAddress(), type4.interfaceAddress(), type4.source());
//Net
static void drop4(FileDescriptor filedescriptor, int i, int j, int k) throws IOException { joinOrDrop4(false, filedescriptor, i, j, k); } private static native int joinOrDrop4(boolean flag, FileDescriptor filedescriptor, int i, int j, int k) throws IOException;
2.
Net.drop6(fd, type6.groupAddress(), type6.index(), type6.source());
//Net
static void drop6(FileDescriptor filedescriptor, byte abyte0[], int i, byte abyte1[]) throws IOException { joinOrDrop6(false, filedescriptor, abyte0, i, abyte1); } private static native int joinOrDrop6(boolean flag, FileDescriptor filedescriptor, byte abyte0[], int i, byte abyte1[]) throws IOException;
从上面可以看出drop方法,首先判断多播成员关系key是否有效,如果有效,判断多播组为ip4还是ip6,然后委托给Net完成实际的drop工作。
总结:
join(报文通道加入多播组)方法,首先检查加入的多播组地址是否正确,然后校验源地址,检查多播成员关系注册器中是否存在多播地址为inetaddress,网络接口为networkinterface,源地址为inetaddress1的多播成员关系key,有则直接返回,否则根据网络协议族family,网络接口,源地址构造多播成员关系MembershipKeyImpl,添加到注册器MembershipRegistry。
阻塞源地址报文与解除源地址报文阻塞,首先检查源地址,再将实际的阻塞与解除阻塞工作委托给Net完成。
drop方法,首先判断多播成员关系key是否有效,如果有效,判断多播组为ip4还是ip6,然后委托给Net完成实际的drop工作。
DatagramChannelImpl 解析四(地址绑定,关闭通道等):http://donald-draper.iteye.com/blog/2373519
评论
3 楼
Donald_Draper
2019-06-18
Donald_Draper 写道
刘落落cici 写道
能给我发一份这个类的源码吗DatagramChannelImpl
我想看一下 这个recive函数返回的这个发送方address是怎么确定的
我想看一下 这个recive函数返回的这个发送方address是怎么确定的
https://github.com/Donaldhan/netty
java nio 反编译即可
2 楼
Donald_Draper
2019-05-28
刘落落cici 写道
能给我发一份这个类的源码吗DatagramChannelImpl
我想看一下 这个recive函数返回的这个发送方address是怎么确定的
我想看一下 这个recive函数返回的这个发送方address是怎么确定的
https://github.com/Donaldhan/netty
1 楼
刘落落cici
2018-05-23
能给我发一份这个类的源码吗DatagramChannelImpl
我想看一下 这个recive函数返回的这个发送方address是怎么确定的
我想看一下 这个recive函数返回的这个发送方address是怎么确定的
发表评论
-
文件通道解析二(文件锁,关闭通道)
2017-05-16 23:17 995文件通道解析一(读写操作,通道数据传输等):http://do ... -
文件通道解析一(读写操作,通道数据传输等)
2017-05-16 10:04 1102Reference定义(PhantomRefere ... -
文件通道创建方式综述
2017-05-15 17:39 937Reference定义(PhantomReference,Cl ... -
文件读写方式简单综述后续(文件,流构造)
2017-05-14 23:04 1403Java Socket通信实例:http://donald-d ... -
文件读写方式简单综述
2017-05-14 11:13 1072Java Socket通信实例:http://donald-d ... -
FileChanne定义
2017-05-12 23:28 871文件读写方式简单综述:http://donald-draper ... -
SeekableByteChannel接口定义
2017-05-11 08:43 1124ByteChannel,分散聚集通道接口的定义(SocketC ... -
FileChannel示例
2017-05-11 08:37 908前面我们看过socket通道,datagram通道,以管道Pi ... -
PipeImpl解析
2017-05-11 08:41 840ServerSocketChannel定义:http://do ... -
Pipe定义
2017-05-10 09:07 843Channel接口定义:http://donald-drape ... -
NIO-Pipe示例
2017-05-10 08:47 849PipeImpl解析:http://donald-draper ... -
DatagramChannelImpl 解析四(地址绑定,关闭通道等)
2017-05-10 08:27 694DatagramChannelImpl 解析一(初始化):ht ... -
NIO-UDP实例
2017-05-09 12:32 1517DatagramChannelImpl 解析一(初始化):ht ... -
DatagramChannelImpl 解析二(报文发送与接收)
2017-05-09 09:03 1343DatagramChannelImpl 解析一(初始化):ht ... -
DatagramChannelImpl 解析一(初始化)
2017-05-08 21:52 1333Channel接口定义:http://donald-drape ... -
MembershipKeyImpl 简介
2017-05-08 09:11 872MembershipKey定义:http://donald-d ... -
DatagramChannel定义
2017-05-07 23:13 1183Channel接口定义:http://donald-drape ... -
MulticastChanne接口定义
2017-05-07 13:45 1069NetworkChannel接口定义:ht ... -
MembershipKey定义
2017-05-06 16:20 833package java.nio.channels; i ... -
SocketChannelImpl 解析四(关闭通道等)
2017-05-05 08:38 2413SocketChannelImpl 解析一(通道连接,发送数据 ...
相关推荐
The default implementation class of java.nio.channels.DatagramChannel.
一、最短路径的概念及应用 在介绍最短路径之前我们首先要明白两个概念:什么是源点,什么是终点?在一条路径中,起始的第 一个节点叫做源点;终点:在一条路径中,最后一个的节点叫做终点;注意!源点和终点都只是相对 于一条路径而言,每一条路径都会有相同或者不相同的源点和终点。 而最短路径这个词不用过多解释,就是其字面意思: 在图中,对于非带权无向图而言, 从源点到终点 边最少的路径(也就是 BFS 广度优先的方法); 而对于带权图而言, 从源点到终点权值之和最少的 路径叫最短路径; 最短路径应用:道路规划; 我们最关心的就是如何用代码去实现寻找最短路径, 通过实现最短路径有两种算法:Dijkstra 迪杰斯 特拉算法和 Floyd 弗洛伊德算法, 接下来我会详细讲解 Dijkstra 迪杰斯特拉算法;
基于faster-rcnn实现的行人检测算法python源码+项目说明+详细注释.zip 使用方法: 1.编译安装faster-rcnn的python接口,代码在:https://github.com/rbgirshick/py 2.下载训练好的caffe模型,百度云链接为:https://pan.baidu.com/s/1w479QUUAwLBS2AJbc-eXIA,将下载的模型文件放到faster-rcnn文件夹的data/faster_rcnn_models文件夹中 3.将本项目中的文件夹替换安装好的faster-rcnn源码中的文件夹 4.使用tools文件夹下的测试脚本运行demo:python person_detect.py
jsp基于Web的可维护的数据库浏览器(源代码+论文+答辩PPT)
Node.js,简称Node,是一个开源且跨平台的JavaScript运行时环境,它允许在浏览器外运行JavaScript代码。Node.js于2009年由Ryan Dahl创立,旨在创建高性能的Web服务器和网络应用程序。它基于Google Chrome的V8 JavaScript引擎,可以在Windows、Linux、Unix、Mac OS X等操作系统上运行。 Node.js的特点之一是事件驱动和非阻塞I/O模型,这使得它非常适合处理大量并发连接,从而在构建实时应用程序如在线游戏、聊天应用以及实时通讯服务时表现卓越。此外,Node.js使用了模块化的架构,通过npm(Node package manager,Node包管理器),社区成员可以共享和复用代码,极大地促进了Node.js生态系统的发展和扩张。 Node.js不仅用于服务器端开发。随着技术的发展,它也被用于构建工具链、开发桌面应用程序、物联网设备等。Node.js能够处理文件系统、操作数据库、处理网络请求等,因此,开发者可以用JavaScript编写全栈应用程序,这一点大大提高了开发效率和便捷性。 在实践中,许多大型企业和组织已经采用Node.js作为其Web应用程序的开发平台,如Netflix、PayPal和Walmart等。它们利用Node.js提高了应用性能,简化了开发流程,并且能更快地响应市场需求。
unet + pytorch 数据科学碗2018-python源码.zip
数据预览链接:https://pan.baidu.com/s/17y5tiSmC5U4d1Mben250gg 提取码:u1da 更多介绍:https://blog.csdn.net/m0_71334485/article/details/138400336
基于Torch Hub的渐进式GAN架构-python源码.zip
JSP基于Iptables图形管理工具的设计与实现(源代码+论文)
使用Keras+TensorFlow+FCN分割KITTI数据集-python源码.zip
基于RRT采样对六轴机械臂进行路径规划Matlab完整源码+代码注释+项目说明.zip
深蹲姿势分析-python源码.zip
基于python实现的交通网络中的流量调控使用复杂网络中的级联失效模型.rar
Node.js,简称Node,是一个开源且跨平台的JavaScript运行时环境,它允许在浏览器外运行JavaScript代码。Node.js于2009年由Ryan Dahl创立,旨在创建高性能的Web服务器和网络应用程序。它基于Google Chrome的V8 JavaScript引擎,可以在Windows、Linux、Unix、Mac OS X等操作系统上运行。 Node.js的特点之一是事件驱动和非阻塞I/O模型,这使得它非常适合处理大量并发连接,从而在构建实时应用程序如在线游戏、聊天应用以及实时通讯服务时表现卓越。此外,Node.js使用了模块化的架构,通过npm(Node package manager,Node包管理器),社区成员可以共享和复用代码,极大地促进了Node.js生态系统的发展和扩张。 Node.js不仅用于服务器端开发。随着技术的发展,它也被用于构建工具链、开发桌面应用程序、物联网设备等。Node.js能够处理文件系统、操作数据库、处理网络请求等,因此,开发者可以用JavaScript编写全栈应用程序,这一点大大提高了开发效率和便捷性。 在实践中,许多大型企业和组织已经采用Node.js作为其Web应用程序的开发平台,如Netflix、PayPal和Walmart等。它们利用Node.js提高了应用性能,简化了开发流程,并且能更快地响应市场需求。
Node.js,简称Node,是一个开源且跨平台的JavaScript运行时环境,它允许在浏览器外运行JavaScript代码。Node.js于2009年由Ryan Dahl创立,旨在创建高性能的Web服务器和网络应用程序。它基于Google Chrome的V8 JavaScript引擎,可以在Windows、Linux、Unix、Mac OS X等操作系统上运行。 Node.js的特点之一是事件驱动和非阻塞I/O模型,这使得它非常适合处理大量并发连接,从而在构建实时应用程序如在线游戏、聊天应用以及实时通讯服务时表现卓越。此外,Node.js使用了模块化的架构,通过npm(Node package manager,Node包管理器),社区成员可以共享和复用代码,极大地促进了Node.js生态系统的发展和扩张。 Node.js不仅用于服务器端开发。随着技术的发展,它也被用于构建工具链、开发桌面应用程序、物联网设备等。Node.js能够处理文件系统、操作数据库、处理网络请求等,因此,开发者可以用JavaScript编写全栈应用程序,这一点大大提高了开发效率和便捷性。 在实践中,许多大型企业和组织已经采用Node.js作为其Web应用程序的开发平台,如Netflix、PayPal和Walmart等。它们利用Node.js提高了应用性能,简化了开发流程,并且能更快地响应市场需求。
深度残差网络ResNet-python源码.zip
触屏版自适应手机wap软件网站模板 触屏版自适应手机wap软件网站模板
2007-2022商业银行绿色信贷数据绿色信贷余额贷款总额绿色信贷比率不良贷款率 在一定的客观缺失。 1、数据来源:公司年报、可持续发展报告、社会责任报告 2、数 据范围: 36家上市银行 北京银行、常熟银行、成都银行、工商银行、光大银行、贵阳 银行、杭州银行、华夏银行、建设银行、江苏银行、江阴银行、交通银行、民生银行、南京 银行、宁波银行、农业银行、平安银行、浦发银行、青岛银行、青农商行、上海银行、苏农 银行、苏州银行、无锡农村商业银行、西安银行、兴业银行、邮储银行、渝农商行、张家港 行、长沙银行、招商银行、浙商银行、郑州银行、中国银行、中信银行、紫金银行
本文档是课题研究的研究报告内含调研以及源码设计以及结果分析
全球夜间灯光数据 参考文献 [1]徐康宁, 陈丰龙, and 刘修岩. "中国经 济增长的真实性:基于全球夜间灯光数据的检验." 经济研究 (2015). [2] 王贤彬等. "中国地区经济差距动态趋势重估——基于卫星灯光数据的考察." 经济学 (季刊) 16.2(2017):20. 基于美国国家海洋与大气管理局(NOAA) 的DMSP/OLS影像数据和VIIRS/DNB影像数据开发而成的,目前主要反映中 国各省、地级市及县区夜间灯光数据和一带一路沿线国家的夜间灯光数据情况。DMSP/ OLS影像灯光数据目前已经应用于经济类研究,并且已有较多文献发表在诸多高水平杂志 上,因此逐渐受到学者关注。VIIRS/DNB影像灯光数据在国内文献中还未被广泛应 用,但基于其具有许多优点因此逐渐受到学者关注。由于学者通常只能获得NOAA上面的 原始图片资料,将这些图像资料转化为可用数据需要用到较为复杂的计算机和编程技术。 数据包含 核心指标:[DN均值]-计算所得的DN总值/栅格数 项目 字段内容 数 据起始时间 DMSP中国各省份灯光数据(校正后) 省份名称、年度、DN均值 1992~20