Trong đời sống để hoàn toàn có thể hiểu nhau thì tất cả chúng ta cần phải trao đổi thông tin với nhau, tất cả chúng ta hoàn toàn có thể trao đổi thông tin bằng cách trò chuyện trực tiếp, qua điện thoại thông minh, email, zalo, skype, facebook, …Trong ứng dụng, những component của chương trình hoặc những chương trình trong một mạng lưới hệ thống cũng cần trao đổi thông tin với nhau để hoàn toàn có thể chạy giống hệt, việc trao đổi thông tin này trải qua message ( tin nhắn ) .Trong Java, nó phân phối 1 số ít API được cho phép những ứng dụng Java hoàn toàn có thể tạo, gửi, nhận và đọc những message. Các API này gọi JMS ( Java Message Service ) API .
Giới thiệu JMS
Message là gì ?
Message (Tin nhắn) là một phần thông tin. Nó có thể là một text, XML, JSON hoặc một Entity (đối tượng Java), … Message là dữ liệu rất hữu ích để giao tiếp giữa các hệ thống khác nhau.
Messaging là gì ?
Messaging ( gửi tin nhắn ) là việc trao đổi thông tin giữa những thành phần khác nhau trong cùng một mạng lưới hệ thống hoặc những mạng lưới hệ thống khác nhau. Nó hoàn toàn có thể xảy ra theo cách đồng điệu hoặc không đồng nhất .Ưu điểm của gửi tin nhắn là năng lực tích hợp những nền tảng khác nhau, làm giảm ùn tắc mạng lưới hệ thống, tăng cường năng lực lan rộng ra và nâng cao độ an toàn và đáng tin cậy gửi nhận tin .Có 2 quy mô gửi tin nhắn : P2P ( Point to Point ) và Pub / Sub ( Publisher / Subscriber ) .
JMS là gì ?
Java Message Service ( JMS ) API là một phần của đặc tả kỹ thuật Java Enterprice Edition ( Java EE ), là một API trung gian hướng thông tin Java ( MOM ) để gửi tin nhắn giữa hai hoặc nhiều client .JMS miêu tả những phương pháp tạo bởi chương trình Java cho việc : tạo ( Create ), gửi ( Send ), nhận ( Receive ), đọc ( Read ) tin nhắn .JMS được cho phép tiếp xúc giữa những thành phần khác nhau của một ứng dụng phân tán được liên kết lỏng lẻo, đáng đáng tin cậy và tương hỗ bất đồng bộ .Giao tiếp giữa những client được tạo ra bởi message broker qua những tiêu chuẩn truyền tin bất đồng bộ như AMQP, MQTT .JMS API là tiến hành để giải quyết và xử lý yếu tố nhà sản xuất-người tiêu dùng .JMS gồm có 2 thành phần :
- API : hỗ trợ chức năng cho người phát triển phần mềm.
- SPI (Service Provider Interface) : cho phép các Provider tạo ra tool JMS tích hợp, định hướng cho mọi người sử dụng theo hướng chuẩn hóa.
Khi tất cả chúng ta tăng trưởng Hệ thống gửi tin nhắn Java với JMS API, thì tất cả chúng ta hoàn toàn có thể tiến hành cùng một ứng dụng trong bất kể JMS Provider software nào .
MOM là gì ?
MOM ( Message-oriented middleware hay MQ – Message Queue ) là một ứng dụng trung gian tương hỗ gửi và nhận tin nhắn trong những ứng dụng phân tán .Cơ chế MOM tựa như như database với việc nhận và gửi message, bảo vệ toàn vẹn tài liệu, transaction và cân đối cho việc gửi nhận tài liệu .Nơi tàng trữ tài liệu và tương tác với MOM có tên gọi là Destination .Một số MOM tiêu biểu vượt trội :
| # | JMS Provider | Organization |
|---|---|---|
| 1. | WebSphere MQ | IBM |
| 2. | Weblogic Messaging | Oracle Corporation |
| 3. | Active MQ | Apache Foundation |
| 4. | Rabbit MQ | Rabbit Technologies(acquired by Spring Source) |
| 5. | HornetQ | JBoss |
| 6. | Sonic MQ | Progress Software |
| 7. | TIBCO EMS | TIBCO |
| 8. | Open MQ | Oracle Corporation |
| 9. | SonicMQ | Aurea Software |
JMS Broker
Để gửi hoặc nhận tin nhắn, thứ nhất, JMS Client phải liên kết với JMS message server ( còn gọi là JMS Broker – nhà môi giới ) :
- Một Connection mở ra một kênh liên lạc giữa client và broker.
- Tiếp theo, client phải thiết lập một session để tạo, tạo và đọc tin nhắn. Bạn có thể nghĩ về session như một luồng thông báo xác định cho một cuộc trò chuyện cụ thể giữa client và broker. Bản thân client là producer hoặc consumer.
- Transaction được tạo bởi client là transaction giữa producer và broker hoặc giữa broker và consumer, nhưng không bao giờ giữa producer và consumer.
- Producer gửi tin nhắn đến destination (đích) mà broker quản lý. Consumer truy cập destination đó để lấy tin nhắn.
- Tin nhắn bao gồm header (tiêu đề), optional properties (thuộc tính), và body (nội dung). Body chứa dữ liệu, header chứa thông tin broker cần định tuyến và quản lý tin nhắn và các thuộc tính có thể được xác định bởi các ứng dụng client hoặc bởi provider để phục vụ nhu cầu của chính họ trong việc xử lý tin nhắn.
- Connection, Session, Destination, Message, Producer và Consumer là những đối tượng cơ bản tạo nên một ứng dụng JMS.
Các thành phần của JMS
- JMS Provider :
- JMS API là một tập hợp các interface, không chứa bất kỳ implementation nào. JMS Provider là một hệ thống bên thứ ba, chịu trách nhiệm implement JMS API để cung cấp các tính năng nhắn tin cho khách hàng.
- JMS Provider còn được gọi là phần mềm MOM. JMS Provider cũng cung cấp một số thành phần UI để quản trị và kiểm soát phần mềm MOM này.
- JMS Provider được viết trên chuẩn Java do đó sẽ chạy được trên đa nền tảng.
- JMS Client : Là các chương trình độc lập hoặc các components (thành phần) của ứng dụng, được viết bằng Java có khả năng trao đổi message.
- JMS producer/ publisher : là JMS client tạo và gửi tin nhắn.
- JMS consumer/ subscriber : là JMS client nhận tin nhắn.
- JMS Message : Là các object, định dạng trung gian chứa data để giao tiếp giữa JMS Client và Provider.
- Administered object : hỗ trợ cơ chế quản lý và cấu hình cho JMS Object. Bao gồm:
- ConnectionFactory Object: được sử dụng để tạo kết nối giữa ứng dụng Java và JMS Provider. Tương tự như khái niệm truy cập DataSource của kết nối dữ liệu.
- Destination Object: là nơi lưu trữ cho message, là đối tượng JMS được JMS Client sử dụng để chỉ định đích của tin nhắn mà nó đang gửi và nguồn tin nhắn mà nó nhận được. Có hai loại Destination: Queue and Topic.
- JMS Queue : Khu vực chứa các tin nhắn đã được gửi và đang chờ để đọc (chỉ bởi một consumer). Hàng đợi này đảm bảo các tin nhắn được nhận theo thứ tự gửi và mỗi tin nhắn chỉ được xử lý một lần.
- JMS Topic : Một cơ chế phân phối để publisher gửi tin nhắn đến nhiều người đăng ký (subscriber).
Cơ chế tiếp xúc JMS
JMS phân phối chính sách tiếp xúc gồm có :
- Asynchronous: JMS tự động chuyển message đến người nhận khi message đến.
- Reliable: một message chỉ được chuyển đến đúng một người nhận mà không có cơ chế nhân bản, do vậy, tín hiệu phản hồi hoàn tất nhận message từ người nhận sẽ gây nên xóa bỏ thông tin trên middleware object.
Các quy mô JMS
JMS tương hỗ 2 quy mô trao đổi tài liệu là P2P ( Point to Point ) và Pub / Sub ( Publisher / Subscriber ). Các quy mô trao đổi này gọi là JMS message domain .
P2P ( Point to Point )
- Có ba thành phần chính là ứng dụng gửi (sender), Queue, ứng dụng nhận (receiver) tin.
- Sử dụng Queue làm nơi lưu trữ. Queue giữ lại các tin nhắn cho đến khi client nhận hoặc đến thời gian timout thiết lập.
- Định nghĩa 02 đối tượng cho việc gửi và nhận, đó là sender và receiver, và chỉ có một người gửi và một người nhận tin nhắn.
- Mô hình này message chuyển đi tuần tự (FIFO).
- Mô hình cho phép người nhận không cần active tại thời điểm gửi message.
- Sử dụng tín hiệu acknowledge để kích hoạt cho việc nhận message ở người nhận hoàn tất.
- Mô hình có tính bảo mật cao do một người gửi và một người nhận nhưng đôi lúc làm hệ thống bị block lại do chờ message đến.
- Cũng có ba thành phần chính là phía gửi (sender), Topic, và phía nhận (receiver).
- Mô hình sử dụng Topic làm nơi lưu trữ. Topic thực chất cũng là dạng queue nhưng có nhiều hơn một queue với các queue có đánh độ ưu tiên khác nhau.
- Mô hình cho phép 1 người gửi và nhiều người nhận do vậy đối tượng được định nghĩa là Publisher và Subcriber.
- Topic sẽ lưu lại toàn bộ tin nhắn mà không bị mất đi cho đến khi MOM được reset, hay xóa.
- Mỗi Subscriber sẽ chỉ nhận được message từ topic sau khi đã subscription.
- Không cần sử dụng thông tin acknowledge và message được chuyển đến các subscriber chỉ là bản copy.
- Mô hình bảo mật không cao do gửi nhiều người nhận nhưng được ưu điểm đó là áp dụng thuận lợi cho hệ thống phân tán.
- Mô hình Pub/Sub đòi hỏi đối tượng nhận phải active hay listener tại thời điểm gửi nhận message, nếu không message sẽ mất đi (non-durable). Do vậy, để message vẫn không mất đi nhưng được lưu trữ tạm thời trong MOM và cho phép người dùng truy cập vào MOM với tính xác thực thì chức năng durable phải được kích hoạt.
Cơ chế gửi nhận message trong JMS được chia thành hai thành phần:
- Synchronous: đối tượng nhận và gửi message thông qua thực hiện phương thức receive và phương thức này giữ ứng dụng chờ đợi cho đến khi message tới.
- Asynchronous: đối tượng nhận bắt buộc phải đăng ký cơ chế lắng nghe MessageListener để đón nhận message và phương thức được kích hoạt là onMessage để đón nhận và xử lý message.
Ưu điểm của JMS
- Reliability (Độ tin cậy) : Tin nhắn trung gian (Messaging middleware) đảm bảo tin nhắc được phân phối đến người nhận (receiver). Nếu người nhận ngừng hoạt động vì một số lý do, hệ thống nhắn tin sẽ lưu trữ tin nhắn cho đến khi nó hoạt động trở lại. Đảm bảo một message chỉ được gửi một lần, tránh trường hợp bị mất message hoặc trùng lặp.
- Asynchronous (Bất đồng bộ) : JMS Provider, client có thể gửi và nhận message không đồng bộ. Nghĩa là người gửi và người nhận không cần chờ nhau.
- Ease of Integration (dễ tích hợp) : Nhiều ứng dụng có thể được viết bằng các ngôn ngữ lập trình khác nhau hoặc chạy trên các máy chủ khác nhau. Miễn là chúng sử dụng cùng một giao thức, một phần mềm trung gian nhắn tin có thể được sử dụng để thiết lập liên lạc giữa chúng.
- Scalability (Khả năng mở rộng): Hệ thống nhắn tin giúp quảng bá tin nhắn đến nhiều receiver, giúp mở rộng.
- Flexibility (Tính linh hoạt) : có thể gán các giao thức khác nhau cho các tin nhắn khác nhau, cho phép ta linh hoạt trong việc thiết kế kiến trúc của mình.
- Loosely coupled (Kết nối lỏng lẻo) :
- JMS API là đặc tả kỹ thuật nên được triển khai bởi tất cả các JMS Provider. Vì vậy chúng ta có thể thay đổi Provider hiện tại sang Provider mới với ít thay đổi (có nghĩa là chỉ cấu hình) hoặc không thay đổi mã ứng dụng JMS.
- Tách biệt người gửi và người nhận, và người truyền tin trung gian sẽ lưu tin nhắn đến khi người nhận có thể xử lý.
- Interoperability (Khả năng tương tác) : JMS API cho phép khả năng tương tác giữa các ngôn ngữ nền tảng Java khác như Scala và Groovy.
Nhược điểm JMS
JMS sẽ không gồm có những tính năng sau, chính bới JMS chỉ là mạng lưới hệ thống gởi nhận tin :
- Load Balancing/Fault Tolerance
- Error/Advisory Notification
- Administration
- Security
- Wire Protocol
- Message Type Repository
Vì một vài hạn chế của JMS nên đa số trong những mạng lưới hệ thống distributed sẽ không sử dụng JMS mà sẽ sử dụng những libs được implement dựa trên JMS như Kafka, Zookeeper … những bạn hoàn toàn có thể tìm hiểu thêm thêm. Tuy nhiên, việc nắm được những khái niệm cơ bản của JMS sẽ giúp tất cả chúng ta chớp lấy được những third party nhanh gọn hơn .
JMS vs Socket
Ưu điểm của JMS :
- Người gửi và người nhận không cần biết nhau.
- Có thể dễ dàng đăng ký và hủy đăng ký
- Hữu ích cho việc lưu trữ thông tin offline và cập nhật số lượng lớn. Vì vậy, người nhận có thể xử lý từng cái một.
- Người gửi / người nhận có thể làm việc bất đồng bộ.
Ưu điểm Socket :
- Socket cung cấp một kết nối trực tiếp.
- Độ trễ thấp, vì không có máy chủ ở giữa (không có MoM)
- Socket hoạt động ở lớp TCP để truyền dữ liệu ít hơn.
Trường hợp sử dụng JMS ?
Một số trường hợp hoàn toàn có thể sử dụng JMS :
- Mong muốn các thành phần không phụ thuộc vào thông tin về interface của các thành phần khác, vì vậy các thành phần có thể dễ dàng thay thế.
- Muốn ứng dụng chạy cho dù tất cả các thành phần có hoạt động hay không.
- Ứng dụng cho phép một thành phần gửi thông tin cho người khác và tiếp tục hoạt động mà không cần chờ nhận được phản hồi ngay lập tức.
AMQP là gì ?
AMQP (Advanced Message Queuing Protocol – Giao thức xếp hàng tin nhắn nâng cao) là một giao thức internet mở và được chuẩn hóa để cho phần mềm trung gian hướng thông báo (MOM) truyền message tin cậy giữa các ứng dụng hoặc tổ chức. Các tính năng xác định của AMQP là định hướng tin nhắn, xếp hàng, định tuyến (bao gồm cả P2P và Publisher/Subscriber), độ tin cậy và bảo mật.
AMQP giúp những developer kiến thiết xây dựng một hệ sinh thái tin nhắn như nhau, phong phú, liên kết những mạng lưới hệ thống một cách tương tác và hợp tác .AMQP thường được so sánh với JMS ( Java Message Service ), mạng lưới hệ thống gửi tin nhắn thông dụng nhất trong hội đồng Java. Một hạn chế của JMS là những API được chỉ định, nhưng định dạng thông tin thì không. AMQP là một giao thức, nó diễn đạt về định dạng của tài liệu được gửi qua mạng dưới dạng luồng byte tài liệu truyền được chỉ định. Đặc tính này được cho phép những thư viện được viết bằng nhiều ngôn từ và chạy trên nhiều hệ quản lý và điều hành và kiến trúc CPU, tạo nên một tiêu chuẩn gửi tin nhắn đa nền tảng, hoàn toàn có thể tương tác thực sự .Một số điều quan trọng cần nhớ :
- AMQP là một giao thức nhắn tin, không triển khai JMS API.
- JMS là API và AMQP là một giao thức. Vì vậy, không có nghĩa gì khi nói rằng giao thức mặc định của JMS là gì, tất nhiên các ứng dụng client sử dụng HTTP/ HTTPS làm giao thức kết nối khi gọi Web Service.
- JMS chỉ là một đặc tả API. Nó không sử dụng bất kỳ giao thức nào. JMS Provider như ActiveMQ có thể đang sử dụng bất kỳ giao thức cơ bản nào để làm JMS Transport cho JMS API, chẳng hạn: AMQP, MQTT, OpenWire, REST (HTTP), RSS và Atom, Stomp, …
Trong bài này, tất cả chúng ta đã khám phá những khái niệm quan trọng của JMS. Trong những bài viết tiếp theo, tất cả chúng ta sẽ cùng hiểu hiểu về cách thiết lập và sử dụng JMS trải qua một số ít JMS Provider như Active MQ, Rabbit MQ, …
Tài liệu tham khảo:
5.0
Nếu bạn thấy hay thì hãy chia sẻ bài viết cho mọi người nhé!
Shares
Bình luận
phản hồi
