5Người điều phối sự kiện

gói synceda; nhập java.util.HashMap; nhập java.util.Map; /** * @className: EventDispatcher * @description: Lớp này không phải là lớp an toàn theo luồng * @date: 2022/5/18 * @author : cakin */ public class EventDispatcher triển khai DynamicRouter{ // Được sử dụng để lưu mối quan hệ giữa Kênh và Tin nhắn riêng tư cuối cùng Map(); } @Override public void registerChannel(Class messageType, Channel kênh) { this.routerTable.put(messageType,channel) ; } @Override public void Clark(Message message) { if(routerTable.containsKey(message.getType())){ // Lấy trực tiếp Kênh tương ứng để xử lý Tin nhắn routerTable.get(message.getType()).dispatch(message); } else { ném MessageMatcherException("không thể khớp kênh cho loại ["+message.getType()+"]");

6 lớp ngoại lệ

gói được đồng bộ hóa; lớp công khai MessageMatcherException mở rộng RuntimeException { public MessageMatcherException(String message) { super(message);

lớp kiểm tra 7

package synceda; public class EventDispatcherExample { // Hai thuộc tính X và Y được định nghĩa trong inputEvent, chủ yếu được sử dụng cho các phần tử trong các Kênh khác static class inputEvent mở rộng Event { private Final int x; int y) { this.x = x; this.y = y } public int getX() { return x } public int getY() { return y; } } // Sự kiện được sử dụng để lưu trữ kết quả lớp tĩnh ResultEvent mở rộng Sự kiện { public Final int result; public ResultEvent(int result) { this.result = result; } public int getResult() { return result } } // Process ResultEvent Handler (Kênh), chỉ cần xuất kết quả tính toán ra bảng điều khiển lớp tĩnh ResultEventHandler thực hiện Channel { @Override public void Dispatch(ResultEvent message) { System.out.println("Kết quả là: " + message.getResult()); } } // inputEventHandler cần gửi Sự kiện đến Bộ định tuyến, vì vậy lớp tĩnh Dispatcher cần được chuyển vào trong quá trình thực hiện xây dựng inputEventHandler triển khai Channel { bộ điều phối EventDispatcher cuối cùng riêng tư; public inputEventHandler(bộ điều phối EventDispatcher) { this.dispatcher = người điều phối; } //Tạo kết quả được tính toán thành một Sự kiện mới và gửi nó tới Bộ định tuyến @Override public voiddispatch(InputEvent message) { System.out.printf("X:%d,Y:%d\n " , message.getX(), message.getY()); int result = message.getX() + message.getY(); Dispatch(new ResultEvent(result)); } public static void main(String[] args) { EventDispatcher bộ điều phối = new EventDispatcher(); // Đăng ký mối quan hệ ràng buộc giữa Sự kiện và Trình xử lý (Kênh) với bộ điều phối DisPatcher.registerChannel(InputEvent.class, new inputEventHandler(dispatcher)); .registerChannel(ResultEvent.class, new ResultEventHandler()); bộ điều phối.dispatch(mới) Sự kiện đầu vào(1, 2)); } } }

Ba kết quả kiểm tra

X:1,Y:2

Kết quả là: 3