前言：

物聯網答辯終于結束了 記一下自己網絡編程的代碼 重連代碼寫了好久 try catch原來可以這么用！

學習地址：https://www.bilibili.com/video/BV1gz4y1C7RK

項目結構：

1、服務器代碼：

package Server;import Entiles.User;import Utils.JdbcUtil;import java.io.IOException;import java.net.InetSocketAddress;import java.nio.ByteBuffer;import java.nio.channels.*;import java.nio.charset.Charset;import java.text.SimpleDateFormat;import java.util.Iterator;import java.util.Scanner;import java.util.Set;public class ChatServer {    public void StratServer(int port) throws IOException {        //soket通道 客戶通道        //創建服務端通道        ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();        //非堵塞模式        serverSocketChannel.configureBlocking(false);        //創建buffer        ByteBuffer byteBuffer = ByteBuffer.allocate(1024);        //綁定端口        serverSocketChannel.bind(new InetSocketAddress(port));        //創建selector 選擇器        Selector selector = Selector.open();        //注冊通道        serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);        //輪播查詢        System.out.println("智能水表服務端(端口:"+port+")已經啟動");//        如果有就緒狀態的通道 則select方法返回1        while(true){            while (selector.select()>0){//            因為有多個通道 ，所以采用集合 獲取所有就緒的通道                //        得到所有就緒狀態的通道集合到key中                Set<SelectionKey> selectionKeys = selector.selectedKeys(); //selectedKeys所有已經就緒的key集合//        轉成集合迭代器                Iterator<SelectionKey> iterator = selectionKeys.iterator();                while(iterator.hasNext()){                    SelectionKey selectionKey = iterator.next();                    //有人來連                    if(selectionKey.isAcceptable()){                        acceptOperator(serverSocketChannel,selector);                    }                    //發過來了已經                    else if(selectionKey.isReadable()){                        readOperator(selector,selectionKey);                    }                    //返回水表數據                    else if(selectionKey.isWritable()){                        writeOperator(selector,selectionKey);                    }                    iterator.remove();                }            }        }    }    //處理服務器寫事件    private void writeOperator(Selector selector,SelectionKey selectionKey) {        try {            //有channel可寫,取出可寫的channel            SocketChannel socketChannel = (SocketChannel) selectionKey.channel();            //                    設計非阻塞            socketChannel.configureBlocking(false);            socketChannel.write(Charset.forName("UTF-8").encode("數據庫存入成功！" ));            //重新將channel注冊到選擇器上，設計為監聽            socketChannel.register(selector,SelectionKey.OP_READ);        }catch (IOException e){            e.printStackTrace();        }    }    //    處理讀事件    private void readOperator(Selector selector, SelectionKey selectionKey) throws IOException {        try {            //                    獲取就緒通道            SocketChannel socketChannel = (SocketChannel)selectionKey.channel();//                    設計buffer            ByteBuffer buffer = ByteBuffer.allocate(1024);//                    循環讀客戶端數據            int length=0;            String msg="";            if((length=socketChannel.read(buffer))>0){  //讀到buffer里面//                        切換模式                buffer.flip();                msg+=Charset.forName("UTF-8").decode(buffer);  //從buffer里面取數據 解碼            }            System.out.println(msg);            String str[]=msg.split(":");            String temp=str[1];            String str2[]=temp.split("、");            SimpleDateFormat tempDate = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");            String datetime = tempDate.format(new java.util.Date());            JdbcUtil.find(new User(str2[0],str2[1],str2[2],datetime));            //重新將channel注冊到選擇器上，設計為監聽            socketChannel.register(selector,SelectionKey.OP_WRITE);        }catch (IOException e){            selectionKey.cancel();            selectionKey.channel().close();            System.out.println("有客戶端斷連，我已主動關閉");        }                        //光廣播到其他用戶上去//                        if(msg.length()>0){//                            System.out.println(msg);//                            castOtherClient(msg,selector,socketChannel);//                        }    }        //廣播到其他客戶端//    private void castOtherClient(String msg, Selector selector, SocketChannel socketChannel) throws IOException {////        //獲取所有就緒的channel//        Set selectionKeySet = selector.keys();//        循環處理搜索就緒的channel//        for (SelectionKey selectionKey : selectionKeySet){            獲取每一個channel//            Channel tarChannel = selectionKey.channel();//            不給自己發信息//            if(tarChannel instanceof SocketChannel && tarChannel!=socketChannel){//                ((SocketChannel)tarChannel).write(Charset.forName("UTF-8").encode(msg)); //傳輸數據是編碼，發送數據是解碼//            }//        }//    }    //處理接收狀態的通道    private void acceptOperator(ServerSocketChannel serverSocketChannel, Selector selector)  {        try {            //                    獲取連接            SocketChannel socketChannel = serverSocketChannel.accept();//                    設計非阻塞            socketChannel.configureBlocking(false);//                     注冊通道            socketChannel.register(selector,SelectionKey.OP_READ);            //回復客戶端消息            socketChannel.write(Charset.forName("UTF-8").encode("您已成功連接到服務器！"));        }catch (IOException e){            e.printStackTrace();        }    }    public static void main(String[] args) throws IOException {        new ChatServer().StratServer(7890);    }}

解釋：
其中我的readOperator函數是負責讀取客戶端傳來的信息。Nio編程核心是通道和選擇器，選擇器通過不斷輪詢，執行對應的函數。
此項目我加入了數據庫，如果收到客戶端信息，存入數據庫。

2、客戶端代碼

2.1、負責發送的主客戶端

package Client;import java.io.IOException;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.nio.charset.Charset;import java.util.Scanner;public class ChatClient {    public void startClient(String name ) throws IOException, InterruptedException {        //        創建通道 綁定主機和端口        SocketChannel socketChannel = null;            socketChannel = SocketChannel.open(new InetSocketAddress(                    "127.0.0.1", 7890));        //接受服務端響應的數據        Selector selector = Selector.open();        socketChannel.configureBlocking(false);        socketChannel.register(selector, SelectionKey.OP_READ);        //創建線程        new Thread(new ClientThread(selector)).start();//負責拿到服務器端數據        //向服務端發送數據        System.out.println("請輸入抄水表編號、抄水量、抄表員(抄水時間自動生成）(請在1min中內完成)");        Scanner scanner = new Scanner(System.in);        while (scanner.hasNextLine()){            ByteBuffer byteBuffer = ByteBuffer.allocate(1024);            String str = scanner.nextLine(); //鍵盤獲取輸入的內容            if(str.length()>0){               socketChannel.write(Charset.forName("UTF-8").encode("客戶端："+name+":"+str+"（已加載數據庫）"));                //System.out.println(Charset.forName("UTF-8").encode(name+":"+str));            }        //設計非堵塞模式        socketChannel.configureBlocking(false);        //設計buffer    }    }    public static void main(String[] args) throws IOException, InterruptedException {        new ChatClient().startClient("gx");    }}

2.2、負責接收服務器信息的客戶端線程

package Client;import java.io.IOException;import java.net.ConnectException;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.nio.charset.Charset;import java.util.Iterator;import java.util.Set;public class ClientThread implements Runnable{    private Selector selector;    ClientThread(Selector selector){        this.selector=selector;    }    @Override    public void run() {//        while(true){            for(;;){                try {                    int length=selector.select();                    if(length ==0){                        continue;                    }                    //        得到所有就緒狀態的通道集合到key中                    Set<SelectionKey> selectionKeys = selector.selectedKeys(); //selectedKeys所有已經就緒的key集合                    //        轉成集合迭代器                    Iterator<SelectionKey> iterator = selectionKeys.iterator();                    while(iterator.hasNext()){                        SelectionKey selectionKey = iterator.next();                        if(selectionKey.isReadable()){                            readOperator(selector,selectionKey);                        }                        iterator.remove();                    }                } catch (IOException | InterruptedException e) {                    e.printStackTrace();                }            }        }    //    處理接收服務器信息事件    private void readOperator(Selector selector, SelectionKey selectionKey) throws InterruptedException {        try {            //                    獲取就緒通道            SocketChannel socketChannel = (SocketChannel)selectionKey.channel();//                    設計buffer            ByteBuffer buffer = ByteBuffer.allocate(1024);//                    循環讀客戶端數據            int length=0;            String msg="";            if((length=socketChannel.read(buffer))>0){  //讀到buffer里面//                        切換模式                buffer.flip();                msg+= Charset.forName("UTF-8").decode(buffer);  //從buffer里面取數據 解碼            }            System.out.println(msg);            //重新將channel注冊到選擇器上，設計為監聽            socketChannel.register(selector,SelectionKey.OP_READ);        }catch (IOException e){            selectionKey.cancel();            System.out.println("服務器中斷 開始準備重連");            while (true){                try {                    new ChatClient().startClient("gx");                } catch (IOException ioException) {                    System.out.println("正在重連（5s） ");                    //ioException.printStackTrace();                    Thread.sleep(5000);                    continue;                }            }        }    }}

3、關鍵重連代碼解釋

1 重連代碼解釋

如果服務器突然關閉，如果在這里不try catch異常，而是向上拋出的話，隨著服務器異常關閉，客戶端也掛了，而且不會重連。
所以我們需要捕獲這個異常，并且開始不斷重連。
我寫了一個死循環，不斷連接，如果連不上他還是會報錯，所以連不上的錯也要捕獲異常，不然程序就報錯結束了，所以捕獲連接沒上的話，continue重新執行while循環，直到連接上服務器。

2 如果客戶端關閉 那么服務器也要主動關閉他

4 數據庫代碼及實體類：

如果還想實現數據庫方面代碼，私我