事件监听: demo

Author: 曾梓健

observe/pom.xml

@@ -31,6 +31,10 @@
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-autoconfigure</artifactId>
 		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-web</artifactId>
+		</dependency>
 	</dependencies>
 
 	<build>

observe/src/main/java/com/hand/event/ObserveApplication.java renamed to observe/src/main/java/com/hand/observe/ObserveApplication.java

@@ -1,4 +1,4 @@
-package com.hand.event;
+package com.hand.observe;
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;

observe/src/main/java/com/hand/observe/bean/Order.java

@@ -0,0 +1,44 @@
+package com.hand.observe.bean;
+
+/**
+ * @author zijian.zeng@hand-china.com
+ * @since 2023-01-30
+ */
+public class Order {
+
+	private long id;
+
+	private String name;
+
+	public Order() {
+	}
+
+	public Order(long id, String name) {
+		this.id = id;
+		this.name = name;
+	}
+
+	public long getId() {
+		return id;
+	}
+
+	public void setId(long id) {
+		this.id = id;
+	}
+
+	public String getName() {
+		return name;
+	}
+
+	public void setName(String name) {
+		this.name = name;
+	}
+
+	@Override
+	public String toString() {
+		return "Order{" +
+				"id=" + id +
+				", name='" + name + '\'' +
+				'}';
+	}
+}

observe/src/main/java/com/hand/observe/controller/OrderController.java

@@ -0,0 +1,31 @@
+package com.hand.observe.controller;
+
+import com.hand.observe.bean.Order;
+import com.hand.observe.service.OrderService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @author zijian.zeng@hand-china.com
+ * @since 2023-01-30
+ */
+@RestController
+@RequestMapping("/order")
+public class OrderController {
+
+
+	@Autowired
+	private OrderService orderService;
+
+
+	@RequestMapping("/buy")
+	public Order getOrder() {
+		Order order = new Order(1, "aaa");
+		orderService.buy(order);
+		return order;
+	}
+
+
+
+}

observe/src/main/java/com/hand/observe/event/OrderSuccessEvent.java

@@ -0,0 +1,36 @@
+package com.hand.observe.event;
+
+import com.hand.observe.bean.Order;
+import org.springframework.context.ApplicationEvent;
+
+/** 事件
+ * @author zijian.zeng@hand-china.com
+ * @since 2023-01-30
+ */
+public class OrderSuccessEvent extends ApplicationEvent {
+
+	private Order order;
+
+	/**
+	 * Create a new {@code ApplicationEvent}.
+	 *
+	 * @param source the object on which the event initially occurred or with
+	 *               which the event is associated (never {@code null})
+	 */
+	public OrderSuccessEvent(Object source) {
+		super(source);
+	}
+
+	public OrderSuccessEvent(Object source, Order order) {
+		super(source);
+		this.order = order;
+	}
+
+	public Order getOrder() {
+		return order;
+	}
+
+	public void setOrder(Order order) {
+		this.order = order;
+	}
+}

observe/src/main/java/com/hand/observe/listener/SmsListener.java

@@ -0,0 +1,26 @@
+package com.hand.observe.listener;
+
+import com.hand.observe.event.OrderSuccessEvent;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.context.ApplicationListener;
+import org.springframework.stereotype.Component;
+
+
+/**
+ * 发送短信的事件监听器
+ *
+ * @author zijian.zeng@hand-china.com
+ * @since 2023-01-30
+ */
+@Component
+public class SmsListener implements ApplicationListener<OrderSuccessEvent> {
+
+
+	Logger logger = LoggerFactory.getLogger(SmsListener.class);
+
+	@Override
+	public void onApplicationEvent(OrderSuccessEvent event) {
+		logger.info("短信发送成功....." + event.getOrder().getName());
+	}
+}

observe/src/main/java/com/hand/observe/service/OrderService.java

@@ -0,0 +1,12 @@
+package com.hand.observe.service;
+
+import com.hand.observe.bean.Order;
+
+/**
+ * @author zijian.zeng@hand-china.com
+ * @since 2023-01-30
+ */
+public interface OrderService {
+
+	void buy(Order order);
+}

observe/src/main/java/com/hand/observe/service/impl/OrderServiceImpl.java

@@ -0,0 +1,36 @@
+package com.hand.observe.service.impl;
+
+import com.hand.observe.bean.Order;
+import com.hand.observe.event.OrderSuccessEvent;
+import com.hand.observe.service.OrderService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.context.ApplicationEventPublisher;
+import org.springframework.context.ApplicationEventPublisherAware;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author zijian.zeng@hand-china.com
+ * @since 2023-01-30
+ */
+
+@Service
+public class OrderServiceImpl implements OrderService, ApplicationEventPublisherAware {
+
+
+	Logger logger = LoggerFactory.getLogger(OrderServiceImpl.class);
+
+	private ApplicationEventPublisher publisher;
+
+	@Override
+	public void buy(Order order) {
+		logger.info("下单成功: " + order.getName());
+		// 发布事件
+		publisher.publishEvent(new OrderSuccessEvent(this, order));
+	}
+
+	@Override
+	public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {
+		this.publisher = applicationEventPublisher;
+	}
+}

observe/src/test/java/com/hand/event/ObserveApplicationTests.java

@@ -0,0 +1,26 @@
+package com.hand.observe;
+
+import com.hand.observe.bean.Order;
+import com.hand.observe.service.OrderService;
+import com.hand.observe.service.impl.OrderServiceImpl;
+import org.junit.jupiter.api.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+
+@SpringBootTest
+@RunWith(SpringRunner.class)
+class ObserveApplicationTests {
+
+	@Autowired
+	private OrderService orderServiceImpl;
+
+
+	@Test
+	void contextLoads() {
+		Order o = new Order(1, "aaa");
+		orderServiceImpl.buy(o);
+	}
+
+}