十万订单每秒热点数据架构优化实践深度解析

java复制代码
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;
public class DatabaseSharding {
private static final Map<Integer, String> shardMap = new HashMap<>();
static {
// 初始化分片规则，这里简单按用户ID模10进行分片
for (int i = 0; i < 10; i++) {
            shardMap.put(i, "jdbc:mysql://localhost:3306/db_shard_" + i);
        }
    }
public static Connection getConnection(int userId) throws SQLException {
String url = shardMap.get(userId % 10);
return DriverManager.getConnection(url, "root", "password");
    }
public static void main(String[] args) {
try {
// 模拟用户下单
int userId = 12345;
String productId = "P001";
int quantity = 1;
// 获取数据库连接
Connection conn = getConnection(userId);
// 插入订单数据
String sql = "INSERT INTO orders (user_id, product_id, quantity) VALUES (?, ?, ?)";
try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
                pstmt.setInt(1, userId);
                pstmt.setString(2, productId);
                pstmt.setInt(3, quantity);
                pstmt.executeUpdate();
                System.out.println("Order placed successfully!");
            }
// 查询订单数据（读写分离）
            sql = "SELECT * FROM orders WHERE user_id = ?";
try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
                pstmt.setInt(1, userId);
try (ResultSet rs = pstmt.executeQuery()) {
while (rs.next()) {
                        System.out.println("Order ID: " + rs.getInt("id"));
                        System.out.println("User ID: " + rs.getInt("user_id"));
                        System.out.println("Product ID: " + rs.getString("product_id"));
                        System.out.println("Quantity: " + rs.getInt("quantity"));
                    }
                }
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

java复制代码
import redis.clients.jedis.Jedis;
public class CacheSystem {
private static Jedis jedis = new Jedis("localhost", 6379);
public static void setCache(String key, String value) {
        jedis.set(key, value);
    }
public static String getCache(String key) {
return jedis.get(key);
    }
public static void main(String[] args) {
// 模拟将热点商品信息缓存在Redis中
String productId = "P001";
String productInfo = "{\"name\":\"热门商品\",\"price\":99.99,\"stock\":100}";
        setCache(productId, productInfo);
// 从Redis中获取热点商品信息
String cachedProductInfo = getCache(productId);
        System.out.println("Cached Product Info: " + cachedProductInfo);
    }
}

java复制代码
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
public class MessageQueue {
private static final String QUEUE_NAME = "order_queue";
public static void sendMessage(String message) throws Exception {
// 创建连接工厂
ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        factory.setUsername("guest");
        factory.setPassword("guest");
// 创建连接
try (Connection connection = factory.newConnection(); Channel channel = connection.createChannel()) {
// 声明队列
            channel.queueDeclare(QUEUE_NAME, false, false, false, null);
// 发送消息
            channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
            System.out.println(" [x] Sent '" + message + "'");
        }
    }
public static void receiveMessage() throws Exception {
// 创建连接工厂
ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        factory.setUsername("guest");
        factory.setPassword("guest");
// 创建连接
try (Connection connection = factory.newConnection(); Channel channel = connection.createChannel()) {
// 声明队列
            channel.queueDeclare(QUEUE_NAME, false, false, false, null);
            System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
// 创建消费者并接收消息
            channel.basicConsume(QUEUE_NAME, true, deliverCallback, cancelCallback);
        }
    }
private static final DeliverCallback deliverCallback = (consumerTag, delivery) -> {
String message = new String(delivery.getBody(), "UTF-8");
        System.out.println(" [x] Received '" + message + "'");
    };
private static final CancelCallback cancelCallback = consumerTag -> {
        System.out.println(" [x] Cancelled '" + consumerTag + "'");
    };
public static void main(String[] args) throws Exception {
// 发送订单消息到消息队列
        sendMessage("{\"user_id\":12345,\"product_id\":\"P001\",\"quantity\":1}");
// 接收并处理订单消息
        receiveMessage();
    }
}

java复制代码
public class Seckill {
public static void main(String[] args) {
try {
// 模拟用户下单（使用数据库分片、读写分离、缓存系统、消息队列等技术）
int userId = 12345;
String productId = "P001";
int quantity = 1;
// 1. 从缓存中获取商品信息（如果不存在则查询数据库并缓存）
String productInfo = CacheSystem.getCache(productId);
if (productInfo == null) {
// 模拟从数据库中查询商品信息并缓存
                productInfo = "{\"name\":\"热门商品\",\"price\":99.99,\"stock\":100}";
                CacheSystem.setCache(productId, productInfo);
            }
// 2. 验证库存（从缓存中获取库存信息并进行扣减）
int stock = Integer.parseInt(new org.json.JSONObject(productInfo).getString("stock"));
if (stock > 0) {
// 扣减库存
int newStock = stock - quantity;
                CacheSystem.setCache(productId, "{\"name\":\"热门商品\",\"price\":99.99,\"stock\":" + newStock + "}");
// 3. 插入订单数据到数据库（使用数据库分片）
try (Connection conn = DatabaseSharding.getConnection(userId)) {
String sql = "INSERT INTO orders (user_id, product_id, quantity) VALUES (?, ?, ?)";
try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
                        pstmt.setInt(1, userId);
                        pstmt.setString(2, productId);
                        pstmt.setInt(3, quantity);
                        pstmt.executeUpdate();
                        System.out.println("Order placed successfully!");
                    }
                }
// 4. 发送订单消息到消息队列（进行异步处理）
try {
                    MessageQueue.sendMessage("{\"user_id\":" + userId + ",\"product_id\":\"" + productId + "\",\"quantity\":" + quantity + "}");
                } catch (Exception e) {
                    e.printStackTrace();
                }
            } else {
                System.out.println("Out of stock!");
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}