Design Pattern - Observer

Nó là gì ?

Observer cho phép các đối tượng có thể lắng nghe và phản ứng khi có thông báo từ một đối tượng khác. Tức là khi một đối tượng gửi một thông báo, các đối tượng lắng nghe nó có thể phản ứng lại với thông báo đó.

Sử dụng khi nào ?

Khi bạn muốn các đối tượng liên lạc với nhau. Khi đối tượng này gửi 1 thông điệp thì các đối tượng đăng ký lắng nghe thông điệp sẽ phản ứng lại với thông điệp đó. Đối tượng gửi thông điệp sẽ không cần biết nó sẽ gửi cho ai và đối tượng nhận thông điệp sẽ không cần biết ai gửi thông điệp đó.

Dùng nó như thế nào ?

Giả sử trong một hệ thống bán hàng, mỗi khi có sản phẩm mới hệ thống sẽ thông báo cho tất cả các khách hàng quan tâm đến sản phẩm này. Đầu tiên tôi tạo ra một lớp interface với 1 phương thức sẽ phản ứng khi có sản phẩm mới .

1. public interface Observer{
2.    void update(String message);//phương thức phản ứng lại khi nhận được thông báo.
3. }
   

Và lớp Customer sẽ triển khai interface trên :

1. public class Customer implements Observer{
2. private String name;
3. private int age;
5. public Customer(String name, int age) {
6. super();
7. this.name = name;
8. this.age = age;
9. }
10. 
    
11. @Override
12. public void update(String message) {
13. System.out.println(name + " " + message);
14. }
15. 
    
16. }

Tiếp theo tạo một interface với các phương thức, cho phép đối tượng Observer đăng ký phản ứng, hủy đăng ký nhận, và thông báo đến tất cả các đối tượng Observer đã đăng ký :

1. public interface Subject {  
2.     public void attachObserver(Observer observer);// thêm đối tượng đăng ký lắng nghe thông báo.
3.     public void detachObserver(Observer observer);// hủy đối tượng đăng ký lắng nghe thông báo
4.     public void notifyObserver();//thong bao đến tất cả các đối tượng đã đăng ký thông báo.
5. }

Và class Product sẽ triển khai interface trên:

1. public class Product implements Subject{
2. private List<Observer> obs = new ArrayList<Observer>();
3. private String nameProduct;
5. public Product(String nameProduct) {
6. super();
7. this.nameProduct = nameProduct;
8. }
9. 
   
10. @Override
11. public void attachObserver(Observer observer) {
12. obs.add(observer);
13. }
14. 
    
15. @Override
16. public void detachObserver(Observer observer) {
17. obs.remove(observer);
18. }
19. 
    
20. @Override
21. public void notifyObserver() {
22. for(Observer ob : obs){
23. ob.update(nameProduct);
24. }
25. }
26. }

Ok đến đây ta đã có một class có thể thông báo đến các observer và observer sẽ phản ứng lại với thông báo này. Tạo hàm main như sau:

1. public class Main {
2. public static void main(String[] args) {
3. Customer cus1 = new Customer("Ti", 11);
4. Customer cus2 = new Customer("Teo", 12);
5. Product product1 = new Product("Laptop");
6. product1.attachObserver(cus1);//cus1 dang ky phan ung khi có thông báo từ product
7. product1.attachObserver(cus2);
8. product1.notifyObserver();//thông báo đến tất cả các Observer.
9. }
10. }

Oke vậy đã xong Observer.