• โฮมเพจ
  • บทความ
  • ทั่วไป
  • Java NIO (Non-blocking I/O) พร้อมตัวอย่างเซิร์ฟเวอร์-ไคลเอ็นต์ – java.nio.ByteBuffer และช่องสัญญาณ ตัวเลือก – Java NIO Vs. IO

Java NIO (Non-blocking I/O) พร้อมตัวอย่างเซิร์ฟเวอร์-ไคลเอ็นต์ – java.nio.ByteBuffer และช่องสัญญาณ ตัวเลือก – Java NIO Vs. IO

เผยแพร่แล้ว: 2021-08-06
Java NIO (ไม่บล็อก I:O) พร้อมตัวอย่างเซิร์ฟเวอร์ - ไคลเอนต์ - CrunchifyNIOServer.java

Java NIO เป็นหัวข้อที่ฉันชอบ ฉันทำงานกับ NIO มาตั้งแต่ 2 ปีที่แล้ว และต้องการแชร์ Server-Client code แบบง่ายสำหรับผู้อ่านของฉันที่สามารถใช้รหัสนี้ในสภาพแวดล้อมที่ใช้งานจริงได้ฟรี

เริ่มต้น JDK 1.4 NIO ถูกสร้างขึ้นเพื่อให้โปรแกรมเมอร์ Java ทั้งหมดใช้อินพุต/เอาต์พุตความเร็วสูงมากโดยไม่ต้องจัดการกับโค้ดเนทีฟที่กำหนดเอง NIO ใช้ไลบรารี java.nio.buffer เมื่อเปรียบเทียบกับ I/O แบบธรรมดา ซึ่งจะระบายและเติมบัฟเฟอร์กลับภายในระบบปฏิบัติการใดๆ

ในบทช่วยสอนนี้ เราจะพูดถึงไลบรารี java.nio.channels และ java.nio.channels.Selector

  • channels แสดงถึงการเชื่อมต่อกับเอนทิตีที่สามารถดำเนินการ I/O เช่น ไฟล์และซ็อกเก็ต กำหนด selectors สำหรับการดำเนินการ I/O แบบมัลติเพล็กซ์ที่ไม่ปิดกั้น
  • selector อาจถูกสร้างขึ้นโดยเรียกใช้ open method ของคลาสนี้ ซึ่งจะใช้ผู้ให้บริการตัวเลือกเริ่มต้นของระบบเพื่อสร้างตัวเลือกใหม่
คำอธิบายแพ็คเกจ java.nio พร้อมรายละเอียด API

หากคุณมี below questions แสดงว่าคุณมาถูกที่แล้ว:

  • วิธีเริ่มต้นใช้งาน Java NIO
  • บทช่วยสอน Java NIO และ Java NIO คืออะไร
  • Java NIO แบบอะซิงโครนัส
  • การใช้งานที่แน่นอนของแพ็คเกจ java nio คืออะไร
  • Java NIO บทช่วยสอน
  • วิธีการใช้ I/O ประสิทธิภาพสูงกับ Java NIO

มาเริ่มกันเลย:

ขั้นตอนที่ 1

  • สร้าง CrunchifyNIOServer.java ซึ่งเปิดการเชื่อมต่อบน port 1111
  • ใช้ isAcceptable() เพื่อตรวจสอบว่าช่องพร้อมที่จะยอมรับการเชื่อมต่อซ็อกเก็ตใหม่หรือไม่
    • ถ้าใช่ – เชื่อมต่อ
  • ใช้ isReadable() เพื่อตรวจสอบว่าช่องพร้อมสำหรับการอ่านหรือไม่
    • ถ้าใช่ – อ่านจากบัฟเฟอร์และพิมพ์บน Eclipse console
  • เมื่อคุณได้ชื่อบริษัทว่า “crunchify”
    • การเชื่อมต่ออย่างใกล้ชิด

ขั้นตอนที่ 2

  • สร้าง CrunchifyNIOClient.java ซึ่งพยายามเชื่อมต่อกับเซิร์ฟเวอร์บน port 1111
  • สร้าง ArrayList ด้วยชื่อบริษัท 5 บริษัท
  • วนซ้ำผ่าน ArrayList และส่งแต่ละบริษัทไปยังเซิร์ฟเวอร์
  • ปิดการเชื่อมต่อหลังจากเสร็จสิ้นภารกิจ

ดูโค้ด Java นี้:

รหัสเซิร์ฟเวอร์ – CrunchifyNIOServer.java

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
package crunchify . com . tutorials ;
 
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 . ServerSocketChannel ;
import java . nio . channels . SocketChannel ;
import java . util . Iterator ;
import java . util . Set ;
 
/**
* @author Crunchify.com
* Java NIO (Non-blocking I/O) with Server-Client Example - java.nio.ByteBuffer and channels.Selector
* This is CrunchifyNIOServer.java
*/
 
public class CrunchifyNIOServer {
 
@ SuppressWarnings ( "unused" )
public static void main ( String [ ] args ) throws IOException {
 
// Selector: A multiplexor of SelectableChannel objects.
// A selector may be created by invoking the open method of this class, which will use the system's default selector provider to create a new selector.
// A selector may also be created by invoking the openSelector method of a custom selector provider. A selector remains open until it is closed via its close method.
Selector selector = Selector . open ( ) ; // selector is open here
 
// ServerSocketChannel: A selectable channel for stream-oriented listening sockets.
// A server-socket channel is created by invoking the open method of this class.
// It is not possible to create a channel for an arbitrary, pre-existing ServerSocket.
ServerSocketChannel crunchifySocket = ServerSocketChannel . open ( ) ;
// InetSocketAddress: This class implements an IP Socket Address (IP address + port number) It can also be a pair (hostname + port number),
// in which case an attempt will be made to resolve the hostname.
// If resolution fails then the address is said to be unresolved but can still be used on some circumstances like connecting through a proxy.
InetSocketAddress crunchifyAddr = new InetSocketAddress ( "localhost" , 1111 ) ;
 
// Binds the channel's socket to a local address and configures the socket to listen for connections
crunchifySocket . bind ( crunchifyAddr ) ;
 
// Adjusts this channel's blocking mode.
crunchifySocket . configureBlocking ( false ) ;
 
int ops = crunchifySocket . validOps ( ) ;
// SelectionKey: A token representing the registration of a SelectableChannel with a Selector.
// A selection key is created each time a channel is registered with a selector.
// A key remains valid until it is cancelled by invoking its cancel method, by closing its channel, or by closing its selector.
SelectionKey selectKy = crunchifySocket . register ( selector , ops , null ) ;
 
// Infinite loop..
// Keep server running
while ( true ) {
 
log ( "I'm a server and I'm waiting for new connection and buffer select..." ) ;
// Selects a set of keys whose corresponding channels are ready for I/O operations
selector . select ( ) ;
 
// token representing the registration of a SelectableChannel with a Selector
Set < SelectionKey > crunchifyKeys = selector . selectedKeys ( ) ;
Iterator < SelectionKey > crunchifyIterator = crunchifyKeys . iterator ( ) ;
 
while ( crunchifyIterator . hasNext ( ) ) {
SelectionKey myKey = crunchifyIterator . next ( ) ;
 
// Tests whether this key's channel is ready to accept a new socket connection
if ( myKey . isAcceptable ( ) ) {
SocketChannel crunchifyClient = crunchifySocket . accept ( ) ;
 
// Adjusts this channel's blocking mode to false
crunchifyClient . configureBlocking ( false ) ;
 
// Operation-set bit for read operations
crunchifyClient . register ( selector , SelectionKey . OP_READ ) ;
log ( "Connection Accepted: " + crunchifyClient . getLocalAddress ( ) + "\n" ) ;
 
// Tests whether this key's channel is ready for reading
} else if ( myKey . isReadable ( ) ) {
SocketChannel crunchifyClient = ( SocketChannel ) myKey . channel ( ) ;
// ByteBuffer: A byte buffer.
// This class defines six categories of operations upon byte buffers:
// Absolute and relative get and put methods that read and write single bytes;
// Absolute and relative bulk get methods that transfer contiguous sequences of bytes from this buffer into an array;
ByteBuffer crunchifyBuffer = ByteBuffer . allocate ( 256 ) ;
crunchifyClient . read ( crunchifyBuffer ) ;
String result = new String ( crunchifyBuffer . array ( ) ) . trim ( ) ;
 
log ( "Message received: " + result ) ;
 
if ( result . equals ( "Crunchify.com" ) ) {
crunchifyClient . close ( ) ;
log ( "\nIt's time to close connection as we got last company name 'Crunchify'" ) ;
log ( "\nServer will keep running. Try running client again to establish new connection" ) ;
}
}
crunchifyIterator . remove ( ) ;
}
}
}
 
private static void log ( String str ) {
System . out . println ( str ) ;
}
}
 

รหัสลูกค้า – CrunchifyNIOClient.java

Java NIO (ไม่บล็อก I:O) พร้อมตัวอย่างเซิร์ฟเวอร์ - ไคลเอนต์ - CrunchifyNIOClient.java
Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
package crunchify . com . tutorials ;
 
import java . io . IOException ;
import java . net . InetSocketAddress ;
import java . nio . ByteBuffer ;
import java . nio . channels . SocketChannel ;
import java . util . ArrayList ;
 
/**
* @author Crunchify.com
* Java NIO (Non-blocking I/O) with Server-Client Example - java.nio.ByteBuffer and channels.Selector
* This is CrunchifyNIOClient.java
*/
 
public class CrunchifyNIOClient {
 
public static void main ( String [ ] args ) throws IOException , InterruptedException {
 
InetSocketAddress crunchifyAddr = new InetSocketAddress ( "localhost" , 1111 ) ;
//  selectable channel for stream-oriented connecting sockets
SocketChannel crunchifyClient = SocketChannel . open ( crunchifyAddr ) ;
 
log ( "Connecting to Server on port 1111..." ) ;
 
ArrayList <String> companyDetails = new ArrayList <String> ( ) ;
 
// create a ArrayList with companyName list
companyDetails . add ( "Facebook" ) ;
companyDetails . add ( "Twitter" ) ;
companyDetails . add ( "IBM" ) ;
companyDetails . add ( "Google" ) ;
companyDetails . add ( "Crunchify" ) ;
 
for ( String companyName : companyDetails ) {
 
byte [ ] message = new String ( companyName ) . getBytes ( ) ;
ByteBuffer buffer = ByteBuffer . wrap ( message ) ;
crunchifyClient . write ( buffer ) ;
 
log ( "sending: " + companyName ) ;
buffer . clear ( ) ;
 
// wait for 2 seconds before sending next message
Thread . sleep ( 2000 ) ;
}
// close(): Closes this channel.
// If the channel has already been closed then this method returns immediately.
// Otherwise it marks the channel as closed and then invokes the implCloseChannel method in order to complete the close operation.
crunchifyClient . close ( ) ;
}
 
private static void log ( String str ) {
System . out . println ( str ) ;
}
}

ผลลัพธ์ที่ฝั่งเซิร์ฟเวอร์:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
I 'm a server and I' m waiting for new connection and buffer select . . .
Connection Accepted : / 127.0.0.1 : 1111
 
I 'm a server and <meta charset="utf-8"/>I' m waiting for new connection and buffer select . . .
Message received : Facebook
< meta charset = "utf-8" / > I 'm a server and <meta charset="utf-8"/>I' m waiting for new connection and buffer select . . .
Message received : Twitter
< meta charset = "utf-8" / > I 'm a server and <meta charset="utf-8"/>I' m waiting for new connection and buffer select . . .
Message received : IBM
< meta charset = "utf-8" / > I 'm a server and <meta charset="utf-8"/>I' m waiting for new connection and < a href = "https://crunchify.com/how-to-remove-duplicate-elements-from-csv-or-any-other-file-in-java/" target = "_blank" rel = "noreferrer noopener" > buffer < / a > select . . .
Message received : Google
< meta charset = "utf-8" / > I 'm a server and <meta charset="utf-8"/>I' m waiting for new connection and buffer select . . .
Message received : Crunchify
 
It 's time to <a href="https://crunchify.com/json-manipulation-in-java-examples/" target="_blank" rel="noreferrer noopener">close connection</a> as we got last company name ' Crunchify '
 
Server will keep running. Try running client again to establish new connection
<meta charset="utf-8"/>I' m a server and < meta charset = "utf-8" / > I ' m waiting for new connection and buffer select . . .

ผลลัพธ์ที่ฝั่งไคลเอ็นต์:

1
2
3
4
5
6
Connecting to Server on port 1111...
sending : Facebook
sending : Twitter
sending : IBM
sending : Google
sending : Crunchify

คำถามที่พบบ่อย:

  1. จากลูกค้า ฉันจะรักษาการเชื่อมต่อแบบถาวรได้อย่างไร
    • คุณสามารถใช้ socket.setKeepAlive(true); เพื่อให้มีการเชื่อมต่อจากฝั่งไคลเอ็นต์
  2. ฉันจะอ่านการตอบกลับข้อความที่ฉันส่งไปยังเซิร์ฟเวอร์ได้อย่างไร เซิร์ฟเวอร์ยังคงสร้างข้อความทุกๆ 10 วินาที ฉันแค่ต้องอ่านการตอบกลับคำขอของฉัน จากสิ่งที่ฉันเข้าใจ ข้อมูล TCP "สตรีม" แทนการสิ้นสุดการบันทึก ฯลฯ
    • สำหรับการสื่อสารกับเซิร์ฟเวอร์ไคลเอ็นต์ ต้องมีการกำหนดโปรโตคอลให้ชัดเจน การโทร readLine() จะถูกบล็อกจนกว่าข้อมูลทั้งหมดจะถูกส่งคืน ดังนั้นอย่าใช้ Try reading bytes from the stream until -1 is returned.

แจ้งให้เราทราบหากใช้งานได้