- 浏览: 996674 次
-
文章分类
- 全部博客 (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)
SocketChannelImpl 解析一(通道连接,发送数据):http://donald-draper.iteye.com/blog/2372364
引言:
上一篇文章我们看了一下SocketChannelImpl的初始化,通道连接(Socket),写操作(write-ByteBuffer)。先回顾一下:
SocketChannelImpl构造主要是初始化读写及状态锁和通道socket文件描述。
connect连接方法首先同步读锁和写锁,确保socket通道打开,并没有连接;然后检查socket地址的正确性与合法性,然后检查当前线程是否有Connect方法的访问控制权限,最后尝试连接socket地址。从缓冲区读取字节序列写到通道write(ByteBuffer),首先确保通道打开,且输出流没有关闭,然后委托给IOUtil写字节序列;IOUtil写字节流过程为首先通过Util从当前线程的缓冲区获取可以容下字节序列的临时缓冲区(DirectByteBuffer),如果没有则创建一个DirectByteBuffer,将字节序列写到临时的DirectByteBuffer中,然后将写操作委托给nativedispatcher(SocketDispatcher),将DirectByteBuffer添加到当前线程的缓冲区,
以便重用,因为DirectByteBuffer实际上是存在物理内存中,频繁的分配将会消耗更多的资源。
上一篇文章我们看了写一个ByteBuffer,现在来看一下写多个ByteBuffer
由于我们在前面已经讲过写单个ByteBuffer的方法,此方与write(ByteBuffer)
基本相似,我们只需要关注下面这点几个:
在看上面这句之前我们先看一下IOVecWrapper
//字节序列数组包装类
来看IOVecWrapper的构造
构造中我们需要关注以下节点:
1.创建存储字节数组起始地址的内存空间
//AllocatedNativeObject
//NativeObject
2.获取字节序列数组包装类起始地址
//NativeObject
从构造可以看出,主要是初始化字节缓冲区包装类的容量,存放字节缓冲区数组,
存放字节缓冲区position数组,存放字节缓冲区容量数组,字节缓冲区副本数组,
创建存储字节数组起始地址的内存空间,初始化字节缓冲区包装类起始地址。
再来看其他方法
//获取存放i个字节缓冲区的缓冲区包装类
上面方法有两点要关注:
1.
//AllocatedNativeObject
2.
这一点我们在前面相关文章中有讲,我们简单看一下Deallocator
从 get(int i),可以看出实际上,先获取线程本地缓存中的iovecwrapper,如果
iovecwrapper不为null,且容量小于i,则释放iovecwrapper内存,置空iovecwrapper;
否则创建容量为i的iovecwrapper,并将iovecwrapper添加的引用对象清除器Cleander,
并添加到线程本地缓存cache中。
再来其他方法
小节:
IOVecWrapper构造,主要是初始化字节缓冲区包装类的容量,存放字节缓冲区数组,
存放字节缓冲区position数组,存放字节缓冲区容量数组,字节缓冲区副本数组,
创建存储字节数组起始地址的内存空间,初始化字节缓冲区包装类起始地址。
get(int i)方法,先获取线程本地缓存中的iovecwrapper,如果
iovecwrapper不为null,且容量小于i,则释放iovecwrapper内存,置空iovecwrapper;
否则创建容量为i的iovecwrapper,并将iovecwrapper添加的引用对象清除器Cleander,
并添加到线程本地缓存cache中。
在看完IOVecWrapper后,我们再回到写字节序列数组函数的关键部分:
//IOUtil
在IOUtil上面的write方法中我们需要关注的是下面这一句
nativedispatcher在SocketChannelImpl中实际为SocketDispatcher
//SocketDispatcher
至此我们把SocketChannelImpl写ByteBuffer数组方法看完,首先同步写锁,确保通道,输出流打开,连接建立委托给IOUtil,将ByteBuffer数组写到输出流中,这一过程为获取存放i个字节缓冲区的IOVecWrapper,遍历ByteBuffer数组m,将字节缓冲区添加到iovecwrapper的字节缓冲区数组中,如果ByteBuffer非Direct类型,委托Util从当前线程的缓冲区获取容量为j2临时DirectByteBuffer,并将ByteBuffer写到DirectByteBuffer,并将DirectByteBuffer添加到iovecwrapper的字节缓冲区(Shadow-Direct)数组中,将字节缓冲区的起始地址写到iovecwrapper,字节缓冲区的实际容量写到iovecwrapper;遍历iovecwrapper的字节缓冲区(Shadow-Direct)数组,将Shadow数组中的DirectByteBuffer通过Util添加到本地线程的缓存区中,并清除DirectByteBuffer在iovecwrapper的相应数组中的信息;最后通过
SocketDispatcher,将iovecwrapper的缓冲区数据,写到filedescriptor对应的输出流中。
总结:
SocketChannelImpl写ByteBuffer数组方法,首先同步写锁,确保通道,输出流打开,连接建立委托给IOUtil,将ByteBuffer数组写到输出流中,这一过程为获取存放i个字节缓冲区的IOVecWrapper,遍历ByteBuffer数组m,将字节缓冲区添加到iovecwrapper的字节缓冲区数组中,如果ByteBuffer非Direct类型,委托Util从当前线程的缓冲区获取容量为j2临时DirectByteBuffer,并将ByteBuffer写到DirectByteBuffer,并将DirectByteBuffer添加到iovecwrapper的字节缓冲区(Shadow-Direct)数组中,将字节缓冲区的起始地址写到iovecwrapper,字节缓冲区的实际容量写到iovecwrapper;遍历iovecwrapper的字节缓冲区(Shadow-Direct)数组,将Shadow数组中的DirectByteBuffer通过Util添加到本地线程的缓存区中,并清除DirectByteBuffer在iovecwrapper的相应数组中的信息;最后通过
SocketDispatcher,将iovecwrapper的缓冲区数据,写到filedescriptor对应的输出流中。
SocketChannelImpl 解析三(接收数据):http://donald-draper.iteye.com/blog/2372590
引言:
上一篇文章我们看了一下SocketChannelImpl的初始化,通道连接(Socket),写操作(write-ByteBuffer)。先回顾一下:
SocketChannelImpl构造主要是初始化读写及状态锁和通道socket文件描述。
connect连接方法首先同步读锁和写锁,确保socket通道打开,并没有连接;然后检查socket地址的正确性与合法性,然后检查当前线程是否有Connect方法的访问控制权限,最后尝试连接socket地址。从缓冲区读取字节序列写到通道write(ByteBuffer),首先确保通道打开,且输出流没有关闭,然后委托给IOUtil写字节序列;IOUtil写字节流过程为首先通过Util从当前线程的缓冲区获取可以容下字节序列的临时缓冲区(DirectByteBuffer),如果没有则创建一个DirectByteBuffer,将字节序列写到临时的DirectByteBuffer中,然后将写操作委托给nativedispatcher(SocketDispatcher),将DirectByteBuffer添加到当前线程的缓冲区,
以便重用,因为DirectByteBuffer实际上是存在物理内存中,频繁的分配将会消耗更多的资源。
上一篇文章我们看了写一个ByteBuffer,现在来看一下写多个ByteBuffer
public long write(ByteBuffer abytebuffer[], int i, int j) throws IOException { //检查offset(i),length(j)的合法性 if(i < 0 || j < 0 || i > abytebuffer.length - j) throw new IndexOutOfBoundsException(); Object obj = writeLock;//获取写锁 JVM INSTR monitorenter ;//进入同步,try long l; //确保通道,输出流打开,连接建立 ensureWriteOpen(); l = 0L; begin();//与end方法配合,记录中断器,处理中断 long l2; synchronized(stateLock) { if(isOpen()) break MISSING_BLOCK_LABEL_165; l2 = 0L; } writerCleanup();//清除写线程 end(l > 0L || l == -2L); synchronized(stateLock) { if(l <= 0L && !isOutputOpen) throw new AsynchronousCloseException(); } if(!$assertionsDisabled && !IOStatus.check(l)) throw new AssertionError(); return l2; //初始化本地写线程 writerThread = NativeThread.current(); obj1; JVM INSTR monitorexit ; long l1; do //委托IOUtil写字节数组序列 l = IOUtil.write(fd, abytebuffer, i, j, nd); while(l == -3L && isOpen()); l1 = IOStatus.normalize(l); writerCleanup(); end(l > 0L || l == -2L); synchronized(stateLock) { if(l <= 0L && !isOutputOpen) throw new AsynchronousCloseException(); } if(!$assertionsDisabled && !IOStatus.check(l)) throw new AssertionError(); obj; JVM INSTR monitorexit ;//退出同步 return l1; Exception exception3;//有异常则抛出 exception3; writerCleanup(); end(l > 0L || l == -2L); synchronized(stateLock) { if(l <= 0L && !isOutputOpen) throw new AsynchronousCloseException(); } if(!$assertionsDisabled && !IOStatus.check(l)) throw new AssertionError(); else throw exception3; Exception exception5; exception5; throw exception5; }
由于我们在前面已经讲过写单个ByteBuffer的方法,此方与write(ByteBuffer)
基本相似,我们只需要关注下面这点几个:
do //委托IOUtil写字节数组序列 l = IOUtil.write(fd, abytebuffer, i, j, nd); while(l == -3L && isOpen());
在看上面这句之前我们先看一下IOVecWrapper
//字节序列数组包装类
class IOVecWrapper { private static final int BASE_OFFSET = 0; private static final int LEN_OFFSET; private static final int SIZE_IOVEC;// private final AllocatedNativeObject vecArray;//存放字节数组的地址 private final int size;//字节数据大小 private final ByteBuffer buf[];//存放字节数组 private final int position[];//存放每个字节数组的position private final int remaining[];//存放每个字节数组的字节数量remaining private final ByteBuffer shadow[];//存放字节数组副本 final long address;//字节序列数组包装类的起始地址 static int addressSize;//操作系统物理地址所占的字节数 private static final ThreadLocal cached = new ThreadLocal();//线程本地缓存 static { addressSize = Util.unsafe().addressSize(); LEN_OFFSET = addressSize; //为什么要地址长度的2倍,一个存放字节缓冲的地址,一个存字节缓冲区的实际长度。 SIZE_IOVEC = (short)(addressSize * 2);//存放字节数组的实际地址 } }
来看IOVecWrapper的构造
private IOVecWrapper(int i) { size = i; buf = new ByteBuffer[i]; position = new int[i]; remaining = new int[i]; shadow = new ByteBuffer[i]; //创建存储字节数组起始地址的内存空间 vecArray = new AllocatedNativeObject(i * SIZE_IOVEC, false); //获取字节序列数组包装类起始地址 address = vecArray.address(); }
构造中我们需要关注以下节点:
1.创建存储字节数组起始地址的内存空间
vecArray = new AllocatedNativeObject(i * SIZE_IOVEC, false);
//AllocatedNativeObject
class AllocatedNativeObject extends NativeObject { AllocatedNativeObject(int i, boolean flag) { super(i, flag); } }
//NativeObject
protected NativeObject(int i, boolean flag) { if(!flag) { //分配可以存i个字节的物理内存 allocationAddress = unsafe.allocateMemory(i); //初始化起始地址 address = allocationAddress; } else { //在分配i个字节的基础上,多分配一页内存,这个我们在前面以说,这里不再说 int j = pageSize(); long l = unsafe.allocateMemory(i + j); allocationAddress = l; address = (l + (long)j) - (l & (long)(j - 1)); } }
2.获取字节序列数组包装类起始地址
address = vecArray.address();
//NativeObject
long address() { return address; }
从构造可以看出,主要是初始化字节缓冲区包装类的容量,存放字节缓冲区数组,
存放字节缓冲区position数组,存放字节缓冲区容量数组,字节缓冲区副本数组,
创建存储字节数组起始地址的内存空间,初始化字节缓冲区包装类起始地址。
再来看其他方法
//获取存放i个字节缓冲区的缓冲区包装类
static IOVecWrapper get(int i) { //获取线程本地的iovecwrapper IOVecWrapper iovecwrapper = (IOVecWrapper)cached.get(); if(iovecwrapper != null && iovecwrapper.size < i) { //iovecwrapper不为null,且容量小于i,则释放iovecwrapper内存 iovecwrapper.vecArray.free(); iovecwrapper = null; } if(iovecwrapper == null) { //创建存放i个字节缓冲区的缓冲区包装类 iovecwrapper = new IOVecWrapper(i); //添加iovecwrapper到引用对象Cleaner Cleaner.create(iovecwrapper, new Deallocator(iovecwrapper.vecArray)); //添加iovecwrapper到线程本地缓存 cached.set(iovecwrapper); } return iovecwrapper; }
上面方法有两点要关注:
1.
//iovecwrapper不为null,且容量小于i,则释放iovecwrapper内存 iovecwrapper.vecArray.free();
//AllocatedNativeObject
synchronized void free() { if(allocationAddress != 0L) { //释放物理内存 unsafe.freeMemory(allocationAddress); allocationAddress = 0L; } }
2.
//添加iovecwrapper到引用对象清除器Cleaner Cleaner.create(iovecwrapper, new Deallocator(iovecwrapper.vecArray));
这一点我们在前面相关文章中有讲,我们简单看一下Deallocator
//Deallocator,引用对象清除器 private static class Deallocator implements Runnable { //这个方法为清除器,实际执行的操作,即释放分配给iovecwrapper的物理内存 public void run() { obj.free(); } private final AllocatedNativeObject obj; Deallocator(AllocatedNativeObject allocatednativeobject) { obj = allocatednativeobject; } }
从 get(int i),可以看出实际上,先获取线程本地缓存中的iovecwrapper,如果
iovecwrapper不为null,且容量小于i,则释放iovecwrapper内存,置空iovecwrapper;
否则创建容量为i的iovecwrapper,并将iovecwrapper添加的引用对象清除器Cleander,
并添加到线程本地缓存cache中。
再来其他方法
//添加字节数组 void setBuffer(int i, ByteBuffer bytebuffer, int j, int k) { //添加字节缓冲区到字节缓冲区包装类的字节数组中,并将字节缓冲区的position及 容量remaining信息,存放到字节缓冲区包装类相应的数组中 buf[i] = bytebuffer; position[i] = j; remaining[i] = k; } //将字节缓冲区i的起始地址l写到内存中 void putBase(int i, long l) { int j = SIZE_IOVEC * i + 0; if(addressSize == 4) //地址长度为4个字节 vecArray.putInt(j, (int)l); else //地址长度为8个字节 vecArray.putLong(j, l); } //将字节缓冲区i的容量l写到内存中 void putLen(int i, long l) { int j = SIZE_IOVEC * i + LEN_OFFSET; if(addressSize == 4) vecArray.putInt(j, (int)l); else vecArray.putLong(j, l); } //添加字节缓冲区bytebuffer到字节缓冲区包装类的字节缓冲区副本数组中 void setShadow(int i, ByteBuffer bytebuffer) { shadow[i] = bytebuffer; } //获取索引i对应的字节缓冲区 ByteBuffer getBuffer(int i) { return buf[i]; } //获取索引i对应的字节缓冲区Position int getPosition(int i) { return position[i]; } //获取索引i对应的字节缓冲区Remaining int getRemaining(int i) { return remaining[i]; } //获取索引i对应的字节缓冲区副本 ByteBuffer getShadow(int i) { return shadow[i]; } //清除字节缓冲区包装类的字节缓冲区和相应的副本数组索引i对应的字节缓冲区 void clearRefs(int i) { buf[i] = null; shadow[i] = null; }
小节:
IOVecWrapper构造,主要是初始化字节缓冲区包装类的容量,存放字节缓冲区数组,
存放字节缓冲区position数组,存放字节缓冲区容量数组,字节缓冲区副本数组,
创建存储字节数组起始地址的内存空间,初始化字节缓冲区包装类起始地址。
get(int i)方法,先获取线程本地缓存中的iovecwrapper,如果
iovecwrapper不为null,且容量小于i,则释放iovecwrapper内存,置空iovecwrapper;
否则创建容量为i的iovecwrapper,并将iovecwrapper添加的引用对象清除器Cleander,
并添加到线程本地缓存cache中。
在看完IOVecWrapper后,我们再回到写字节序列数组函数的关键部分:
do //委托IOUtil写字节数组序列 l = IOUtil.write(fd, abytebuffer, i, j, nd); while(l == -3L && isOpen());
//IOUtil
static long write(FileDescriptor filedescriptor, ByteBuffer abytebuffer[], int i, int j, NativeDispatcher nativedispatcher) throws IOException { IOVecWrapper iovecwrapper; boolean flag; int k; //获取存放i个字节缓冲区的IOVecWrapper iovecwrapper = IOVecWrapper.get(j); flag = false; k = 0; long l1; int l = i + j; for(int i1 = i; i1 < l && k < IOV_MAX; i1++) { ByteBuffer bytebuffer = abytebuffer[i1]; int j1 = bytebuffer.position(); int k1 = bytebuffer.limit(); if(!$assertionsDisabled && j1 > k1) throw new AssertionError(); int j2 = j1 > k1 ? 0 : k1 - j1; if(j2 <= 0) continue; //将字节缓冲区添加到iovecwrapper的字节缓冲区数组中 iovecwrapper.setBuffer(k, bytebuffer, j1, j2); if(!(bytebuffer instanceof DirectBuffer)) { //获取容量为j2临时DirectByteBuffer ByteBuffer bytebuffer2 = Util.getTemporaryDirectBuffer(j2); //将字节序列写到DirectByteBuffer bytebuffer2.put(bytebuffer); //读写转换 bytebuffer2.flip(); iovecwrapper.setShadow(k, bytebuffer2); bytebuffer.position(j1); bytebuffer = bytebuffer2; j1 = bytebuffer2.position(); } //将字节缓冲区的起始地址写到iovecwrapper iovecwrapper.putBase(k, ((DirectBuffer)bytebuffer).address() + (long)j1); //将字节缓冲区的实际容量写到iovecwrapper iovecwrapper.putLen(k, j2); k++; } if(k != 0) break MISSING_BLOCK_LABEL_267; l1 = 0L; if(!flag) { for(int i2 = 0; i2 < k; i2++) { //获取iovecwrapper索引i2对应的字节序列副本 ByteBuffer bytebuffer1 = iovecwrapper.getShadow(i2); if(bytebuffer1 != null) //如果字节序列不为空,则添加到当前线程的缓存区中 Util.offerLastTemporaryDirectBuffer(bytebuffer1); //清除索引i2对应的字节序列在iovecwrapper中的字节序列数组,及相应副本数组的信息 iovecwrapper.clearRefs(i2); } } return l1; long l4; //委托给nativedispatcher,将iovecwrapper的缓冲区数据,写到filedescriptor对应的输出流中。 long l2 = nativedispatcher.writev(filedescriptor, iovecwrapper.address, k); ... }
在IOUtil上面的write方法中我们需要关注的是下面这一句
//委托给nativedispatcher,将iovecwrapper的缓冲区数据,写到filedescriptor对应的输出流中。 long l2 = nativedispatcher.writev(filedescriptor, iovecwrapper.address, k);
nativedispatcher在SocketChannelImpl中实际为SocketDispatcher
//SocketDispatcher
long writev(FileDescriptor filedescriptor, long l, int i) throws IOException { return writev0(filedescriptor, l, i); } static native long writev0(FileDescriptor filedescriptor, long l, int i) throws IOException;
至此我们把SocketChannelImpl写ByteBuffer数组方法看完,首先同步写锁,确保通道,输出流打开,连接建立委托给IOUtil,将ByteBuffer数组写到输出流中,这一过程为获取存放i个字节缓冲区的IOVecWrapper,遍历ByteBuffer数组m,将字节缓冲区添加到iovecwrapper的字节缓冲区数组中,如果ByteBuffer非Direct类型,委托Util从当前线程的缓冲区获取容量为j2临时DirectByteBuffer,并将ByteBuffer写到DirectByteBuffer,并将DirectByteBuffer添加到iovecwrapper的字节缓冲区(Shadow-Direct)数组中,将字节缓冲区的起始地址写到iovecwrapper,字节缓冲区的实际容量写到iovecwrapper;遍历iovecwrapper的字节缓冲区(Shadow-Direct)数组,将Shadow数组中的DirectByteBuffer通过Util添加到本地线程的缓存区中,并清除DirectByteBuffer在iovecwrapper的相应数组中的信息;最后通过
SocketDispatcher,将iovecwrapper的缓冲区数据,写到filedescriptor对应的输出流中。
总结:
SocketChannelImpl写ByteBuffer数组方法,首先同步写锁,确保通道,输出流打开,连接建立委托给IOUtil,将ByteBuffer数组写到输出流中,这一过程为获取存放i个字节缓冲区的IOVecWrapper,遍历ByteBuffer数组m,将字节缓冲区添加到iovecwrapper的字节缓冲区数组中,如果ByteBuffer非Direct类型,委托Util从当前线程的缓冲区获取容量为j2临时DirectByteBuffer,并将ByteBuffer写到DirectByteBuffer,并将DirectByteBuffer添加到iovecwrapper的字节缓冲区(Shadow-Direct)数组中,将字节缓冲区的起始地址写到iovecwrapper,字节缓冲区的实际容量写到iovecwrapper;遍历iovecwrapper的字节缓冲区(Shadow-Direct)数组,将Shadow数组中的DirectByteBuffer通过Util添加到本地线程的缓存区中,并清除DirectByteBuffer在iovecwrapper的相应数组中的信息;最后通过
SocketDispatcher,将iovecwrapper的缓冲区数据,写到filedescriptor对应的输出流中。
SocketChannelImpl 解析三(接收数据):http://donald-draper.iteye.com/blog/2372590
发表评论
-
文件通道解析二(文件锁,关闭通道)
2017-05-16 23:17 1103文件通道解析一(读写操作,通道数据传输等):http://do ... -
文件通道解析一(读写操作,通道数据传输等)
2017-05-16 10:04 1197Reference定义(PhantomRefere ... -
文件通道创建方式综述
2017-05-15 17:39 1104Reference定义(PhantomReference,Cl ... -
文件读写方式简单综述后续(文件,流构造)
2017-05-14 23:04 1521Java Socket通信实例:http://donald-d ... -
文件读写方式简单综述
2017-05-14 11:13 1166Java Socket通信实例:http://donald-d ... -
FileChanne定义
2017-05-12 23:28 980文件读写方式简单综述:http://donald-draper ... -
SeekableByteChannel接口定义
2017-05-11 08:43 1270ByteChannel,分散聚集通道接口的定义(SocketC ... -
FileChannel示例
2017-05-11 08:37 1019前面我们看过socket通道,datagram通道,以管道Pi ... -
PipeImpl解析
2017-05-11 08:41 967ServerSocketChannel定义:http://do ... -
Pipe定义
2017-05-10 09:07 938Channel接口定义:http://donald-drape ... -
NIO-Pipe示例
2017-05-10 08:47 945PipeImpl解析:http://donald-draper ... -
DatagramChannelImpl 解析四(地址绑定,关闭通道等)
2017-05-10 08:27 827DatagramChannelImpl 解析一(初始化):ht ... -
DatagramChannelImpl 解析三(多播)
2017-05-10 08:20 1984DatagramChannelImpl 解析一(初始化):ht ... -
NIO-UDP实例
2017-05-09 12:32 1622DatagramChannelImpl 解析一(初始化):ht ... -
DatagramChannelImpl 解析二(报文发送与接收)
2017-05-09 09:03 1442DatagramChannelImpl 解析一(初始化):ht ... -
DatagramChannelImpl 解析一(初始化)
2017-05-08 21:52 1459Channel接口定义:http://donald-drape ... -
MembershipKeyImpl 简介
2017-05-08 09:11 956MembershipKey定义:http://donald-d ... -
DatagramChannel定义
2017-05-07 23:13 1261Channel接口定义:http://donald-drape ... -
MulticastChanne接口定义
2017-05-07 13:45 1187NetworkChannel接口定义:ht ... -
MembershipKey定义
2017-05-06 16:20 955package java.nio.channels; i ...
相关推荐
此外,Stream API也是1.8的一大亮点,它提供了处理集合的新方式,可以进行数据流的过滤、映射、归约等操作,大大简化了数据处理的代码。 在"jdk-5b86f66575b7"这个压缩包中,很可能包含了JDK 1.8的完整源码,包括...
at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:574) at IceInternal.Network.doFinishConnect(Network.java:393) ... 6 more 这种报错是ICE服务端没有起来,telnet服务端ICE的端口不通...
# 基于C语言的SmartPlugModbus固件项目 ## 项目简介 该项目是一个基于C语言的固件项目,旨在实现一个支持Modbus RTU通信协议的智能设备固件。该固件被设计为与SmartPlugModbus设备配合使用,用于控制和管理多个电源插座,提供过流、欠流、过压、欠压和过热保护,同时监控插座状态和电压、电流等参数。 ## 项目的主要特性和功能 1. Modbus RTU通信协议支持固件实现了Modbus RTU通信协议,允许通过Modbus协议与设备进行通信,包括读取和写入设备参数、状态和控制命令。 2. 多插座控制固件支持控制多个电源插座,包括开启、关闭、查询状态等。 3. 保护功能设备提供过流、欠流、过压、欠压和过热保护,防止设备损坏和安全事故。 4. 参数配置通过Modbus协议,用户可以配置设备的保护参数,如电流、电压限制等。
【项目资源】: 单片机项目适用于从基础到高级的各种项目,特别是在性能要求较高的场景中,比如操作系统开发、嵌入式编程和底层系统编程。如果您是初学者,可以从简单的控制台程序开始练习;如果是进阶开发者,可以尝试涉及硬件或网络的项目。 【项目质量】: 所有源码都经过严格测试,可以直接运行。 功能在确认正常工作后才上传。 【适用人群】: 适用于希望学习不同技术领域的小白或进阶学习者。 可作为毕设项目、课程设计、大作业、工程实训或初期项目立项。 【附加价值】: 项目具有较高的学习借鉴价值,也可直接拿来修改复刻。 对于有一定基础或热衷于研究的人来说,可以在这些基础代码上进行修改和扩展,实现其他功能。 【沟通交流】: 有任何使用上的问题,欢迎随时与博主沟通,博主会及时解答。 鼓励下载和使用,并欢迎大家互相学习,共同进步。 # 注意 1. 本资源仅用于开源学习和技术交流。不可商用等,一切后果由使用者承担。 2. 部分字体以及插图等来自网络,若是侵权请联系删除。
【项目资源】: 物联网项目适用于从基础到高级的各种项目,特别是在性能要求较高的场景中,比如操作系统开发、嵌入式编程和底层系统编程。如果您是初学者,可以从简单的控制台程序开始练习;如果是进阶开发者,可以尝试涉及硬件或网络的项目。 【项目质量】: 所有源码都经过严格测试,可以直接运行。 功能在确认正常工作后才上传。 【适用人群】: 适用于希望学习不同技术领域的小白或进阶学习者。 可作为毕设项目、课程设计、大作业、工程实训或初期项目立项。 【附加价值】: 项目具有较高的学习借鉴价值,也可直接拿来修改复刻。 对于有一定基础或热衷于研究的人来说,可以在这些基础代码上进行修改和扩展,实现其他功能。 【沟通交流】: 有任何使用上的问题,欢迎随时与博主沟通,博主会及时解答。 鼓励下载和使用,并欢迎大家互相学习,共同进步。 # 注意 1. 本资源仅用于开源学习和技术交流。不可商用等,一切后果由使用者承担。 2. 部分字体以及插图等来自网络,若是侵权请联系删除。
# 基于嵌入式系统的StackAttack游戏项目 ## 项目简介 StackAttack是一个基于嵌入式系统的游戏项目,设计用于SPI TFT彩色液晶显示面板上运行。游戏的核心玩法是操控一个名为“Claw”(爪子)的游戏角色,在由格子组成的地图上移动并抓取箱子。玩家通过操纵杆控制游戏角色,成功抓取并移动箱子到目标位置后得分。游戏地图由二维数组表示,每个格子代表一个位置。当玩家成功将所有箱子移动到目标行时,游戏结束。 ## 项目的主要特性和功能 1. 游戏角色控制玩家通过操纵杆控制Claw(爪子)角色移动。 2. 地图和箱子管理游戏地图由二维数组表示,每个格子代表一个位置。箱子在游戏地图上的位置由数组中的值表示。 3. 游戏逻辑包括角色的移动、箱子的抓取和移动、得分计算等。 4. 图形显示使用SPITFTILI9341图形库控制SPI TFT显示屏,实现游戏的图形输出。 5. 暂停功能游戏支持暂停功能,方便玩家随时暂停游戏。
内容概要:本文档提供了基于STM32、OpenCV和卷积神经网络的车牌识别系统的完整代码示例。系统通过摄像头捕捉视频流,利用OpenCV进行图像处理(如灰度化、二值化、轮廓检测等)以定位车牌区域,并使用预训练的ONNX模型对车牌字符进行识别。之后,系统将识别到的车牌号与预先存储在CSV文件中的居民车牌数据库进行匹配,以判断车辆是否为小区居民所有,从而实现对外来车辆的收费管理。; 适合人群:对嵌入式系统开发、计算机视觉和深度学习感兴趣的开发者,尤其是有一定C++编程基础和技术背景的研究人员或工程师。; 使用场景及目标:①适用于社区、停车场等场所的车辆管理;②帮助开发者理解车牌识别的基本流程,包括图像预处理、车牌定位、字符识别以及与数据库的交互;③提供一个可扩展的基础框架,便于后续优化和功能增加。; 阅读建议:读者应确保具备基本的OpenCV库使用经验和C++编程能力。在学习过程中,建议同时参考相关文献资料,深入理解每个步骤背后的原理,并尝试调整参数或替换模型以提高识别精度。此外,还需准备相应的硬件设备(如摄像头)和软件环境(如安装OpenCV库),以便实际运行代码并观察效果。
efwfw
内容概要:本文详细介绍了利用西门子S7-200 PLC和MCGS组态软件构建智能交通灯控制系统的方法。首先阐述了系统的硬件配置,包括PLC的选择、IO分配、光电开关的应用等。接着深入探讨了梯形图编程的核心逻辑,如定时器嵌套、车流判断、紧急模式处理等。同时,还讲解了MCGS组态界面的设计要点,如动态指示灯、车流统计曲线、急停按钮等功能的实现。此外,文中分享了一些调试经验和优化技巧,如信号隔离、通信参数设置、夜间模式优化等。 适合人群:对PLC编程和工业自动化感兴趣的工程技术人员、高校相关专业学生。 使用场景及目标:适用于城市交通管理部门进行智能交通灯系统的规划与实施,旨在提高交通效率,减少拥堵。通过学习本文,读者能够掌握PLC编程的基本方法和MCGS组态软件的使用技巧。 其他说明:文中提供了详细的接线图、梯形图代码片段和组态界面截图,便于读者理解和实践。同时,作者还分享了许多实际操作中的注意事项和经验教训,有助于初学者少走弯路。
【项目资源】: 物联网项目适用于从基础到高级的各种项目,特别是在性能要求较高的场景中,比如操作系统开发、嵌入式编程和底层系统编程。如果您是初学者,可以从简单的控制台程序开始练习;如果是进阶开发者,可以尝试涉及硬件或网络的项目。 【项目质量】: 所有源码都经过严格测试,可以直接运行。 功能在确认正常工作后才上传。 【适用人群】: 适用于希望学习不同技术领域的小白或进阶学习者。 可作为毕设项目、课程设计、大作业、工程实训或初期项目立项。 【附加价值】: 项目具有较高的学习借鉴价值,也可直接拿来修改复刻。 对于有一定基础或热衷于研究的人来说,可以在这些基础代码上进行修改和扩展,实现其他功能。 【沟通交流】: 有任何使用上的问题,欢迎随时与博主沟通,博主会及时解答。 鼓励下载和使用,并欢迎大家互相学习,共同进步。 # 注意 1. 本资源仅用于开源学习和技术交流。不可商用等,一切后果由使用者承担。 2. 部分字体以及插图等来自网络,若是侵权请联系删除。
摘 要 面对信息时代的机遇与挑战,利用高科技手段来提高企业的管理水平无疑是一条行之有效的途径。利用计算机管理可以最大限度的发挥准确、快捷、高效等作用, 在越来越激烈的珠宝行业中,计算机管理技术对珠宝首饰公司的服务管理提供强有力的支持。因此,利用全新的计算机网络和珠宝首饰管理系统,已成为提高珠宝首饰公司的管理效率,改进服务水准的重要手段之一。本系统应用Visual Basic 6.0 中文版开发前台,用Microsoft Access 作后台服务器,采用客户机/服务器(C/S)管理思想来对珠宝首饰进销存管理。 关键词:管理水平, 管理效率,服务水准,珠宝首饰管理系统,客户机/服务器,管理思想
稀疏分解方法在信号去噪中的应用研究_内含源码数据论文.zip
本书由吉姆·诺埃尔和大卫·多蒂奇编辑,旨在探讨领导力发展领域的最新趋势和实践。书中不仅提供了领导力发展领域的历史回顾,还挑战了组织对领导力发展的战略视角,详细介绍了如何培养全球领导者,并提供了关于领导力发展方法、策略和系统、高潜力人才发展、高层管理参与、有效学习方法以及领导力指标等方面的深入案例研究和理论分析。此外,书中还探讨了创新的领导力发展方法,并对未来的发展趋势进行了展望。
一种基于 QR 二维码的彩色二维码编码译码设计及其软件实现.zip
【项目资源】: 单片机项目适用于从基础到高级的各种项目,特别是在性能要求较高的场景中,比如操作系统开发、嵌入式编程和底层系统编程。如果您是初学者,可以从简单的控制台程序开始练习;如果是进阶开发者,可以尝试涉及硬件或网络的项目。 【项目质量】: 所有源码都经过严格测试,可以直接运行。 功能在确认正常工作后才上传。 【适用人群】: 适用于希望学习不同技术领域的小白或进阶学习者。 可作为毕设项目、课程设计、大作业、工程实训或初期项目立项。 【附加价值】: 项目具有较高的学习借鉴价值,也可直接拿来修改复刻。 对于有一定基础或热衷于研究的人来说,可以在这些基础代码上进行修改和扩展,实现其他功能。 【沟通交流】: 有任何使用上的问题,欢迎随时与博主沟通,博主会及时解答。 鼓励下载和使用,并欢迎大家互相学习,共同进步。 # 注意 1. 本资源仅用于开源学习和技术交流。不可商用等,一切后果由使用者承担。 2. 部分字体以及插图等来自网络,若是侵权请联系删除。
【项目资源】: 物联网项目适用于从基础到高级的各种项目,特别是在性能要求较高的场景中,比如操作系统开发、嵌入式编程和底层系统编程。如果您是初学者,可以从简单的控制台程序开始练习;如果是进阶开发者,可以尝试涉及硬件或网络的项目。 【项目质量】: 所有源码都经过严格测试,可以直接运行。 功能在确认正常工作后才上传。 【适用人群】: 适用于希望学习不同技术领域的小白或进阶学习者。 可作为毕设项目、课程设计、大作业、工程实训或初期项目立项。 【附加价值】: 项目具有较高的学习借鉴价值,也可直接拿来修改复刻。 对于有一定基础或热衷于研究的人来说,可以在这些基础代码上进行修改和扩展,实现其他功能。 【沟通交流】: 有任何使用上的问题,欢迎随时与博主沟通,博主会及时解答。 鼓励下载和使用,并欢迎大家互相学习,共同进步。 # 注意 1. 本资源仅用于开源学习和技术交流。不可商用等,一切后果由使用者承担。 2. 部分字体以及插图等来自网络,若是侵权请联系删除。
内容概要:本文详细介绍了使用COMSOL Multiphysics的弱形式接口对三维光子晶体进行数值模拟的方法和技巧。文章通过具体的代码示例,解释了如何构建光子晶体的介电常数分布、设置弱形式PDE、处理电磁场切向连续性、应用Floquet周期边界条件以及特征值求解等关键步骤。特别强调了弱形式接口相比传统物理场接口的优势,如灵活性和对复杂边界的处理能力。文中还分享了一些实用的经验和注意事项,如布洛赫边界条件的实现、特征值求解器参数的优化配置以及网格划分的技巧。 适合人群:具备一定电磁学和数值模拟基础的研究人员或工程师,尤其是对光子晶体仿真感兴趣的读者。 使用场景及目标:①理解并掌握COMSOL弱形式接口在光子晶体仿真中的应用;②学习如何通过弱形式设置处理复杂的电磁场问题;③提高对光子晶体能带结构和带隙特性的认识;④掌握特征值求解和网格划分的最佳实践。 阅读建议:由于本文涉及较多的具体代码和物理概念,建议读者在阅读过程中结合COMSOL软件进行实际操作,同时查阅相关电磁理论书籍以加深理解。此外,对于文中提到的一些具体参数设置和技巧,可以通过尝试不同的配置来巩固所学知识。
内容概要:PT5000汽轮机滑动轴承系统模拟试验台是一个类似于电厂汽轮机发电机的缩小模型,旨在帮助用户获取汽轮机转子动态行为和滑动轴承油膜现象的实际经验,并研究振动控制方法。该试验台模拟两级涡轮机(低压和中压),每级转子两侧各有8个叶片,共计16个叶片。通过电机驱动而非涡轮发电机,可以进行启停机测试,识别共振现象。试验台还支持多种实验,如不平衡/现场动平衡、轴不对中实验、摩擦实验、油膜故障试验、轴颈轴承实验以及根据油压和温度进行的转子动力学试验。试验台配备了多种传感器和控制系统,包括电涡流传感器、温度传感器、压力传感器等,用于监测和记录实验数据。 适合人群:从事汽轮机设计、制造、维护的技术人员,以及相关专业的高校师生和研究人员。 使用场景及目标:①研究汽轮机转子的动态行为和滑动轴承的油膜现象;②进行振动控制方法的研究;③模拟再现油膜涡动转和油膜震荡,研究其控制条件;④进行不平衡、不对中、摩擦等常见故障的模拟和分析;⑤通过调整油压、温度和预加载力,研究轴的行为变化。 其他说明:该试验台不仅适用于教学和科研,还可用于工业领域的培训和技术验证。试验台具有丰富的配置和可选配件,可以根据具体需求进行定制。试验台的机械和电气参数详细列出,确保用户能够全面了解设备性能。
电影类型知识图谱构建,包含相关数据集
# 基于C++的Minimal BASIC解释器 ## 项目简介 本项目是一个C++实现的Minimal BASIC解释器。该解释器能够解释并执行一些基本的BASIC语言命令,如赋值、打印、输入、条件跳转等。用户可以通过命令行交互地输入命令,或者编写一个按行数升序依次运行的大程序。 ## 项目的主要特性和功能 1. 解释执行能够解释并执行简单的BASIC语言命令。 2. 变量定义与赋值支持定义变量并为其赋值。 3. 打印输出支持将表达式的值打印到控制台。 4. 输入支持从用户获取输入值并赋值给变量。 5. 条件跳转支持基于条件的跳转语句。 6. 注释支持注释语句,使程序更加易读。 ## 安装使用步骤 1. 准备环境确保你的开发环境已经安装了C++编译器,如GCC。 3. 编译使用CMake工具编译源代码。 4. 运行编译成功后,运行可执行文件,即可与解释器交互。 ## 注意事项