Java实现拍卖系统详解

🏆本文收录于「滚雪球学SpringBoot」专栏，专业攻坚指数级提升持续更新中，up！up！up！！欢迎点赞&&收藏&&订阅。

@TOC

✨ 前言

拍卖系统是一种典型的电商系统场景，它包含用户注册、拍卖发起、竞价、订单生成等功能模块。在 Java 中开发一个拍卖系统，涉及多个技术点，包括数据库操作、Web开发、实时通信、定时任务和并发处理等。

本教程将带你从零开始实现一个简单的 Java 拍卖系统，并逐步讲解其中的核心功能和实现逻辑。

🧠 功能模块

1. 用户模块：

   • 用户注册与登录。
   • 用户可以发起拍卖和参与竞拍。

2. 拍卖模块：

   • 拍卖商品发布。
   • 拍卖开始后，用户可以竞价。
   • 实时通知最高出价。
   • 拍卖结束后生成订单。

3. 订单模块：

   • 拍卖结束时生成订单。
   • 支付订单。

4. 技术点：

   • Spring Boot 用于开发 RESTful API。
   • MySQL 作为数据库存储用户、商品和竞拍记录。
   • WebSocket 实现实时竞价。
   • 定时任务管理拍卖时间。

🌟 系统设计

1. 数据库设计

用户表（user）：

CREATE TABLE user (
    id BIGINT AUTO_INCREMENT PRIMARY KEY,
    username VARCHAR(50) NOT NULL UNIQUE,
    password VARCHAR(100) NOT NULL,
    email VARCHAR(100) NOT NULL
);

商品表（item）：

CREATE TABLE item (
    id BIGINT AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(100) NOT NULL,
    description TEXT,
    starting_price DECIMAL(10, 2) NOT NULL,
    current_price DECIMAL(10, 2) DEFAULT NULL,
    auction_end_time DATETIME NOT NULL,
    user_id BIGINT NOT NULL,
    FOREIGN KEY (user_id) REFERENCES user(id)
);

竞价记录表（bid）：

CREATE TABLE bid (
    id BIGINT AUTO_INCREMENT PRIMARY KEY,
    item_id BIGINT NOT NULL,
    user_id BIGINT NOT NULL,
    bid_amount DECIMAL(10, 2) NOT NULL,
    bid_time DATETIME NOT NULL,
    FOREIGN KEY (item_id) REFERENCES item(id),
    FOREIGN KEY (user_id) REFERENCES user(id)
);

订单表（order）：

CREATE TABLE order (
    id BIGINT AUTO_INCREMENT PRIMARY KEY,
    item_id BIGINT NOT NULL,
    user_id BIGINT NOT NULL,
    total_price DECIMAL(10, 2) NOT NULL,
    order_time DATETIME NOT NULL,
    FOREIGN KEY (item_id) REFERENCES item(id),
    FOREIGN KEY (user_id) REFERENCES user(id)
);

2. 系统架构

1. 技术栈：

   • Spring Boot：RESTful API 和业务逻辑。
   • MySQL：数据存储。
   • WebSocket：实时竞价通知。
   • Spring Scheduler：定时任务，用于拍卖结束的处理。

2. 模块划分：

   • 用户模块：用户注册、登录。
   • 拍卖模块：商品发布、竞价、拍卖结束处理。
   • 订单模块：生成订单和支付。

🛠️ 功能实现

1. 用户模块

用户模块包含用户的注册和登录功能。

注册接口：

@RestController
@RequestMapping("/users")
public class UserController {

    private final UserService userService;

    public UserController(UserService userService) {
        this.userService = userService;
    }

    @PostMapping("/register")
    public ResponseEntity<String> registerUser(@RequestBody User user) {
        userService.saveUser(user);
        return ResponseEntity.ok("User registered successfully!");
    }
}

服务层：

@Service
public class UserService {

    private final UserRepository userRepository;

    public UserService(UserRepository userRepository) {
        this.userRepository = userRepository;
    }

    public void saveUser(User user) {
        userRepository.save(user);
    }
}

数据层：

@Repository
public interface UserRepository extends JpaRepository<User, Long> {
    Optional<User> findByUsername(String username);
}

2. 拍卖商品模块

拍卖商品发布接口：

@RestController
@RequestMapping("/items")
public class ItemController {

    private final ItemService itemService;

    public ItemController(ItemService itemService) {
        this.itemService = itemService;
    }

    @PostMapping("/create")
    public ResponseEntity<String> createItem(@RequestBody Item item) {
        itemService.saveItem(item);
        return ResponseEntity.ok("Item created successfully!");
    }
}

服务层：

@Service
public class ItemService {

    private final ItemRepository itemRepository;

    public ItemService(ItemRepository itemRepository) {
        this.itemRepository = itemRepository;
    }

    public void saveItem(Item item) {
        itemRepository.save(item);
    }
}

数据层：

@Repository
public interface ItemRepository extends JpaRepository<Item, Long> {
}

3. 实时竞价功能

WebSocket 实现实时竞价通知：

WebSocket配置：

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {

    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        config.enableSimpleBroker("/topic");
        config.setApplicationDestinationPrefixes("/app");
    }

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/auction").setAllowedOrigins("*").withSockJS();
    }
}

竞价控制器：

@RestController
@RequestMapping("/bids")
public class BidController {

    private final SimpMessagingTemplate messagingTemplate;
    private final BidService bidService;

    public BidController(SimpMessagingTemplate messagingTemplate, BidService bidService) {
        this.messagingTemplate = messagingTemplate;
        this.bidService = bidService;
    }

    @PostMapping("/placeBid")
    public ResponseEntity<String> placeBid(@RequestBody Bid bid) {
        bidService.saveBid(bid);
        messagingTemplate.convertAndSend("/topic/auction/" + bid.getItemId(), bid);
        return ResponseEntity.ok("Bid placed successfully!");
    }
}

4. 定时任务：拍卖结束处理

使用 Spring Scheduler 定时检测拍卖是否结束：

定时任务实现：

@Component
public class AuctionScheduler {

    private final ItemRepository itemRepository;
    private final OrderService orderService;

    public AuctionScheduler(ItemRepository itemRepository, OrderService orderService) {
        this.itemRepository = itemRepository;
        this.orderService = orderService;
    }

    @Scheduled(fixedRate = 60000) // 每分钟检查一次
    public void checkAuctions() {
        List<Item> expiredItems = itemRepository.findExpiredItems(LocalDateTime.now());
        for (Item item : expiredItems) {
            orderService.createOrderForHighestBid(item);
            item.setAuctionEnded(true);
            itemRepository.save(item);
        }
    }
}

订单生成服务：

@Service
public class OrderService {

    private final BidRepository bidRepository;
    private final OrderRepository orderRepository;

    public OrderService(BidRepository bidRepository, OrderRepository orderRepository) {
        this.bidRepository = bidRepository;
        this.orderRepository = orderRepository;
    }

    public void createOrderForHighestBid(Item item) {
        Optional<Bid> highestBid = bidRepository.findTopByItemIdOrderByBidAmountDesc(item.getId());
        if (highestBid.isPresent()) {
            Order order = new Order();
            order.setItemId(item.getId());
            order.setUserId(highestBid.get().getUserId());
            order.setTotalPrice(highestBid.get().getBidAmount());
            order.setOrderTime(LocalDateTime.now());
            orderRepository.save(order);
        }
    }
}

🌟 系统运行流程

1. 用户通过 API 注册账号并登录。
2. 拍卖发起者发布商品，并设定拍卖结束时间。
3. 参与者使用 WebSocket 连接实时参与竞拍，出价后通知所有用户。
4. 定时任务检测拍卖是否结束，拍卖结束后生成订单并通知买家和卖家。
5. 买家支付订单，完成交易。

✨ 总结与扩展

这是一套简单的 Java 拍卖系统实现。为了让系统更完善，可以进行以下扩展：

1. 支付功能：集成支付网关（如支付宝、PayPal）。
2. 权限管理：为不同角色用户（买家、卖家、管理员）设置权限。
3. 高并发优化：对竞价和订单模块进行 Redis 分布式锁优化。
4. 数据分析：提供拍卖数据的分析功能。

通过这套实现，你可以了解 Java 的核心开发技术，并基于此扩展更复杂的拍卖系统！🎉

🧧福利赠与你🧧

  无论你是计算机专业的学生，还是对编程有兴趣的小伙伴，都建议直接毫无顾忌的学习此专栏「滚雪球学SpringBoot」，bug菌郑重承诺，凡是学习此专栏的同学，均能获取到所需的知识和技能，全网最快速入门SpringBoot，就像滚雪球一样，越滚越大， 无边无际，指数级提升。

最后，如果这篇文章对你有所帮助，帮忙给作者来个一键三连，关注、点赞、收藏，您的支持就是我坚持写作最大的动力。

同时欢迎大家关注公众号:「猿圈奇妙屋」 ，以便学习更多同类型的技术文章，免费白嫖最新BAT互联网公司面试题、4000G pdf电子书籍、简历模板、技术文章Markdown文档等海量资料。

✨️ Who am I?

我是bug菌，CSDN | 掘金 | InfoQ | 51CTO | 华为云 | 阿里云 | 腾讯云 等社区博客专家，C站博客之星Top30，华为云2023年度十佳博主，掘金多年度人气作者Top40，掘金等各大社区平台签约作者，51CTO年度博主Top12，掘金/InfoQ/51CTO等社区优质创作者；全网粉丝合计 30w+；更多精彩福利点击这里；硬核微信公众号「猿圈奇妙屋」，欢迎你的加入！免费白嫖最新BAT互联网公司面试真题、4000G PDF电子书籍、简历模板等海量资料，你想要的我都有，关键是你不来拿。

-End-