Socket là phương tiện hiệu quả để xây dựng các ứng dụng theo kiến trúc Client-Server. Trong bài viết này, tôi sẽ hướng dẫn các bạn các bước cơ bản trong việc xây dựng các ứng dụng Client-Server sử dụng Socket làm phương tiện giao tiếp theo cả hai chế độ: có nối kết (TCP – Transmission Control Protocol) và không nối kết ( UDP – User Datagram Protocol).
Các bạn nên xem bài viết trình làng Lập trình mạng trong Java trước khi liên tục xem nội dung tiếp theo của bài viết .
Tóm Tắt
Mô hình Client-Server sử dụng Socket ở chính sách có nối kết ( TCP )
Có thể phân thành 4 giai đoạn như sau:
- Giai đoạn 1: Server tạo Socket, gán số hiệu cổng và lắng nghe yêu cầu nối kết. Server sẵn sàng phục vụ Client.socket(): Server yêu cầu tạo một socket để có thể sử dụng các dịch vụ của tầng vận chuyển.
- bind(): Server yêu cầu gán số hiệu cổng (port) cho socket.
- listen(): Server lắng nghe các yêu cầu nối kết từ các client trên cổng đã được gán.
- Giai đoạn 2: Client tạo Socket, yêu cầu thiết lập một nối kết với Server.
- socket(): Client yêu cầu tạo một socket để có thể sử dụng các dịch vụ của tầng vận chuyển, thông thường hệ thống tự động gán một số hiệu cổng còn rảnh cho socket của Client.
- connect(): Client gởi yêu cầu nối kết đến server có địa chỉ IP và Port xác định.
- accept(): Server chấp nhận nối kết của client, khi đó một kênh giao tiếp ảo được hình thành, Client và server có thể trao đổi thông tin với nhau thông qua kênh ảo này.
- Giai đoạn 3: Trao đổi thông tin giữa Client và Server.
- Sau khi chấp nhận yêu cầu nối kết, thông thường server thực hiện lệnh read() và nghẽn cho đến khi có thông điệp yêu cầu (Request Message) từ client gởi đến.
- Server phân tích và thực thi yêu cầu. Kết quả sẽ được gởi về client bằng lệnh write().
- Sau khi gởi yêu cầu bằng lệnh write(), client chờ nhận thông điệp kết quả (ReplyMessage) từ server bằng lệnh read().
- Giai đoạn 4: Kết thúc phiên làm việc.
- Các câu lệnh read(), write() có thể được thưc hiện nhiều lần (ký hiệu bằng hình ellipse).
- Kênh ảo sẽ bị xóa khi Server hoặc Client đóng socket bằng lệnh close().
Mô hình Client-Server sử dụng Socket ở chính sách không nối kết ( UDP )
Có thể phân thành 3 tiến trình như sau :
- Giai đoạn 1: Server tạo Socket – gán số hiệu cổng.
- socket(): Server yêu cầu tạo một socket để có thể sử dụng các dịch vụ của tầng vận chuyển.
- bind(): Server yêu cầu gán số hiệu cổng cho socket.
- Giai đoạn 2: Client tạo Socket.
- socket(): Client yêu cầu tạo một socket để có thể sử dụng các dịch vụ của tầng vận chuyển, thông thường hệ thống tự động gán một số hiệu cổng còn rảnh cho socket của Client.
- Giai đoạn 3: Trao đổi thông tin giữa Client và Server.
- Sau khi tạo Socket xong, Client và Server có thể trao đổi thông tin qua lại với nhau thông qua hai hàm send() và receive().
- Đơn vị dữ liệu trao đổi giữa Client và Server là các Datagram Package (Gói tin thư tín).
- Protocol của ứng dụng phải định nghĩa khuôn dạng và ý nghĩa của các Datagram Package. Mỗi Datagram Package có chứa thông tin về địa chỉ người gởi và người nhận (IP, Port).
Xây dựng ứng dụng Client-Server với Socket trong Java
Thông qua các lớp trong gói java.net, các chương trình Java có thể sử dụng TCP hoặc UDP để giao tiếp qua Internet.
- Lớp IntetAddress: Lớp này quản lý địa chỉ Internet bao gồm địa chỉ IP và tên máy tính.
- Lớp Socket: Hỗ trợ các phương thức liên quan đến Socket cho chương trình Client ở chế độ có nối kết.
- Lớp ServerSocket: Hỗ trợ các phương thức liên quan đến Socket cho chương trình Server ở chế độ có nối kết.
- Lớp DatagramSocket: Hỗ trợ các phương thức liên quan đến Socket ở chế độ không nối kết cho cả Client và Server.
- Lớp DatagramPacket: Lớp cài đặt gói tin dạng thư tín người dùng (Datagram Packet) trong giao tiếp giữa Client và Server ở chế độ không nối kết.
Xây dựng chương trình Client – Server ở chính sách có nối kết ( TCP )
Trong phần tiếp theo tôi sẽ hướng dẫn những bạn thiết kế xây dựng chương trình Client – Server đơn giản. Client sẽ gởi lần lượt những số từ 0 đến 9 tới Server. Server lần lượt sẽ gởi những số nhận được về Client .Các bước tổng quát kiến thiết xây dựng một chương trình Client – Server ở chính sách có nối kết như sau :
- Mở một socket nối kết đến server đã biết địa chỉ IP (hay tên miền) và số hiệu cổng.
- Lấy InputStream và OutputStream gán với Socket.
- Tham khảo Protocol của dịch vụ để định dạng đúng dữ liệu trao đổi với Server.
- Trao đổi dữ liệu với Server nhờ vào các InputStream và OutputStream.
- Đóng Socket trước khi kết thúc chương trình.
Xây dựng chương trình Client ở chính sách có nối kết
Một số phương pháp thiết yếu để thiết kế xây dựng những chương trình client sử dụng socket ở chính sách có nối kết :
-
public Socket(String HostName, int PortNumber) : Phương thức này dùng để nối kết đến một server có tên là HostName, cổng là PortNumber. Nếu nối kết thành công, một kênh ảo sẽ được hình thành giữa Client và Server.
- HostName : Địa chỉ IP hoặc tên logic theo dạng tên miền .
- PortNumber : có giả trị từ 0 .. 65535
-
public InputStream getInputStream()
: Phương thức này trả về InputStream nối với Socket. Chương trình Client dùng InputStream này để nhận tài liệu từ Server gởi về .
-
public OutputStream getOutputStream()
: Phương thức này trả về OutputStream nối với Socket. Chương trình Client dùng OutputStream này để gởi tài liệu cho Server .
- public close ( ) :
Phương thức này sẽ đóng Socket lại, giải phóng kênh ảo, xóa nối kết giữa Client và
Server.
Code của chương trình Client như sau :
package com.gpcoder.tcp;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
public class EchoChatClient {
public final static String SERVER_IP = "127.0.0.1";
public final static int SERVER_PORT = 7;
public static void main(String[] args) throws IOException, InterruptedException {
Socket socket = null;
try {
socket = new Socket(SERVER_IP, SERVER_PORT); // Connect to server
System.out.println("Connected: " + socket);
InputStream is = socket.getInputStream();
OutputStream os = socket.getOutputStream();
for (int i = '0'; i <= '9'; i++) {
os.write(i); // Send each number to the server
int ch = is.read(); // Waiting for results from server
System.out.print((char) ch + " "); // Display the results received from the server
Thread.sleep(200);
}
} catch (IOException ie) {
System.out.println("Can't connect to server");
} finally {
if (socket != null) {
socket.close();
}
}
}
}
Xây dựng chương trình Server ở chính sách có nối kết
Một số phương pháp thiết yếu để xây dụng những chương trình Server sử dụng socket ở chính sách có nối kết. :
-
public ServerSocket(int portNumber)
: phương thức này tạo một Socket với số hiệu cổng là portNumber mà sau đó Server sẽ lắng nghe trên cổng này .
-
public Socket accept()
:
Phương thức này lắng nghe yêu cầu nối kết của các Client. Đây là một phương thức hoạt động ở chế độ nghẽn. Nó sẽ bị nghẽn cho đến khi có một yêu cầu nối kết của client gởi đến. Khi có yêu cầu nối kết của Client gởi đến, nó sẽ chấp nhận yêu cầu nối kết, trả về
một Socket là một đầu của kênh giao tiếp ảo giữa Server và Client yêu cầu nối kết. -
public InputStream getInputStream()
: Phương thức này trả về InputStream nối với Socket. Chương trình Server dùng InputStream này để nhận tài liệu từ Client gởi đến .
-
public OutputStream getOutputStream()
: Phương thức này trả về OutputStream nối với Socket. Chương trình Server dùng OutputStream này để trả tài liệu cho Client .
- public close ( ) :
Phương thức này sẽ đóng Socket lại, giải phóng kênh ảo, xóa nối kết giữa Client và
Server.
Một Server hoàn toàn có thể được setup để ship hàng những Client theo hai cách : Giao hàng tuần tự hoặc ship hàng song song .
- Trong chính sách ship hàng tuần tự, tại một thời gian Server chỉ gật đầu một nhu yếu nối kết. Các nhu yếu nối kết của những Client khác đều không được phân phối ( đưa vào hàng đợi ) .
- trái lại trong chính sách Giao hàng song song, tại một thời gian Server gật đầu nhiều nhu yếu nối kết và Giao hàng nhiều Client cùng lúc .
Xây dựng chương trình Server ship hàng tuần tự
Các bước thực thi như sau :
- Tạo socket và gán số hiệu cổng cho server.
- Lắng nghe yêu cầu nối kết.
- Với một yêu cầu nối kết được chấp nhận thực hiện các bước sau:
- Lấy InputStream và OutputStream gắn với Socket của kênh ảo vừa được hình thành.
- Lặp lại công việc sau:
- Chờ nhận các yêu cầu (công việc).
- Phân tích và thực hiện yêu cầu.
- Tạo thông điệp trả lời.
- Gởi thông điệp trả lời về Client.
- Nếu không còn yêu cầu hoặc Client kết thúc, đóng Socket và quay lại bước 2.
Code của chương trình Server như sau :
package com.gpcoder.tcp;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class EchoChatSingleServer {
public final static int SERVER_PORT = 7;
public static void main(String[] args) throws IOException {
ServerSocket serverSocket = null;
try {
System.out.println("Binding to port " + SERVER_PORT + ", please wait ...");
serverSocket = new ServerSocket(SERVER_PORT);
System.out.println("Server started: " + serverSocket);
System.out.println("Waiting for a client ...");
while (true) {
try {
Socket socket = serverSocket.accept();
System.out.println("Client accepted: " + socket);
OutputStream os = socket.getOutputStream();
InputStream is = socket.getInputStream();
int ch = 0;
while (true) {
ch = is.read(); // Receive data from client
if (ch == -1) {
break;
}
os.write(ch); // Send the results to client
}
socket.close();
} catch (IOException e) {
System.err.println(" Connection Error: " + e);
}
}
} catch (IOException e1) {
e1.printStackTrace();
} finally {
if (serverSocket != null) {
serverSocket.close();
}
}
}
}
Chạy chương trình Server, ta có tác dụng sau :
Tiếp tục chạy chương trình Client, ta có tác dụng sau :
Xem lại hành lang cửa số console của Server, ta thấy hiệu quả như sau :
Xây dựng chương trình Server ship hàng song song
Server ship hàng song song hoàn toàn có thể chia thành 2 phần thực thi song song nhau :
- Phần 1 ( Dispatcher Thread ) : Xử lý những nhu yếu nối kết. Lặp lại những việc làm sau :
- Lắng nghe nhu yếu nối kết của Client .
- Chấp nhận một yêu cầu nối kết: Tạo kênh giao tiếp ảo mới với Client, tạo Phần 2 để xử lý các thông điệp yêu cầu của Client.
- Phần 2 ( Worker Thread ) : Xử lý những thông điệp nhu yếu từ người mua. Lặp lại các công việc sau:
- Chờ nhận thông điệp yêu cầu của khách hàng.
- Phân tích và xử lý yêu cầu.
- Gởi thông điệp trả lời cho khách hàng.
Phần 2 sẽ kết thúc khi kênh ảo bị xóa đi .Với mỗi Client, trên Server sẽ có một Phần 2 để giải quyết và xử lý nhu yếu của người mua. Như vậy tại một thời gian bất kể luôn sống sót 1 Phần 1 và 0 hoặc nhiều Phần 2 .Code của chương trình Server như sau :
EchoChatMultiServer.java
package com.gpcoder.tcp;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class EchoChatMultiServer {
public static final int NUM_OF_THREAD = 4;
public final static int SERVER_PORT = 7;
public static void main(String[] args) throws IOException {
ExecutorService executor = Executors.newFixedThreadPool(NUM_OF_THREAD);
ServerSocket serverSocket = null;
try {
System.out.println("Binding to port " + SERVER_PORT + ", please wait ...");
serverSocket = new ServerSocket(SERVER_PORT);
System.out.println("Server started: " + serverSocket);
System.out.println("Waiting for a client ...");
while (true) {
try {
Socket socket = serverSocket.accept();
System.out.println("Client accepted: " + socket);
WorkerThread handler = new WorkerThread(socket);
executor.execute(handler);
} catch (IOException e) {
System.err.println(" Connection Error: " + e);
}
}
} catch (IOException e1) {
e1.printStackTrace();
} finally {
if (serverSocket != null) {
serverSocket.close();
}
}
}
}
WorkerThread.java
package com.gpcoder.tcp;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
public class WorkerThread extends Thread {
private Socket socket;
public WorkerThread(Socket socket) {
this.socket = socket;
}
public void run() {
System.out.println("Processing: " + socket);
try {
OutputStream os = socket.getOutputStream();
InputStream is = socket.getInputStream();
while (true) {
int ch = is.read(); // Receive data from client
if (ch == -1) {
break;
}
os.write(ch); // Send the results to client
}
} catch (IOException e) {
System.err.println("Request Processing Error: " + e);
}
System.out.println("Complete processing: " + socket);
}
}
Chạy chương trình Server, ta có tác dụng sau :
Chạy liên tục 3 chương trình Client, ta có kết quả như sau:
Xem thêm: Ngôn ngữ HTML – Lập Trình Từ Đầu
Như bạn thấy, cả 3 chương trình Client đều được Server giải quyết và xử lý cùng lúc .
Xây dựng chương trình Client – Server ở chính sách không nối kết ( UDP )
UDP – User Datagram Protocol : cung cấp cơ chế vận chuyển không bảo đảm và không nối kết trên mạng IP, ngược với giao thức vận chuyển tin cậy, có nối kết TCP.
Cả giao thức TCP và UDP đều phân tài liệu ra thành những gói tin. Tuy nhiên TCP có thêm vào những tiêu đề ( Header ) vào trong gói tin để được cho phép truyền lại những gói tin thất lạc và tập hợp những gói tin lại theo thứ tự đúng đắn. UDP không cung ứng tính năng này, nếu một gói tin bị thất lạc hoặc bị lỗi, nó sẽ không được truyền lại, và thứ tự đến đích của những gói tin cũng không giống như thứ tự lúc nó được gởi đi .Tuy nhiên, về vận tốc, UDP sẽ truyền nhanh gấp 3 lần TCP. Cho nên chúng thường được dùng trong những ứng dụng yên cầu thời hạn truyền tải ngắn và không cần tính đúng chuẩn cao, ví dụ truyền âm thanh, hình ảnh …Mô hình client – server sử dụng lớp ServerSocket và Socket ở trên sử dụng giao thức TCP. Nếu muốn sử dụng quy mô client – server với giao thức UDP, ta sử dụng hai lớp java.net. DatagramSocket và java.net. DatagramPacket .DatagramSocket được sử dụng để truyền và nhận những DatagramPacket. Dữ liệu được truyền đi là một mảng những byte, chúng được gói vào trong lớp DatagramPacket. Chiều dài của tài liệu tối đa hoàn toàn có thể đưa vào DatagramPacket là khoảng chừng 60.000 byte ( nhờ vào vào dạng đường truyền ). Ngoài ra DatagramPacket còn chứa địa chỉ IP và cổng của quy trình gởi và nhận tài liệu .Cổng trong giao thức TCP và UDP hoàn toàn có thể trùng nhau. Trên cùng một máy tính, bạn hoàn toàn có thể gán cổng 20 cho socket dùng giao thức TCP và cổng 20 cho socket sử dụng giao thức UDP .Một số phương pháp thiết yếu để kiến thiết xây dựng những chương trình Client-Server sử dụng socket ở chính sách không nối kết :
- public DatagramPacket(byte[] b, int n, InternetAddress ia, int port) : Phương thức này cho phép tạo một DatagramPacket chứa dữ liệu và cả địa chỉ của máy nhận dữ liệu. Phương thức trả về một đối tượng thuộc lớp DatagramePacket.
- public DatagramSocket( int port) : Tạo Socket kiểu không nối kết cho Client với số hiệu cổng được xác định trong tham số (port). Nếu không xác định port, hệ thống tự động gán số hiệu cổng chưa sử dụng cho socket.
- public void send(DatagramPacket dp) : Dùng để gởi một DatagramPacket đi.
- public synchronized void receive(Datagrampacket dp) : Chờ nhận một DatagramPacket. Quá trình sẽ bị nghẽn cho đến khi có dữ liệu đến.
Các phương thức lấy thông tin trên một DatagramPacket nhận được:
Khi nhận được một DatagramPacket từ một quy trình khác gởi đến, ta hoàn toàn có thể lấy thông tin trên DatagramPacket này bằng những phương pháp sau :
- public synchronized() InternetAddress getAddress() : Địa chỉ máy gởi.
- public synchronized() int getPort() : Cổng của quá trình gởi.
- public synchronized() byte[] getData() : Dữ liệu từ gói tin.
- public synchronized() int getLength() : Chiều dài của dữ liệu trong gói tin.
Các phương thức đặt thông tin cho gói tin gởi:
Trước khi gởi một DatagramPacket đi, ta hoàn toàn có thể đặt thông tin trên DatagramPacket này bằng những phương pháp sau :
- public synchronized() void setAddress(IntermetAddress address) : Đặt địa chỉ máy nhận.
- public synchronized() void setPort(int port) : Đặt cổng quá trình nhận.
- public synchronized() void setData(byte buffer[]) : Đặt dữ liệu gởi.
- public synchronized() void setLength(int len) : Đặt chiều dài dữ liệu gởi.
Xây dựng chương trình Server ở chính sách không nối kết
Chương trình EchoServer setup Echo Server ở chính sách không nối kết, cổng mặc định là 7. Chương trình chờ nhận từng gói tin, lấy tài liệu ra khỏi gói tin nhận được và gởi ngược tài liệu đó về Client .
package com.gpcoder.udp;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
public class EchoServer {
public final static int SERVER_PORT = 7; // Cổng mặc định của Echo Server
public final static byte[] BUFFER = new byte[4096]; // Vùng đệm chứa dữ liệu cho gói tin nhận
public static void main(String[] args) {
DatagramSocket ds = null;
try {
System.out.println("Binding to port " + SERVER_PORT + ", please wait ...");
ds = new DatagramSocket(SERVER_PORT); // Tạo Socket với cổng là 7
System.out.println("Server started ");
System.out.println("Waiting for messages from Client ... ");
while (true) { // Tạo gói tin nhận
DatagramPacket incoming = new DatagramPacket(BUFFER, BUFFER.length);
ds.receive(incoming); // Chờ nhận gói tin gởi đến
// Lấy dữ liệu khỏi gói tin nhận
String message = new String(incoming.getData(), 0, incoming.getLength());
System.out.println("Received: " + message);
// Tạo gói tin gởi chứa dữ liệu vừa nhận được
DatagramPacket outsending = new DatagramPacket(message.getBytes(), incoming.getLength(),
incoming.getAddress(), incoming.getPort());
ds.send(outsending);
}
} catch (IOException e) {
e.printStackTrace();
} finally {
if (ds != null) {
ds.close();
}
}
}
}
Xây dựng chương trình Client ở chính sách không nối kết
Chương trình này được cho phép người sử dụng nhận những chuỗi từ bàn phím, gởi chuỗi sang EchoServer ở chính sách không nối kết ở cổng số 7, chờ nhận và in tài liệu từ Server gởi về ra màn hình hiển thị .
package com.gpcoder.udp;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
public class EchoClient {
public final static String SERVER_IP = "127.0.0.1";
public final static int SERVER_PORT = 7; // Cổng mặc định của Echo Server
public final static byte[] BUFFER = new byte[4096]; // Vùng đệm chứa dữ liệu cho gói tin nhận
public static void main(String[] args) {
DatagramSocket ds = null;
try {
ds = new DatagramSocket(); // Tạo DatagramSocket
System.out.println("Client started ");
InetAddress server = InetAddress.getByName(SERVER_IP);
while (true) {
System.out.println("Enter your message: ");
InputStreamReader isr = new InputStreamReader(System.in); // Nhập
BufferedReader br = new BufferedReader(isr); // một chuỗi
String theString = br.readLine(); // từ bàn phím
byte[] data = theString.getBytes(); // Đổi chuỗi ra mảng bytes
// Tạo gói tin gởi
DatagramPacket dp = new DatagramPacket(data, data.length, server, SERVER_PORT);
ds.send(dp); // Send gói tin sang Echo Server
// Gói tin nhận
DatagramPacket incoming = new DatagramPacket(BUFFER, BUFFER.length);
ds.receive(incoming); // Chờ nhận dữ liệu từ EchoServer gởi về
// Đổi dữ liệu nhận được dạng mảng bytes ra chuỗi và in ra màn hình
System.out.println("Received: " + new String(incoming.getData(), 0, incoming.getLength()));
}
} catch (IOException e) {
System.err.println(e);
} finally {
if (ds != null) {
ds.close();
}
}
}
}
Chạy chương trình Server, ta có hiệu quả như sau :
Chạy chương trình Client, ta có tác dụng như sau :
Tại Client, nhập nội dung message là Hello. Ta có tác dụng như sau :
Tại Cient, liên tục nhập nội dung là How are you. Ta có hiệu quả như sau :
Xây dựng chương trình Client-Server nối kết theo dạng multicast ( truyền theo nhóm )
Các chính sách Socket TCP và UDP đã ra mắt ở trên đề gọi là unicast, nghĩa là tiếp xúc chỉ diễn ra giữa một máy tính gửi và một máy tính nhận .Multicast là việc gửi tiếp thị ( broadcast ) nhưng đến một nhóm máy tính ở cùng một địa chỉ cho trước. Địa chỉ multicast là địa chỉ lớp D được xác lập trong khoảng chừng 244.0.0.0 đến 239.255.255.255. Địa chỉ 244.0.0.0 là địa chỉ riêng nên không sử dụng được .Multicast được sử dụng trong game nhiều người chơi, trong những ứng dụng mà đối tượng người tiêu dùng là nhiều thiết bị hay nhiều máy tính cùng nhận một loại thông tin. Multicast cũng được sử dụng trong giải thuật vạch đường ( Routing Protocol ), khi những router muốn update thông tin với nhau .Java tương hỗ Multicast trải qua lớp java.net. MulticastSocket. Một Multicast Socket là 1 DatagramSocket ( UDP ) có năng lực gia nhập ( joining ) vào một nhóm những máy tính multicast trên mạng. Khi một máy tính nào gửi thông điệp đến nhóm thì toàn bộ những máy tính trong đó đều nhận được .
Một số phương pháp thiết yếu để kiến thiết xây dựng những chương trình Multicast :
- public MulticastSocket(int port): Tạo Socket kiểu Multicast với số hiệu cổng được xác định trong tham số (port).
- public void joinGroup(InetAddress group) : Tham gia nhóm Multicast tại địa chỉ xác định.
- public void leaveGroup(InetAddress group) : Rời khỏi nhóm Multicast tại địa chỉ xác định.
- public void send(DatagramPacket dp) : Dùng để gởi một DatagramPacket đi.
public synchronized void receive(Datagrampacket dp) : Chờ nhận một DatagramPacket.
Ví dụ :Cài đặt một dịch vụ gởi tin nhắn trên cổng 8888, tại địa chỉ 224.0.0.1. Khi Client muốn nhận tin nhắn thì Join Group tại địa chỉ và cổng trên .
Lớp Sender
package com.gpcoder.multicast;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
public class MulticastSender {
public static final String GROUP_ADDRESS = "224.0.0.1";
public static final int PORT = 8888;
public static void main(String[] args) throws InterruptedException {
DatagramSocket socket = null;
try {
// Get the address that we are going to connect to.
InetAddress address = InetAddress.getByName(GROUP_ADDRESS);
// Create a new Multicast socket
socket = new DatagramSocket();
DatagramPacket outPacket = null;
long counter = 0;
while (true) {
String msg = "Sent message No. " + counter;
counter++;
outPacket = new DatagramPacket(msg.getBytes(), msg.getBytes().length, address, PORT);
socket.send(outPacket);
System.out.println("Server sent packet with msg: " + msg);
Thread.sleep(1000); // Sleep 1 second before sending the next message
}
} catch (IOException ex) {
ex.printStackTrace();
} finally {
if (socket != null) {
socket.close();
}
}
}
}
Lớp Receiver
package com.gpcoder.multicast;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.InetAddress;
import java.net.MulticastSocket;
public class MulticastReceiver {
public static final byte[] BUFFER = new byte[4096];
public static void main(String[] args) {
MulticastSocket socket = null;
DatagramPacket inPacket = null;
try {
// Get the address that we are going to connect to.
InetAddress address = InetAddress.getByName(MulticastSender.GROUP_ADDRESS);
// Create a new Multicast socket
socket = new MulticastSocket(MulticastSender.PORT);
// Joint the Multicast group
socket.joinGroup(address);
while (true) {
// Receive the information and print it.
inPacket = new DatagramPacket(BUFFER, BUFFER.length);
socket.receive(inPacket);
String msg = new String(BUFFER, 0, inPacket.getLength());
System.out.println("From " + inPacket.getAddress() + " Msg : " + msg);
}
} catch (IOException ex) {
ex.printStackTrace();
}
}
}
Chạy chương trình MulticastSender, sau đó start tiếp một vài chương trình MulticastReceiver. Chúng ta nhận được tác dụng như sau :
Như bạn thấy, bất kỳ client nào join group đều nhận được nội dung message giống nhau, và nhận cùng thời điểm. Chương trình Multicast Server vẫn phục vụ theo dạng UDP, chỉ khác là sẽ gửi gói tin Datagram đến địa chỉ IP thuộc lớp D.
Tài liệu tham khảo:
- https://docs.oracle.com/javase/tutorial/networking/index.html
- Giáo trình Lập trình truyền thông – Thầy Ngô Bá Hùng, Nguyễn Công Huy – Khoa CNTT&TT, Trường Đại học Cần Thơ.
4.8Nếu bạn thấy hay thì hãy chia sẻ bài viết cho mọi người nhé!
Shares
Có thể bạn muốn xem:
- Lập trình mạng với java ( 22/03/2018 )
Bình luận
phản hồi
Source: https://final-blade.com
Category: Kiến thức Internet
