重点注意:有说明的地方。
package nio.chat;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.util.Iterator;
public class Server extends Thread {
private Selector selector;
private ServerSocketChannel serverChannel;
private ByteBuffer wBuffer=ByteBuffer.allocate(1024); //共享 buffer 在多 链接时候会产生错误
private ByteBuffer rBuffer=ByteBuffer.allocate(1024);
public Server(ServerSocketChannel sc) throws Exception {
serverChannel=sc;
selector = Selector.open();
serverChannel.register(selector, SelectionKey.OP_ACCEPT);
}
public void run(){
while (true){
try{
if (selector.select(1000) == 0){
System.out.print(".");
continue;
}
Iterator<SelectionKey> ki = selector.selectedKeys().iterator();
while (ki.hasNext()){
SelectionKey key = ki.next();
if (key.isAcceptable()){
handleAccept(key);
}else
if (key.isReadable()){
handleRead(key);
}else
if (key.isWritable()){
handleWrite(key);
}
ki.remove();
}
}catch(Exception e){
e.printStackTrace();
}
}
}
private void handleWrite(SelectionKey key){
SocketChannel cc = (SocketChannel) key.channel();
ByteBuffer buf= (ByteBuffer)(key.attachment());
//byte []b={5,'H','E','L','L','O'};
//buf=ByteBuffer.wrap(b);
try{
buf.flip();
cc.write(buf);
if(buf.hasRemaining()==false){
// key.interestOps(SelectionKey.OP_READ);
byte []b=buf.array();
System.out.println("---->response finished!,msg="+new String(b,1,b[0],"utf-8"));
buf.clear();
SelectionKey s=cc.register(selector, SelectionKey.OP_READ, rBuffer);
System.out.println("---toRead,selectionKey="+s);
}
}catch(Exception e){
try{
cc.close();
}catch(Exception e1){};
e.printStackTrace();
System.out.println("---closed!---");
}
}
private void handleRead(SelectionKey key){
SocketChannel cc = (SocketChannel) key.channel();
ByteBuffer buf= (ByteBuffer)(key.attachment());
try{
int read=cc.read(buf);
byte []bs=buf.array();
int pos=buf.position();
if(pos>0 && pos==(int)bs[0]+1){
String msg=new String(bs,1,bs[0],"utf-8");
System.out.println("---->Recv:"+msg);
buf.clear();
String msg1="收到"+(pos-1)+"bytes,content("+msg+")";
bs=msg1.getBytes("utf-8");
byte []bl=new byte[bs.length+1];
bl[0]=(byte)bs.length;
System.arraycopy(bs, 0, bl, 1, bs.length);
wBuffer.put(bl);
//key.interestOps(SelectionKey.OP_WRITE);
SelectionKey s=cc.register(selector, SelectionKey.OP_WRITE, wBuffer);
System.out.println("---toWrite, selectionKey="+s);
}
if(read==-1){
System.out.println("--遇到结束--");
}
}catch(Exception e){
try{
cc.close();
}catch(Exception e1){};
e.printStackTrace();
System.out.println("---closed!---");
}
}
private void handleAccept(SelectionKey key) {
try{
SocketChannel cc = ((ServerSocketChannel) key.channel()).accept();
cc.configureBlocking(false);
SelectionKey s=cc.register(selector, SelectionKey.OP_READ, rBuffer);
System.out.println("---toRead, selectionKey="+s);
//key.interestOps(SelectionKey.OP_READ);
System.out.println("--Connect from "+cc.getRemoteAddress());
}catch(Exception e){
e.printStackTrace();
}
}
public static void main(String []args) throws Exception {
ServerSocketChannel serverChannel = ServerSocketChannel.open();
serverChannel.socket().bind(new InetSocketAddress(Client.port));
serverChannel.configureBlocking(false);
Server sc=new Server(serverChannel);
sc.start();
}
}
package nio.chat;
import java.io.InputStreamReader;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.SocketChannel;
import java.util.Iterator;
public class Client extends Thread{
private Selector selector;
private SocketChannel channel;
private BufferedReader br = null;
private ByteBuffer readBuffer=ByteBuffer.allocate(1024);
public Client(SocketChannel c) throws Exception {
this.channel=c;
selector=Selector.open();
channel.register(selector, SelectionKey.OP_WRITE|SelectionKey.OP_READ,null);
}
public void run() {
SelectionKey key;
boolean ced=false;
int loop=0;
while(true){
try{
if(channel.finishConnect() && ced==false){
ced=true;
}
if(ced==false){
continue;
}
int is=selector.select(); //先获取就绪数,如不调用本方法, 这 selectedKeys() 得到不就绪的 SelectionKey
if(is==0){
continue;
}
Iterator<SelectionKey> ks = selector.selectedKeys().iterator();
while (ks.hasNext()){
key = ks.next();
if (key.isWritable() ){
send();
}
if(key.isReadable()){
read();
}
ks.remove(); //从 selector 删除, 如不删除,会导致下次 selectedKeys() 无法加入就绪的 SelectionKey
}
loop++;
}catch(Exception e){
e.printStackTrace();
break;
}
}
System.out.println("---end of chat-----");
try{
channel.close();
}catch(Exception e){
e.printStackTrace();
}
}
private void read() throws Exception {
ByteBuffer bu=ByteBuffer.allocate(20);
int read=channel.read(bu);
for(int i=0;i<read;i++){
readBuffer.put(bu.get(i));
int len=readBuffer.get(0);
if(len==readBuffer.position()-1){
byte []bs=readBuffer.array();
System.out.println("\r\n--收到:"+new String(bs,1,len,"utf-8"));
readBuffer.clear();
}
}
}
static int nLine=0;
static long lastTime=0;
private void send(){
nLine++;
if(System.currentTimeMillis()-lastTime<10*1000){
return;
}
lastTime=System.currentTimeMillis();
try{
String line=String.valueOf(nLine);
byte []bs=line.getBytes("utf-8");
int len=bs.length;
byte []b={(byte)len};
ByteBuffer b1=ByteBuffer.wrap(b);
ByteBuffer b2=ByteBuffer.wrap(bs);
while(b1.hasRemaining()){
channel.write(b1);
}
while(b2.hasRemaining()){
channel.write(b2);
}
System.out.println("\t 发送完毕!,msg="+line);
}catch(Exception e){
e.printStackTrace();
System.exit(0);
}
}
public static String host="127.0.0.1";
public static int port=8001;
public static void main(String []args) throws Exception {
SocketChannel clntChan = SocketChannel.open();
clntChan.configureBlocking(false);
Client dealer=new Client(clntChan);
clntChan.connect(new InetSocketAddress(host, port));
dealer.start();
}
}
相关推荐
1-第一天-魔乐java基础视频学习笔记.docx:这部分内容可能包括Java语言的简介,安装Java开发环境(JDK),以及编写第一个"Hello, World!"程序。此外,还可能涉及基本的编程概念,如变量、数据类型、运算符和控制流程...
【李兴华java word版全部笔记】是一份详尽的Java学习资料集合,由知名教师李兴华精心编撰而成。这份文档集旨在为Java初学者及进阶者提供全面、系统的学习指导,覆盖了Java语言的基础到高级知识点,帮助读者深入理解...
涉及到NIO(非阻塞I/O),Netty利用Java NIO库实现了高效的网络通信。NIO的核心概念有Selector(选择器)和Buffer(缓冲区)。Selector用于监听多个Channel的事件,而Buffer则用于高效地读写数据。 通过这个简单的...
Java IO(Input/Output)是Java平台中用于处理数据输入和输出的核心API。在Java中,IO操作通常...同时,Java NIO(New Input/Output)提供了更高级的特性,如非阻塞I/O和通道,对于高性能的IO操作,可以考虑使用NIO。
内容概要:本文档《数据结构》(02331)第一章主要介绍数据结构的基础概念,涵盖数据与数据元素的定义及其特性,详细阐述了数据结构的三大要素:逻辑结构、存储结构和数据运算。逻辑结构分为线性结构(如线性表、栈、队列)、树形结构(涉及根节点、父节点、子节点等术语)和其他结构。存储结构对比了顺序存储和链式存储的特点,包括访问方式、插入删除操作的时间复杂度以及空间分配方式,并介绍了索引存储和散列存储的概念。最后讲解了抽象数据类型(ADT)的定义及其组成部分,并探讨了算法分析中的时间复杂度计算方法。 适合人群:计算机相关专业学生或初学者,对数据结构有一定兴趣并希望系统学习其基础知识的人群。 使用场景及目标:①理解数据结构的基本概念,掌握逻辑结构和存储结构的区别与联系;②熟悉不同存储方式的特点及应用场景;③学会分析简单算法的时间复杂度,为后续深入学习打下坚实基础。 阅读建议:本章节内容较为理论化,建议结合实际案例进行理解,尤其是对于逻辑结构和存储结构的理解要深入到具体的应用场景中,同时可以尝试编写一些简单的程序来加深对抽象数据类型的认识。
内容概要:本文详细介绍了施耐德M580系列PLC的存储结构、系统硬件架构、上电写入程序及CPU冗余特性。在存储结构方面,涵盖拓扑寻址、Device DDT远程寻址以及寄存器寻址三种方式,详细解释了不同类型的寻址方法及其应用场景。系统硬件架构部分,阐述了最小系统的构建要素,包括CPU、机架和模块的选择与配置,并介绍了常见的系统拓扑结构,如简单的机架间拓扑和远程子站以太网菊花链等。上电写入程序环节,说明了通过USB和以太网两种接口进行程序下载的具体步骤,特别是针对初次下载时IP地址的设置方法。最后,CPU冗余部分重点描述了热备功能的实现机制,包括IP通讯地址配置和热备拓扑结构。 适合人群:从事工业自动化领域工作的技术人员,特别是对PLC编程及系统集成有一定了解的工程师。 使用场景及目标:①帮助工程师理解施耐德M580系列PLC的寻址机制,以便更好地进行模块配置和编程;②指导工程师完成最小系统的搭建,优化系统拓扑结构的设计;③提供详细的上电写入程序指南,确保程序下载顺利进行;④解释CPU冗余的实现方式,提高系统的稳定性和可靠性。 其他说明:文中还涉及一些特殊模块的功能介绍,如定时器事件和Modbus串口通讯模块,这些内容有助于用户深入了解M580系列PLC的高级应用。此外,附录部分提供了远程子站和热备冗余系统的实物图片,便于用户直观理解相关概念。
某型自动垂直提升仓储系统方案论证及关键零部件的设计.zip
2135D3F1EFA99CB590678658F575DB23.pdf#page=1&view=fitH
可以搜索文本内的内容,指定目录,指定文件格式,匹配大小写等
Windows 平台 Android Studio 下载与安装指南.zip
Android Studio Meerkat 2024.3.1 Patch 1(android-studio-2024.3.1.14-windows.zip)适用于Windows系统,文件使用360压缩软件分割成两个压缩包,必须一起下载使用: part1: https://download.csdn.net/download/weixin_43800734/90557033 part2: https://download.csdn.net/download/weixin_43800734/90557035
国网台区终端最新规范
国网台区终端最新规范
1.【锂电池剩余寿命预测】Transformer-GRU锂电池剩余寿命预测(Matlab完整源码和数据) 2.数据集:NASA数据集,已经处理好,B0005电池训练、B0006测试; 3.环境准备:Matlab2023b,可读性强; 4.模型描述:Transformer-GRU在各种各样的问题上表现非常出色,现在被广泛使用。 5.领域描述:近年来,随着锂离子电池的能量密度、功率密度逐渐提升,其安全性能与剩余使用寿命预测变得愈发重要。本代码实现了Transformer-GRU在该领域的应用。 6.作者介绍:机器学习之心,博客专家认证,机器学习领域创作者,2023博客之星TOP50,主做机器学习和深度学习时序、回归、分类、聚类和降维等程序设计和案例分析,文章底部有博主联系方式。从事Matlab、Python算法仿真工作8年,更多仿真源码、数据集定制私信。
Android项目原生java语言课程设计,包含LW+ppt
大学生入门前端-五子棋vue项目
这是一个完整的端到端解决方案,用于分析和预测阿联酋(UAE)地区的二手车价格。数据集包含 10,000 条二手车信息,覆盖了迪拜、阿布扎比和沙迦等城市,并提供了精确的地理位置数据。此外,项目还包括一个基于 Dash 构建的 Web 应用程序代码和一个训练好的 XGBoost 模型,帮助用户探索区域市场趋势、预测车价以及可视化地理空间洞察。 数据集内容 项目文件以压缩 ZIP 归档形式提供,包含以下内容: 数据文件: data/uae_used_cars_10k.csv:包含 10,000 条二手车记录的数据集,涵盖车辆品牌、型号、年份、里程数、发动机缸数、价格、变速箱类型、燃料类型、颜色、描述以及销售地点(如迪拜、阿布扎比、沙迦)。 模型文件: models/stacking_model.pkl:训练好的 XGBoost 模型,用于预测二手车价格。 models/scaler.pkl:用于数据预处理的缩放器。 models.py:模型相关功能的实现。 train_model.py:训练模型的脚本。 Web 应用程序文件: app.py:Dash 应用程序的主文件。 callback
资源内项目源码是来自个人的毕业设计,代码都测试ok,包含源码、数据集、可视化页面和部署说明,可产生核心指标曲线图、混淆矩阵、F1分数曲线、精确率-召回率曲线、验证集预测结果、标签分布图。都是运行成功后才上传资源,毕设答辩评审绝对信服的保底85分以上,放心下载使用,拿来就能用。包含源码、数据集、可视化页面和部署说明一站式服务,拿来就能用的绝对好资源!!! 项目备注 1、该资源内项目代码都经过测试运行成功,功能ok的情况下才上传的,请放心下载使用! 2、本项目适合计算机相关专业(如计科、人工智能、通信工程、自动化、电子信息等)的在校学生、老师或者企业员工下载学习,也适合小白学习进阶,当然也可作为毕设项目、课程设计、大作业、项目初期立项演示等。 3、如果基础还行,也可在此代码基础上进行修改,以实现其他功能,也可用于毕设、课设、作业等。 下载后请首先打开README.txt文件,仅供学习参考, 切勿用于商业用途。
资源内项目源码是来自个人的毕业设计,代码都测试ok,包含源码、数据集、可视化页面和部署说明,可产生核心指标曲线图、混淆矩阵、F1分数曲线、精确率-召回率曲线、验证集预测结果、标签分布图。都是运行成功后才上传资源,毕设答辩评审绝对信服的保底85分以上,放心下载使用,拿来就能用。包含源码、数据集、可视化页面和部署说明一站式服务,拿来就能用的绝对好资源!!! 项目备注 1、该资源内项目代码都经过测试运行成功,功能ok的情况下才上传的,请放心下载使用! 2、本项目适合计算机相关专业(如计科、人工智能、通信工程、自动化、电子信息等)的在校学生、老师或者企业员工下载学习,也适合小白学习进阶,当然也可作为毕设项目、课程设计、大作业、项目初期立项演示等。 3、如果基础还行,也可在此代码基础上进行修改,以实现其他功能,也可用于毕设、课设、作业等。 下载后请首先打开README.txt文件,仅供学习参考, 切勿用于商业用途。
此为代码审查工具 可查 文件数,字节数,总行数,代码行数,注释行数,空白行数,注释率等