java 阻塞 socket_java socket非阻塞I/O

1      非阻塞(Nonblocking)体系结构

在这一部分,我将从理论的角度来解释非阻塞体系的结构及其工作原理。这部“喜剧”(当然,如果你喜欢的话也可以称做戏剧)的“人物”如下:

●服务器端:接收请求的应用程序。

●客户端:向服务器端发出请求的应用程序。

●套接字通道:客户端与服务器端之间的通信通道。它能识别服务器端的IP地址和端口号。数据以Buffer中元素的形式通过套接字通道传送。

●选择器:所有非阻塞技术的主要对象。它监视着已注册的套接字通道,并序列化服务器需要应答的请求。

●关键字:选择器用来对对象的请求进行排序。每个关键字代表一个单独的客户端子请求并包含识别客户端和请求类型的信息。

2 SocketChannel 类

SocketAddress rama = new SocketAddress("localhost" , 8888) ;

利用静态工厂方法得到SocketChannel的实例。

SocketChannel client = SocketChannel.open(rama) ;

如果这是传统的套接字,那么就会寻求得到socket的输入或者输出流,利用通道,我们可以直接写入通道本身,

不是写入字节数组,而是要写入ByteBuffer对象,将此对象写入 client的read 方法。

b60c9848b8bdb26972b8b8877bdfc74a.png

客户端应用程序同时执行对服务器端的请求,接着选择器将其集中起来,创建关键字,然后将其发

送至服务器端。这看起来像是阻塞(Blocking)体系,因为在一定时间内只处理一个请求,但事实并非如此。

实际上,每个关键字不代表从客户端发至服务器端的整个信息流,仅仅只是一部分。我们不要忘了选择器能

分割那些被关键字标识的子请求里的数据。因此,如果有更多连续地数据发送至服务器端,那么选择器就会

创建更多的根据时间共享策略(Time-sharing policy)来进行处理的关键字。强调一下,在图一中关键字的颜色

与客户端的颜色相对应。

服务器端非阻塞(Server Nonblocking)

客户端和服务器端是两个Java应用程序。套接字通道是SocketChannel类的实例,这个类允许通过网络传送数据。

它们能被Java程序员看作是一个新的套接字。SocketChannel类被定义在java.nio.channel包中。

选择器是一个Selector类的对象。该类的每个实例均能监视更多的套接字通道,进而建立更多的连接。

当一些有意义的事发生在通道上(如客户端试图连接服务器端或进行读/写操作),选择器便会通知应用程序处理请求。

选择器会创建一个关键字,这个关键字是SelectionKey类的一个实例。每个关键字都保存着应用程序的标识及请求的类型。

其中,请求的类型可以是如下之一:

基本上,服务器端的实现是由选择器等待事件和创建关键字的无限循环组成的。根据关键字的类型,及时的执行操作。

关键字存在以下4种可能的类型。

Acceptable: 相应的客户端要求连接。

Connectable:服务器端接受连接。

Readable:服务器端可读。

Writeable:服务器端可写。

一个通用的实现非阻塞服务器的算法如下:

create SocketChannel;

create Selector

associate the SocketChannel to the Selector

for(;;) {

waiting events from the Selector;

event arrived; create keys;

for each key created by Selector {

check the type of request;

isAcceptable:

get the client SocketChannel;

associate that SocketChannel to the Selector;

record it for read/write operations

continue;

isReadable:

get the client SocketChannel;

read from the socket;

continue;

isWriteable:

get the client SocketChannel;

write on the socket;

continue;

}

}

3  下面为一个实例

(1)客户端

1

4f1150b881333f12a311ae9ef34da474.pngpackagecn.bupt.channel;24f1150b881333f12a311ae9ef34da474.png34f1150b881333f12a311ae9ef34da474.pngimportjava.io.IOException;44f1150b881333f12a311ae9ef34da474.pngimportjava.net.InetSocketAddress;54f1150b881333f12a311ae9ef34da474.pngimportjava.net.SocketAddress;64f1150b881333f12a311ae9ef34da474.pngimportjava.nio.ByteBuffer;74f1150b881333f12a311ae9ef34da474.pngimportjava.nio.channels.Channels;84f1150b881333f12a311ae9ef34da474.pngimportjava.nio.channels.SocketChannel;94f1150b881333f12a311ae9ef34da474.pngimportjava.nio.channels.WritableByteChannel;104f1150b881333f12a311ae9ef34da474.png114f1150b881333f12a311ae9ef34da474.pngimportcn.bupt.constant.Default;124f1150b881333f12a311ae9ef34da474.png131fa987a29c6482f53d401256f96355eb.png

ca75c07623e1b494fee67e8f316fc310.gifpublicclassChargenClient9b8a8a44dd1c74ae49c20a7cd451974e.png{14d18c02628675d0a2c816449d98bda930.png15d18c02628675d0a2c816449d98bda930.pngpublicstaticintDEFAULT_PORT=8778;1697e794c86028c5f5b5461ae5ef440a4c.png

3c6cafce68eb941a00f1998f1d3d3aa6.gif/** *//**17d18c02628675d0a2c816449d98bda930.png     *@paramargs18ecedf933ec37d714bd4c2545da43add2.png*/1997e794c86028c5f5b5461ae5ef440a4c.png

3c6cafce68eb941a00f1998f1d3d3aa6.gifpublicstaticvoidmain(String[] args)9b8a8a44dd1c74ae49c20a7cd451974e.png{20d18c02628675d0a2c816449d98bda930.png//TODO Auto-generated method stub21d18c02628675d0a2c816449d98bda930.pngif(args.length==0)2297e794c86028c5f5b5461ae5ef440a4c.png

3c6cafce68eb941a00f1998f1d3d3aa6.gif9b8a8a44dd1c74ae49c20a7cd451974e.png{23d18c02628675d0a2c816449d98bda930.png           System.out.println("please input the port");24d18c02628675d0a2c816449d98bda930.pngreturn;25ecedf933ec37d714bd4c2545da43add2.png       }26d18c02628675d0a2c816449d98bda930.png27d18c02628675d0a2c816449d98bda930.pngintport ;28d18c02628675d0a2c816449d98bda930.png29d18c02628675d0a2c816449d98bda930.png30d18c02628675d0a2c816449d98bda930.png       port=DEFAULT_PORT ;31d18c02628675d0a2c816449d98bda930.png32d18c02628675d0a2c816449d98bda930.png       SocketAddress address=newInetSocketAddress(args[0] , port) ;3397e794c86028c5f5b5461ae5ef440a4c.png

3c6cafce68eb941a00f1998f1d3d3aa6.giftry9b8a8a44dd1c74ae49c20a7cd451974e.png{34d18c02628675d0a2c816449d98bda930.png        SocketChannel client=SocketChannel.open(address) ;35d18c02628675d0a2c816449d98bda930.png        ByteBuffer buffer=ByteBuffer.allocate(74) ;36d18c02628675d0a2c816449d98bda930.png        WritableByteChannel out=Channels.newChannel(System.out) ;37d18c02628675d0a2c816449d98bda930.png38d18c02628675d0a2c816449d98bda930.pngwhile(client.read(buffer)!=-1)3997e794c86028c5f5b5461ae5ef440a4c.png

3c6cafce68eb941a00f1998f1d3d3aa6.gif9b8a8a44dd1c74ae49c20a7cd451974e.png{40d18c02628675d0a2c816449d98bda930.png            buffer.flip() ;41d18c02628675d0a2c816449d98bda930.png            out.write(buffer) ;42d18c02628675d0a2c816449d98bda930.png            buffer.clear() ;43d18c02628675d0a2c816449d98bda930.png44ecedf933ec37d714bd4c2545da43add2.png        }45d18c02628675d0a2c816449d98bda930.png46d18c02628675d0a2c816449d98bda930.png47d18c02628675d0a2c816449d98bda930.png48d18c02628675d0a2c816449d98bda930.png49d18c02628675d0a2c816449d98bda930.png50d18c02628675d0a2c816449d98bda930.png5197e794c86028c5f5b5461ae5ef440a4c.png

3c6cafce68eb941a00f1998f1d3d3aa6.gif    }catch(IOException e)9b8a8a44dd1c74ae49c20a7cd451974e.png{52d18c02628675d0a2c816449d98bda930.png//TODO Auto-generated catch block53d18c02628675d0a2c816449d98bda930.pnge.printStackTrace();54ecedf933ec37d714bd4c2545da43add2.png    }55d18c02628675d0a2c816449d98bda930.png56d18c02628675d0a2c816449d98bda930.png57d18c02628675d0a2c816449d98bda930.png58ecedf933ec37d714bd4c2545da43add2.png    }59d18c02628675d0a2c816449d98bda930.png608f1ba5b45633e9678d1db480c16cae3f.png}614f1150b881333f12a311ae9ef34da474.png

(2) 服务器端

1

4f1150b881333f12a311ae9ef34da474.pngpackagecn.bupt.channel;24f1150b881333f12a311ae9ef34da474.png34f1150b881333f12a311ae9ef34da474.pngimportjava.io.IOException;44f1150b881333f12a311ae9ef34da474.pngimportjava.net.InetSocketAddress;54f1150b881333f12a311ae9ef34da474.pngimportjava.net.ServerSocket;64f1150b881333f12a311ae9ef34da474.pngimportjava.nio.ByteBuffer;74f1150b881333f12a311ae9ef34da474.pngimportjava.nio.channels.SelectionKey;84f1150b881333f12a311ae9ef34da474.pngimportjava.nio.channels.Selector;94f1150b881333f12a311ae9ef34da474.pngimportjava.nio.channels.ServerSocketChannel;104f1150b881333f12a311ae9ef34da474.pngimportjava.nio.channels.SocketChannel;114f1150b881333f12a311ae9ef34da474.pngimportjava.util.Iterator;124f1150b881333f12a311ae9ef34da474.pngimportjava.util.Set;134f1150b881333f12a311ae9ef34da474.png141fa987a29c6482f53d401256f96355eb.png

ca75c07623e1b494fee67e8f316fc310.gifpublicclassChargenServer9b8a8a44dd1c74ae49c20a7cd451974e.png{15d18c02628675d0a2c816449d98bda930.png16d18c02628675d0a2c816449d98bda930.pngpublicstaticfinalintDEFAULT_PORT=8778;1797e794c86028c5f5b5461ae5ef440a4c.png

3c6cafce68eb941a00f1998f1d3d3aa6.gif/** *//**18d18c02628675d0a2c816449d98bda930.png     *@paramargs19ecedf933ec37d714bd4c2545da43add2.png*/2097e794c86028c5f5b5461ae5ef440a4c.png

3c6cafce68eb941a00f1998f1d3d3aa6.gifpublicstaticvoidmain(String[] args)9b8a8a44dd1c74ae49c20a7cd451974e.png{21d18c02628675d0a2c816449d98bda930.png//TODO Auto-generated method stub22d18c02628675d0a2c816449d98bda930.pngintport ;23d18c02628675d0a2c816449d98bda930.png        port=DEFAULT_PORT ;24d18c02628675d0a2c816449d98bda930.png25d18c02628675d0a2c816449d98bda930.pngbyte[] rotation=newbyte[95*2] ;26d18c02628675d0a2c816449d98bda930.pngfor(bytei=''; i

3c6cafce68eb941a00f1998f1d3d3aa6.gif9b8a8a44dd1c74ae49c20a7cd451974e.png{28d18c02628675d0a2c816449d98bda930.png            rotation[i-'']=i ;29d18c02628675d0a2c816449d98bda930.png            rotation[i+95-'']=i ;30ecedf933ec37d714bd4c2545da43add2.png        }31d18c02628675d0a2c816449d98bda930.png32d18c02628675d0a2c816449d98bda930.png        ServerSocketChannel serverChannel=null;33d18c02628675d0a2c816449d98bda930.png        Selector selector=null;34d18c02628675d0a2c816449d98bda930.png35d18c02628675d0a2c816449d98bda930.png3697e794c86028c5f5b5461ae5ef440a4c.png

3c6cafce68eb941a00f1998f1d3d3aa6.gif/** *//**37d18c02628675d0a2c816449d98bda930.png         * 先建立服务器端的通道38d18c02628675d0a2c816449d98bda930.png         *39ecedf933ec37d714bd4c2545da43add2.png*/40d18c02628675d0a2c816449d98bda930.png4197e794c86028c5f5b5461ae5ef440a4c.png

3c6cafce68eb941a00f1998f1d3d3aa6.giftry9b8a8a44dd1c74ae49c20a7cd451974e.png{42d18c02628675d0a2c816449d98bda930.png            serverChannel=ServerSocketChannel.open() ;43d18c02628675d0a2c816449d98bda930.png            ServerSocket ss=serverChannel.socket() ;44d18c02628675d0a2c816449d98bda930.png            InetSocketAddress address=newInetSocketAddress(port) ;45d18c02628675d0a2c816449d98bda930.png            ss.bind(address) ;46d18c02628675d0a2c816449d98bda930.png            serverChannel.configureBlocking(false) ;47d18c02628675d0a2c816449d98bda930.png            selector=Selector.open() ;48d18c02628675d0a2c816449d98bda930.png            serverChannel.register(selector, SelectionKey.OP_ACCEPT) ;49d18c02628675d0a2c816449d98bda930.png50d18c02628675d0a2c816449d98bda930.png51d18c02628675d0a2c816449d98bda930.png5297e794c86028c5f5b5461ae5ef440a4c.png

3c6cafce68eb941a00f1998f1d3d3aa6.gif        }catch(IOException e)9b8a8a44dd1c74ae49c20a7cd451974e.png{53d18c02628675d0a2c816449d98bda930.png//TODO Auto-generated catch block54d18c02628675d0a2c816449d98bda930.pnge.printStackTrace();55ecedf933ec37d714bd4c2545da43add2.png        }56d18c02628675d0a2c816449d98bda930.png57d18c02628675d0a2c816449d98bda930.png58d18c02628675d0a2c816449d98bda930.pngwhile(true)5997e794c86028c5f5b5461ae5ef440a4c.png

3c6cafce68eb941a00f1998f1d3d3aa6.gif9b8a8a44dd1c74ae49c20a7cd451974e.png{60d18c02628675d0a2c816449d98bda930.png6197e794c86028c5f5b5461ae5ef440a4c.png

3c6cafce68eb941a00f1998f1d3d3aa6.giftry9b8a8a44dd1c74ae49c20a7cd451974e.png{62d18c02628675d0a2c816449d98bda930.png                selector.select() ;6397e794c86028c5f5b5461ae5ef440a4c.png

3c6cafce68eb941a00f1998f1d3d3aa6.gif            }catch(IOException e)9b8a8a44dd1c74ae49c20a7cd451974e.png{64d18c02628675d0a2c816449d98bda930.png                e.printStackTrace();65ecedf933ec37d714bd4c2545da43add2.png            }66d18c02628675d0a2c816449d98bda930.png67d18c02628675d0a2c816449d98bda930.png            Set readyKeys=selector.selectedKeys() ;68d18c02628675d0a2c816449d98bda930.png            Iterator iter=readyKeys.iterator() ;69d18c02628675d0a2c816449d98bda930.pngwhile(iter.hasNext())7097e794c86028c5f5b5461ae5ef440a4c.png

3c6cafce68eb941a00f1998f1d3d3aa6.gif9b8a8a44dd1c74ae49c20a7cd451974e.png{71d18c02628675d0a2c816449d98bda930.png                SelectionKey key=(SelectionKey) iter.next() ;72d18c02628675d0a2c816449d98bda930.png                iter.remove() ;73d18c02628675d0a2c816449d98bda930.png74d18c02628675d0a2c816449d98bda930.pngif(key.isAcceptable())7597e794c86028c5f5b5461ae5ef440a4c.png

3c6cafce68eb941a00f1998f1d3d3aa6.gif9b8a8a44dd1c74ae49c20a7cd451974e.png{76d18c02628675d0a2c816449d98bda930.png                    ServerSocketChannel server=(ServerSocketChannel) key.channel() ;7797e794c86028c5f5b5461ae5ef440a4c.png

3c6cafce68eb941a00f1998f1d3d3aa6.giftry9b8a8a44dd1c74ae49c20a7cd451974e.png{78d18c02628675d0a2c816449d98bda930.png                        SocketChannel client=server.accept() ;79d18c02628675d0a2c816449d98bda930.png                        System.out.println("Accept connection from"+client) ;80d18c02628675d0a2c816449d98bda930.png                        client.configureBlocking(false) ;81d18c02628675d0a2c816449d98bda930.png                        SelectionKey key2=client.register(selector, SelectionKey.OP_WRITE) ;82d18c02628675d0a2c816449d98bda930.png                        ByteBuffer buffer=ByteBuffer.allocate(74) ;83d18c02628675d0a2c816449d98bda930.png                        buffer.put(rotation ,0,72) ;84d18c02628675d0a2c816449d98bda930.png                        buffer.put((byte)'\r') ;85d18c02628675d0a2c816449d98bda930.png                        buffer.put((byte)'\n') ;86d18c02628675d0a2c816449d98bda930.png                        buffer.flip() ;87d18c02628675d0a2c816449d98bda930.png                        key2.attach(buffer) ;88d18c02628675d0a2c816449d98bda930.png89d18c02628675d0a2c816449d98bda930.png90d18c02628675d0a2c816449d98bda930.png91d18c02628675d0a2c816449d98bda930.png9297e794c86028c5f5b5461ae5ef440a4c.png

3c6cafce68eb941a00f1998f1d3d3aa6.gif                    }catch(IOException e)9b8a8a44dd1c74ae49c20a7cd451974e.png{93d18c02628675d0a2c816449d98bda930.png//TODO Auto-generated catch block94d18c02628675d0a2c816449d98bda930.pnge.printStackTrace();95ecedf933ec37d714bd4c2545da43add2.png                    }96d18c02628675d0a2c816449d98bda930.png97d18c02628675d0a2c816449d98bda930.png98d18c02628675d0a2c816449d98bda930.png99d18c02628675d0a2c816449d98bda930.png100ecedf933ec37d714bd4c2545da43add2.png                }101d18c02628675d0a2c816449d98bda930.png102d18c02628675d0a2c816449d98bda930.pngelse103d18c02628675d0a2c816449d98bda930.pngif(key.isWritable())10497e794c86028c5f5b5461ae5ef440a4c.png

3c6cafce68eb941a00f1998f1d3d3aa6.gif9b8a8a44dd1c74ae49c20a7cd451974e.png{105d18c02628675d0a2c816449d98bda930.png10697e794c86028c5f5b5461ae5ef440a4c.png

3c6cafce68eb941a00f1998f1d3d3aa6.gif/** *//**107d18c02628675d0a2c816449d98bda930.png                         * 建立客户端通道108d18c02628675d0a2c816449d98bda930.png                         *109ecedf933ec37d714bd4c2545da43add2.png*/110d18c02628675d0a2c816449d98bda930.png                        SocketChannel client=(SocketChannel)key.channel() ;111d18c02628675d0a2c816449d98bda930.png                        ByteBuffer buffer=(ByteBuffer) key.attachment() ;112d18c02628675d0a2c816449d98bda930.pngif(!buffer.hasRemaining())11397e794c86028c5f5b5461ae5ef440a4c.png

3c6cafce68eb941a00f1998f1d3d3aa6.gif9b8a8a44dd1c74ae49c20a7cd451974e.png{114d18c02628675d0a2c816449d98bda930.png                            buffer.rewind() ;115d18c02628675d0a2c816449d98bda930.pngintfirst=buffer.get() ;116d18c02628675d0a2c816449d98bda930.png                            buffer.rewind() ;117d18c02628675d0a2c816449d98bda930.pngintposition=first-''+1;118d18c02628675d0a2c816449d98bda930.png                            buffer.put(rotation , position ,72) ;119d18c02628675d0a2c816449d98bda930.png                            buffer.put((byte)'\r') ;120d18c02628675d0a2c816449d98bda930.png                            buffer.put((byte)'\n');121d18c02628675d0a2c816449d98bda930.png                            buffer.flip() ;122ecedf933ec37d714bd4c2545da43add2.png                        }12397e794c86028c5f5b5461ae5ef440a4c.png

3c6cafce68eb941a00f1998f1d3d3aa6.giftry9b8a8a44dd1c74ae49c20a7cd451974e.png{124d18c02628675d0a2c816449d98bda930.png                            client.write(buffer) ;12597e794c86028c5f5b5461ae5ef440a4c.png

3c6cafce68eb941a00f1998f1d3d3aa6.gif                        }catch(IOException e)9b8a8a44dd1c74ae49c20a7cd451974e.png{126d18c02628675d0a2c816449d98bda930.png//TODO Auto-generated catch block127d18c02628675d0a2c816449d98bda930.pnge.printStackTrace();128ecedf933ec37d714bd4c2545da43add2.png                        }129ecedf933ec37d714bd4c2545da43add2.png                    }130d18c02628675d0a2c816449d98bda930.png131d18c02628675d0a2c816449d98bda930.png132d18c02628675d0a2c816449d98bda930.png133d18c02628675d0a2c816449d98bda930.png134d18c02628675d0a2c816449d98bda930.png135d18c02628675d0a2c816449d98bda930.png136d18c02628675d0a2c816449d98bda930.png137d18c02628675d0a2c816449d98bda930.png138d18c02628675d0a2c816449d98bda930.png                key.cancel() ;13997e794c86028c5f5b5461ae5ef440a4c.png

3c6cafce68eb941a00f1998f1d3d3aa6.giftry9b8a8a44dd1c74ae49c20a7cd451974e.png{140d18c02628675d0a2c816449d98bda930.png                    key.channel().close() ;14197e794c86028c5f5b5461ae5ef440a4c.png

3c6cafce68eb941a00f1998f1d3d3aa6.gif                }catch(IOException e)9b8a8a44dd1c74ae49c20a7cd451974e.png{142d18c02628675d0a2c816449d98bda930.png//TODO Auto-generated catch block143d18c02628675d0a2c816449d98bda930.pnge.printStackTrace();144ecedf933ec37d714bd4c2545da43add2.png                }145ecedf933ec37d714bd4c2545da43add2.png            }146d18c02628675d0a2c816449d98bda930.png147d18c02628675d0a2c816449d98bda930.png148ecedf933ec37d714bd4c2545da43add2.png        }149d18c02628675d0a2c816449d98bda930.png150d18c02628675d0a2c816449d98bda930.png151d18c02628675d0a2c816449d98bda930.png152d18c02628675d0a2c816449d98bda930.png153d18c02628675d0a2c816449d98bda930.png154d18c02628675d0a2c816449d98bda930.png155d18c02628675d0a2c816449d98bda930.png156d18c02628675d0a2c816449d98bda930.png157d18c02628675d0a2c816449d98bda930.png158ecedf933ec37d714bd4c2545da43add2.png    }159d18c02628675d0a2c816449d98bda930.png1608f1ba5b45633e9678d1db480c16cae3f.png}1614f1150b881333f12a311ae9ef34da474.png

posted on 2010-08-01 21:19 buptduming 阅读(4114) 评论(0)  编辑  收藏

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/556869.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

java mod函数的使用方法_java 数学计算的具体使用

java.lang.Math 库提供了常用的数学计算工具常量final double E 2.7182818284590452354; // 自然对数底数final double PI 3.14159265358979323846; // 圆周率final double DEGREES_TO_RADIANS 0.017453292519943295; // 角度转弧度final double RADIANS_TO_DEGREES 57.295…

java的debug模式_java第六章:debug模式介绍及大量实例练习

1.Debug模式1.1什么是Debug模式【理解】是供程序员使用的程序调试工具,它可以用于查看程序的执行流程,也可以用于追踪程序执行过程来调试程序。1.2Debug模式操作流程【应用】如何加断点选择要设置断点的代码行,在行号的区域后面单击鼠标左键即…

注解RequestMapping中的URI路径最前面到底需不需要加斜线?

注解RequestMapping中的URI路径最前面到底需不需要加斜线? 您有没有这样的困惑:在协同开发过程中,使用RequestMapping,或者是GetMapping,或者是PostMapping这类注解时,有的程序员加了斜线,有的程序员没有…

java ajax jquery分页插件_jquery ajax分页插件的简单实现

说到基于jQuery的ajax分页插件,那我们就先看看主要的代码结构:1、首先定义一个pager对象:var sjPager window.sjPager {opts: {//默认属性pageSize: 10,preText: "pre",nextText: "next",firstText: "First"…

java thrift连接池_由浅入深了解Thrift之客户端连接池化

一、问题描述在上一篇《由浅入深了解Thrift之服务模型和序列化机制》文章中,我们已经了解了thrift的基本架构和网络服务模型的优缺点。如今的互联网圈中,RPC服务化的思想如火如荼。我们又该如何将thrift服务化应用到我们的项目中哪?实现thrif…

Vue 进阶组件实战应用 -- 父子组件传值的应用实例(子父组件传值的两种触发方式)

基础的子组件和父组件通信已经搞定了,可以看此博客 父子组件传值基础应用 需求 现在需求是在一个父页面引用子组件,不只是要实现基本的父子组件传值。并且子组件给父组件传值的触发条件要在父页面触发。 目前小编采用的方式是使用ref 属性this.emit 方法…

学习Spring Boot:(一)入门

微服务 微服务其实是服务化思路的一种最佳实践方向,遵循SOA(面向服务的架构)的思路,各个企业在服务化治理上面的道路已经走得很远了,整个软件交付链上各个环节的基础设施逐渐成熟了,微服务就诞生了。 微服务…

学习Spring Boot:(二)启动原理

前言 主要了解前面的程序入口 SpringBootApplication 这个注解的结构。 正文 参考《SpringBoot揭秘 快速构建微服务体系》第三章的学习,总结下。 SpringBootApplication背后的秘密 Target(ElementType.TYPE) Retention(RetentionPolicy.RUNTIME) Documented In…

学习Spring Boot:(四)应用日志

前言 应用日志是一个系统非常重要的一部分,后来不管是开发还是线上,日志都起到至关重要的作用。这次使用的是 Logback 日志框架。 正文 Spring Boot在所有内部日志中使用Commons Logging,但是默认配置也提供了对常用日志的支持&#xff0c…

学习Spring Boot:(五)使用 devtools热部署

前言 spring-boot-devtools 是一个为开发者服务的一个模块,其中最重要的功能就是自动应用代码更改到最新的App上面去。原理是在发现代码有更改之后,重新启动应用,但是比速度比手动停止后再启动还要更快,更快指的不是节省出来的手工…

学习Spring Boot:(六) 集成Swagger2

前言 Swagger是用来描述和文档化RESTful API的一个项目。Swagger Spec是一套规范,定义了该如何去描述一个RESTful API。类似的项目还有RAML、API Blueprint。 根据Swagger Spec来描述RESTful API的文件称之为Swagger specification file,它使用JSON来表…

java的队列实现方法_Java实现队列的三种方法集合

数组实现队列//数组实现队列class queue{int[] a new int[5];int i 0;//入队操作public void in(int m) {a[i] m;}// 出队列操作 取出最前面的值 通过循环遍历把所有的数据向前一位public int out() {int index 0;int temp a[0];for(int j 0;j < i;j) {a[j] a[j 1];…

php 简转繁体,php如何实现简体繁体转换

思路&#xff1a;根据中文简体、繁体对应的数据表&#xff0c;将其整理成一个以简体字为键&#xff0c;繁体字为值的一个一维数组&#xff0c;类似下面这样的一个数组结构&#xff1a;$dataarray(侧>側,厂>廠);在线学习视频分享&#xff1a;php视频教程好了&#xff0c;根…

学习Spring Boot:(八)Mybatis使用分页插件PageHelper

首先Mybqtis可以通过SQL 的方式实现分页很简单&#xff0c;只要在查询SQL 后面加上limit #{currIndex} , #{pageSize}就可以了。 本文主要介绍使用拦截器的方式实现分页。 实现原理 拦截器实现了拦截所有查询需要分页的方法&#xff0c;并且利用获取到的分页相关参数统一在s…

学习Spring Boot:(九)统一异常处理

前言 开发的时候&#xff0c;每个controller的接口都需要进行捕捉异常的处理&#xff0c;以前有的是用切面做的&#xff0c;但是SpringMVC中就自带了ControllerAdvice &#xff0c;用来定义统一异常处理类&#xff0c;在 SpringBoot 中额外增加了 RestControllerAdvice。 使用…

php7 ast,PHP7 的抽象语法树(AST)带来的变化

什么是抽象语法树&#xff1f;抽象语法树(abstract syntax tree&#xff0c;AST)是源代码的抽象语法结构的树状表示&#xff0c;树上的每个节点都表示源代码中的一种结构&#xff0c;这所以说是抽象的&#xff0c;是因为抽象语法树并不会表示出真实语法出现的每一个细节&#x…

学习Spring Boot:(十)使用hibernate validation完成数据后端校验

前言 后台数据的校验也是开发中比较注重的一点&#xff0c;用来校验数据的正确性&#xff0c;以免一些非法的数据破坏系统&#xff0c;或者进入数据库&#xff0c;造成数据污染&#xff0c;由于数据检验可能应用到很多层面&#xff0c;所以系统对数据校验要求比较严格且追求可…

php 仿高德,仿高德路线规划滑动效果

因为项目有个界面要模仿高德地图路径规划滑动效果&#xff0c;因此写了demo&#xff0c;并简单说下分析过程。高德地图效果演示:仿高德路线规划滑动.gifdemo效果演示:高德地图规划滑动.gif一. 分析首先&#xff0c;我们可以看出这个滚动的视图应该是UIScrollView或者UIScrollVi…

学习Spring Boot:(十八)Spring Boot 中session共享

前言 前面我们将 Redis 集成到工程中来了&#xff0c;现在需要用它来做点实事了。这次为了解决分布式系统中的 session 共享的问题&#xff0c;将 session 托管到 Redis。 正文 引入依赖 除了上篇文章中引入 spring-boot-starter-data-redis&#xff0c;还需要 spring-sess…

学习Spring Boot:(十九)Shiro 中使用缓存

前言 在 shiro 中每次去拦截请求进行权限认证的时候&#xff0c;都会去数据库查询该用户的所有权限信息&#xff0c; 这个时候就是有一个问题了&#xff0c;因为用户的权限信息在短时间内是不可变的&#xff0c;每次查询出来的数据其实都是重复数据&#xff0c;没必要每次都去…