使用指南-开发指南

开发指南

自定义Repository

public interface UserRepository extends BaseRepository<User, Long> {

    @Query("SELECT * FROM users WHERE status = #{status}")
    List<User> findByStatus(String status);

    @Cacheable(value = "users", key = "#email")
    User findByEmail(String email);
}

消息处理器

@Component
public class OrderEventHandler {

    @MessageHandler("order.created")
    public void handleOrderCreated(Message<Order> message) {
        Order order = message.getPayload();
        // 处理订单创建事件
    }

    @MessageHandler("order.cancelled") 
    public void handleOrderCancelled(Message<String> message) {
        String orderId = message.getPayload();
        // 处理订单取消事件
    }
}

Web控制器

@RestController
@RequestMapping("/api/products")
public class ProductController {

    @Autowired
    private ProductService productService;

    @GetMapping
    public Page<Product> getProducts(
            @RequestParam(defaultValue = "0") int page,
            @RequestParam(defaultValue = "20") int size,
            @RequestParam(required = false) String keyword) {
        return productService.searchProducts(keyword, page, size);
    }

    @PostMapping
    public Product createProduct(@Valid @RequestBody CreateProductRequest request) {
        return productService.createProduct(request);
    }
}