2. 程式人生 > >java NIO服務端和客戶端程式碼實現

java NIO服務端和客戶端程式碼實現

阿新 • • 發佈：2019-02-16
  1. package cn.nio; 
  2. import java.io.IOException; 
  3. import java.net.InetSocketAddress; 
  4. import java.nio.ByteBuffer; 
  5. import java.nio.channels.SelectionKey; 
  6. import java.nio.channels.Selector; 
  7. import java.nio.channels.ServerSocketChannel; 
  8. import java.nio.channels.SocketChannel; 
  9. import java.util.Iterator; 
  10. /**
  11. * NIO服務端
  12. * @author 小路
  13. */
  14. public class NIOServer { 
  15. //通道管理器
  16. private Selector selector; 
  17. /**
  18.      * 獲得一個ServerSocket通道，並對該通道做一些初始化的工作
  19.      * @param port  繫結的埠號
  20.      * @throws IOException
  21.      */
  22. public void initServer(int port) throws IOException { 
  23. // 獲得一個ServerSocket通道
  24.         ServerSocketChannel serverChannel = ServerSocketChannel.open(); 
  25. // 設定通道為非阻塞
  26.         serverChannel.configureBlocking(false); 
  27. // 將該通道對應的ServerSocket繫結到port埠
  28.         serverChannel.socket().bind(new InetSocketAddress(port)); 
  29. // 獲得一個通道管理器
  30. this.selector = Selector.open(); 
  31. //將通道管理器和該通道繫結，併為該通道註冊SelectionKey.OP_ACCEPT事件,註冊該事件後，
  32. //當該事件到達時，selector.select()會返回，如果該事件沒到達selector.select()會一直阻塞。
  33.         serverChannel.register(selector, SelectionKey.OP_ACCEPT); 
  34.     } 
  35. /**
  36.      * 採用輪詢的方式監聽selector上是否有需要處理的事件，如果有，則進行處理
  37.      * @throws IOException
  38.      */
  39. @SuppressWarnings("unchecked") 
  40. public void listen() throws IOException { 
  41.         System.out.println("服務端啟動成功！"); 
  42. // 輪詢訪問selector
  43. while (true) { 
  44. //當註冊的事件到達時，方法返回；否則,該方法會一直阻塞
  45.             selector.select(); 
  46. // 獲得selector中選中的項的迭代器，選中的項為註冊的事件
  47.             Iterator ite = this.selector.selectedKeys().iterator(); 
  48. while (ite.hasNext()) { 
  49.                 SelectionKey key = (SelectionKey) ite.next(); 
  50. // 刪除已選的key,以防重複處理
  51.                 ite.remove(); 
  52. // 客戶端請求連線事件
  53. if (key.isAcceptable()) { 
  54.                     ServerSocketChannel server = (ServerSocketChannel) key 
  55.                             .channel(); 
  56. // 獲得和客戶端連線的通道
  57.                     SocketChannel channel = server.accept(); 
  58. // 設定成非阻塞
  59.                     channel.configureBlocking(false); 
  60. //在這裡可以給客戶端傳送資訊哦
  61.                     channel.write(ByteBuffer.wrap(new String("向客戶端傳送了一條資訊").getBytes())); 
  62. //在和客戶端連線成功之後，為了可以接收到客戶端的資訊，需要給通道設定讀的許可權。
  63.                     channel.register(this.selector, SelectionKey.OP_READ); 
  64. // 獲得了可讀的事件
  65.                 } else if (key.isReadable()) { 
  66.                         read(key); 
  67.                 } 
  68.             } 
  69.         } 
  70.     } 
  71. /**
  72.      * 處理讀取客戶端發來的資訊 的事件
  73.      * @param key
  74.      * @throws IOException
  75.      */
  76. public void read(SelectionKey key) throws IOException{ 
  77. // 伺服器可讀取訊息:得到事件發生的Socket通道
  78.         SocketChannel channel = (SocketChannel) key.channel(); 
  79. // 建立讀取的緩衝區
  80.         ByteBuffer buffer = ByteBuffer.allocate(10); 
  81.         channel.read(buffer); 
  82. byte[] data = buffer.array(); 
  83.         String msg = new String(data).trim(); 
  84.         System.out.println("服務端收到資訊："+msg); 
  85.         ByteBuffer outBuffer = ByteBuffer.wrap(msg.getBytes()); 
  86.         channel.write(outBuffer);// 將訊息回送給客戶端
  87.     } 
  88. /**
  89.      * 啟動服務端測試
  90.      * @throws IOException
  91.      */
  92. public static void main(String[] args) throws IOException { 
  93.         NIOServer server = new NIOServer(); 
  94.         server.initServer(8000); 
  95.         server.listen(); 
  96.     } 
  97. } 

相關推薦

java NIO服務端和客戶端程式碼實現

package cn.nio;  import java.io.IOException;  import java.net.InetSocketAddress;  import java.nio.ByteBuffer;  import java.nio.channels.SelectionKey;  impo

java socket網路程式設計例項程式碼（含服務端和客戶端）

本程式碼為java socket網路程式設計例項程式碼，包括客戶端和服務端，實現客戶端傳送訊息，服務端接收並反饋訊息。 server.java為服務端程式碼。 client.java為客戶端程式碼。 服務端程式碼server.java： package socket;

Java review--NIO例項:實現服務端和客戶端的簡單通訊

客戶端程式碼： package nio; import java.io.IOException; import java.net.InetSocketAddress; import java.net.ServerSocket; import java.nio.Byte

Java網絡編程【Socket服務端和客戶端】

rgs .net aio highlight 如果 org author oid try Socket 編程大家都不陌生，Java 學習中必學的部分，也是 Java網絡編程核心內容之一。Java 網絡編程又包括 TCP、UDP，URL 等模塊。TCP 對應 Socket

java 整合 cas系統 服務端和客戶端配置

http://blog.csdn.net/yunye114105/article/details/7997041 參考： http://blog.csdn.net/diyagea/article/details/50638737 (配置SSL協議)http://www.cnblogs.c

JAVA中Socket服務端和客戶端網路通訊簡單案例

一. 簡單介紹下Socket的用途： 1.Java最初是作為網路程式語言出現的，其對網路提供了高度的支援，使得客戶端和伺服器的溝通變成了現實，而在網路程式設計中，使用最多的就是Socket。像大家熟悉的QQ、MSN都使用了Socket相關的技術 2.IP地址+埠號組成了所

基於Socket的服務端多執行緒模式——服務端和客戶端程式碼

本文程式碼來源於《實戰java高併發程式設計》葛一鳴 郭超 著 學習這本書的過程中，感覺這一部分比較重要，自己做下總結，也希望能給大家提供些幫助。       本程式碼模擬簡單的Echo伺服器，對於Echo伺服器，他會讀取客戶端的一個輸入，並將這個輸入原

用axis生成webservice服務端和客戶端程式碼

最近，接手了公司java webservice部分的開發，攢了一些經驗，為了避免後續把它丟到太空去了，現抽時間把過程記錄下來。 1、webservice服務端 1)新建web project 2)新建webservice  3)選擇對應的wsdl檔案直接生成服務端程式碼

Linux c實現一個tcp文件服務器和客戶端

repr snippets 功能 stderr strcpy fprintf inet_addr 編寫 create 總體需求：編寫tcp文件服務器和客戶端。客戶端可以上傳和下載文件。 ===========================================

python3實現TCP協議的簡單服務器和客戶端

由於 轉載 while encoding ont ans 令行 cti 數據 利用python3來實現TCP協議，和UDP類似。UDP應用於及時通信，而TCP協議用來傳送文件、命令等操作，因為這些數據不允許丟失，否則會造成文件錯誤或命令混亂。下面代碼就是模擬客戶端通過命令行

python3實現UDP協議的簡單服務器和客戶端

開始 turn lose () rec 交流 cnblogs 無連接 簡單的 利用python中的socket模塊中的來實現UDP協議，這裏寫一個簡單的服務器和客戶端。為了說明網絡編程中UDP的應用，這裏就不寫圖形化了，在兩臺電腦上分別打開UDP的客戶端和服務端就可以了。

CnetOS 6.6 rsync 的服務端和客戶端配置

rsync rsync 的服務端和客戶端配 linux centos 6.6 CentOS 6.6 rsync 的服務端和客戶端配置基本信息系統版本主機名IP地址角色CentOS 6.6backup10.0.0.10rsync服務端CentOS 6.6lamp0110.0.0.8rsync

tcp 服務端和客戶端程序設計

cti ida ons uint8_t 文件 數據 開頭 ews 信息 一、實驗目的 學習和掌握Linux下的TCP服務器基本原理和基本編程方法,體會TCP與UDP編程的不同，UDP編程：http://blog.csdn.net/yueguanghaidao/articl

編寫一個簡單的TCP服務端和客戶端

不同的 大連 終端 服務器端 com 讀寫 所有 字數 資料 下面的實驗環境是linux系統。 效果如下： 1.啟動服務端程序，監聽在6666端口上 2.啟動客戶端，與服務端建立TCP連接 3.建立完TCP連接，在客戶端上向服務端發送消息 4.斷開

openvpn 服務器和客戶端搭建和配置

window linux openvpn1， 搭建環境： 電腦A ： win7 64bit, 作為openvpn server 網上下載openvpn安裝包，直接安裝。 網口1， 有線網絡，可以訪問外網

oracle服務器和客戶端字符集的查看和修改

ultraedit 組成 alter 錯誤 eat 數據 rom 必須 直接 文章來源：http://www.cnblogs.com/chenyan296076785/p/3533065.html 一、什麽是oracle字符集 Oracle字符集是一個字節數據的解釋的符號集

使用自環接口的UDP服務器和客戶端

while clas code style client cal listen __main__ choices 1 import argparse,socket 2 from datetime import datetime 3 4 MAX_BYTES = 6

QTcpSocket-Qt使用Tcp通訊實現服務端和客戶端

超過 amp 方式 all trac tro article ada 內部 版權聲明：若無來源註明，Techie亮博客文章均為原創。 轉載請以鏈接形式標明本文標題和地址： 本文標題：QTcpSocket-Qt使用Tcp通訊實現服務端和客戶端 本文地址：http:/

QUdpSocket-Qt使用Udp通訊實現服務端和客戶端

array tle sig post 客戶端 種類型 可用 進行 += 版權聲明：若無來源註明，Techie亮博客文章均為原創。 轉載請以鏈接形式標明本文標題和地址： 本文標題：QUdpSocket-Qt使用Udp通訊實現服務端和客戶端 本文地址：http://t

windows安裝svn服務器和客戶端遇到的問題

註意 屬性 family 服務 電腦 圖片 地址 本地 pos 在本機既安裝svn服務器，又安裝svn客戶端，中間遇到的問題： 安裝svn-server端，將本地文件導入到svn-server,（要導入服務器的文件-右鍵-import-輸入要導入的路徑）.註意：中