专注于 JetBrains IDEA 全家桶,永久激活,教程
持续更新 PyCharm,IDEA,WebStorm,PhpStorm,DataGrip,RubyMine,CLion,AppCode 永久激活教程

通俗的nio socket Selector解释

**java选择器(Selector)是用来干嘛的?**不要贴api的,上面的写的我看不懂希望大家能给我个通熟易懂的例子,还有ServerSocketChannel这个类,java.nio这个包里的东西,我看api也不懂

在用nio通讯的过程我用以下情景模拟:

1。 学校(ServerSocketChannel)

2。 学校教务处(Selector)

3。 老师 (ServerSocket )

4。 学生 (SocketChannel)

5。 员工号/学生号(SelectionKey)

学校:相当于我们的网络应用程序,一旦学校启动,学校就不停止,不断运行,直到学期结束;

要启动学校就要:

ServerSocketChannel ssc= ServerSocketChannel.open();//新建NIO通道

ssc.configureBlocking( false );//使通道为非阻塞

老师: 相当于服务端的Socket,一个老师对应多个学生,多个学生向老师请教,老师会一一做出回答。而学校要正常运营当然当不了老师,所以在开学之前,必须先聘请专业的老师来任教

ServerSocket ss = ssc.socket();//创建基于NIO通道的socket连接

//新建socket通道的端口

ss.bind(new InetSocketAddress(“127.0.0.1”,SERVERPORT));

学校教务处: 老师都有了,但是需要有部门对老师和学生做统一的管理, 如果你去一个学校找一个人,实在是找不到,你可以告诉教务处,那个人是学生还是老师,是老师的话员工编号老师姓名的多少,是学生的话学号和姓名是多少,教务处就会找到告诉你他在哪里。

//将NIO通道选绑定到择器,当然绑定后分配的主键为skey

SelectionKey skey = ssc.register( selector, SelectionKey.OP_ACCEPT );

ssc注册了选择器后,其下的老师ServerSocket就也入了员工册了。所以老师的编号就是skey

学生: 学校、老师、教务处都有了,现在就可以招生了!

如果有学生来报名:

while(true){//除非学期结束,否则一直等待学生

int num = selector.select();//获取通道内是否有选择器的关心事件, 意思是有多少学生报告

if(num<1){continue; }

Set selectedKeys = selector.selectedKeys();//获取通道内关心事件的集合 ,这里的集合就是老师和学生的编号集合,如果key是学生的,那就是老学生来问问题,如果key是老师的,那就是招生办的老师带着一个新生来注册

Iterator it = selectedKeys.iterator();

while (it.hasNext()) {//遍历每个key (学生key和老师key)

…….

}

…..

}

既然有学生来报告,那有两种可能,一种是招生老师带着新生来注册的,一种是老生来问问题的。

上面的while (it.hasNext()) 体可以这样写:

while (it.hasNext()) {//遍历每个事件

try{

SelectionKey key = (SelectionKey)it.next(); //先得到这个学生的编号key

//判断是新生报道还是老生问问题

if ((key.readyOps() & SelectionKey.OP_ACCEPT)

== SelectionKey.OP_ACCEPT) {

//这是招生老师的Key说明是新生注册,先找到招生老师,再由招生老师找到新生,就可以给新生注册学号了

ServerSocketChannel serverChanel = (ServerSocketChannel)key.channel(); //通过key把学校和老师找到了

//从serverSocketChannel中创建出与客户端的连接socketChannel 有了老师才有学生,不可能我教计算机的,来一个想学李小龙的都让他报名

SocketChannel sc = serverChanel.accept(); //学生报名成功

sc.configureBlocking( false );

// 把新连接注册到选择器,新生被接收后给注册个新学号

SelectionKey newKey = sc.register( selector,

SelectionKey.OP_READ ); //注册学号成功,并分配学生的权限

it.remove(); //新生注册任务完成了,呵呵

System.out.println( “Got connection from “+sc );

}else

//读客户端数据的事件,此时有客户端发数据过来,客户端事件 这是老学生来问问题了。

if((key.readyOps() & SelectionKey.OP_READ)== SelectionKey.OP_READ){

// 读取数据 ,接受学生的问题

SocketChannel sc = (SocketChannel)key.channel(); //通过学号知道是谁问的问题

//下面接受问题

int bytesEchoed = 0;

while((bytesEchoed = sc.read(echoBuffer))> 0){

System.out.println(“bytesEchoed:”+bytesEchoed);

}

echoBuffer.flip();

System.out.println(“limet:”+echoBuffer.limit());

byte [] content = new byte[echoBuffer.limit()];

echoBuffer.get(content);

String result=new String(content);

doPost(result,sc); //相应老师会去做回答的,细节自己去写吧

echoBuffer.clear();

it.remove(); //任务完成,记得上面也是一样,要remove掉,否则下一次又来一次任务,就死循环了

}

}catch(Exception e){}

}

}

ssc.register( selector, SelectionKey.OP_ACCEPT );

这个方法的第二个参数是什么意思呀?还有这个SelectionKey.OP_READ

api这样说:用于套接字接受操作的操作集位。

ssc.register( selector, SelectionKey.OP_ACCEPT );

这个方法是把ssc注册绑定到选择器selector 这样下次你想找ssc或者判断一个对象是不是ssc就可以通过selector来查找,查找是通过判断ssc的key得到的。

至于第二个参数SelectionKey.OP_ACCEPT 你可以理解成ssc的key类型或者操作权限

如果 ssc是学校老师,那么绑定成功后 老师就拥有了OP_ACCEPT的权限或者说他的key类型是SelectionKey.OP_ACCEPT

Accept是接受的意思,这是不是很像socket编程里的 accept()方法呢? 是的,没错,我们正是通过这个参数给了老师招生和带学生来注册的权限。

而学生呢?

他拥有的权限为SelectionKey.OP_READ 表示有收发读取消息的权限,即问问题的权限,因此他不能帮别的学生注册。

所以你回到上面仔细看看while结构体里面做了判断如下:

if ((key.readyOps() & SelectionKey.OP_ACCEPT) == SelectionKey.OP_ACCEPT) {…} 很明显,拥有Accept权限的人只可能是老师,那老师有什么事会找教务处? 那肯定就是他是招生办的,招到一个学生来报名来注册了。

然后,马上给这个新连上来的客户端分配了一个key

SelectionKey newKey = sc.register( selector,

SelectionKey.OP_READ ); 看,这里只给他OP_READ,而不是Accept哦

另一个if

else

if((key.readyOps() & SelectionKey.OP_READ)== SelectionKey.OP_READ){

//很明显,这是这学生,因为所有带OP_READ的人都是前面由招生办老师带过来注册过的。

文章永久链接:https://tech.souyunku.com/29988

未经允许不得转载:搜云库技术团队 » 通俗的nio socket Selector解释

JetBrains 全家桶,激活、破解、教程

提供 JetBrains 全家桶激活码、注册码、破解补丁下载及详细激活教程,支持 IntelliJ IDEA、PyCharm、WebStorm 等工具的永久激活。无论是破解教程,还是最新激活码,均可免费获得,帮助开发者解决常见激活问题,确保轻松破解并快速使用 JetBrains 软件。获取免费的破解补丁和激活码,快速解决激活难题,全面覆盖 2024/2025 版本!

联系我们联系我们