select*from t_coupon_task_fail where batch_id ='xxxxxx'limit0,1000;<\/code><\/pre>\n\n\n\n\u7136\u800c\uff0c\u8bb8\u591a\u4eba\u5e38\u5e38\u5ffd\u89c6\u4e00\u4e2a\u95ee\u9898\uff1a\u5f53 MySQL \u5728\u5904\u7406\u5206\u9875\u5f88\u6df1\u7684\u6570\u636e\u65f6\uff0c\u5c24\u5176\u662f\u8bfb\u53d6\u5927\u6570\u636e\u91cf\u4e2d\u7684\u9760\u540e\u90e8\u5206\u65f6\uff0c\u4f1a\u9047\u5230\u6df1\u5ea6\u5206\u9875\u95ee\u9898\u3002<\/p>\n\n\n\n
\u4ec0\u4e48\u662f\u6df1\u5206\u9875\uff1f<\/h2>\n\n\n\n
MySQL \u7684\u6df1\u5206\u9875\u95ee\u9898\u6307\u7684\u662f\u5728\u4f7f\u7528\u5206\u9875\u67e5\u8be2\u65f6\uff0c\u968f\u7740\u9875\u6570\u7684\u589e\u52a0\uff0c\u67e5\u8be2\u7684\u6548\u7387\u4f1a\u663e\u8457\u964d\u4f4e\uff0c\u5c24\u5176\u662f\u5bf9\u4e8e\u5927\u91cf\u6570\u636e\u7684\u8868\u3002\u8fd9\u901a\u5e38\u53d1\u751f\u5728\u4f7f\u7528 LIMIT<\/code> \u5b50\u53e5\u8fdb\u884c\u5206\u9875\u65f6\uff0c\u4f8b\u5982 LIMIT offset, count<\/code>\u3002\u5f53 offset<\/code> \u503c\u5f88\u5927\u65f6\uff0cMySQL \u9700\u8981\u626b\u63cf\u548c\u8df3\u8fc7\u5927\u91cf\u7684\u884c\uff0c\u8fd9\u4f1a\u5bfc\u81f4\u67e5\u8be2\u53d8\u6162\u3002<\/p>\n\n\n\n\u5bf9\u4e8e SELECT * FROM table LIMIT 1000000, 10<\/code> \u8fd9\u6837\u7684\u67e5\u8be2\uff0cMySQL \u4f1a\u626b\u63cf\u524d 1000000 \u6761\u8bb0\u5f55\uff0c\u7136\u540e\u4e22\u5f03\u5b83\u4eec\uff0c\u53ea\u8fd4\u56de\u63a5\u4e0b\u6765\u7684 10 \u6761\u3002\u8fd9\u610f\u5473\u7740\u5373\u4f7f\u6700\u7ec8\u7ed3\u679c\u53ea\u5305\u542b 10 \u6761\u8bb0\u5f55\uff0cMySQL \u4ecd\u7136\u9700\u8981\u5904\u7406\u5e76\u4e22\u5f03\u5927\u91cf\u7684\u884c\uff0c\u5bfc\u81f4\u67e5\u8be2\u65f6\u95f4\u968f\u7740 offset<\/code> \u589e\u5927\u800c\u589e\u52a0\u3002<\/p>\n\n\n\nGit \u5206\u652f<\/h2>\n\n\n\n
20240904_dev_coupon-distribute-v3_limit-page_ding.ma<\/p>\n\n\n\n
\u751f\u6210\u6d4b\u8bd5\u6570\u636e\u590d\u73b0\u6df1\u5206\u9875<\/h2>\n\n\n\n
\u6211\u4eec\u901a\u8fc7\u5b58\u50a8\u8fc7\u7a0b\u6a21\u62df 100 \u4e07\u7684\u5355\u4e2a\u6279\u6b21\u9519\u8bef\u8bb0\u5f55\uff0c\u786e\u4fdd\u6570\u636e\u6709\u4e2a\u504f\u771f\u5b9e\u7684\u72b6\u6001\u3002\u4e3b\u8981\u662f\u6570\u636e\u91cf\u5c0f\u4e86\u6a21\u62df\u4e0d\u51fa\u6765\u6df1\u5206\u9875\u7684\u6548\u679c\u3002<\/p>\n\n\n\n
DELIMITER $$\n\nCREATE PROCEDURE insert_coupon_task_fail_records()\nBEGIN\n DECLARE i INT DEFAULT 1;\n DECLARE batch_size INT DEFAULT 1000; -- \u6bcf\u6279\u63d2\u51651000\u6761\u8bb0\u5f55\n DECLARE json_data TEXT;\n\n WHILE i <= 1000000 DO\n -- \u5f00\u542f\u4e00\u4e2a\u4e8b\u52a1\n START TRANSACTION;\n\n -- \u6267\u884c\u6279\u91cf\u63d2\u5165\n SET @end = i + batch_size - 1;\n WHILE i <= @end DO\n SET json_data = CONCAT('{\"key\": \"value_', i, '\"}');\n INSERT INTO `t_coupon_task_fail` (`batch_id`, `json_object`)\n VALUES (1830889785603571980, json_data);\n SET i = i + 1;\n END WHILE;\n\n -- \u63d0\u4ea4\u4e8b\u52a1\n COMMIT;\n END WHILE;\nEND$$\n\nDELIMITER ;<\/code><\/pre>\n\n\n\n\u901a\u8fc7\u6267\u884c\u8fd9\u4e2a\u5b58\u50a8\u8fc7\u7a0b\uff0c\u6a21\u62df\u51fa 100 \u4e07\u8bb0\u5f55\uff0c\u5927\u6982\u6267\u884c\u5728 10 \u79d2\u4ee5\u4e0a\u3002<\/p>\n\n\n\n
CALL insert_coupon_task_fail_records();<\/code><\/pre>\n\n\n\n\u6211\u4eec\u5148\u6765\u770b\u770b\u6267\u884c\u67e5\u8be2\u524d 10 \u6761\u6570\u636e SQL \u6267\u884c\u65f6\u95f4\u662f\u591a\u4e45\uff0c\u6839\u636e\u6267\u884c\u8fd4\u56de\u7ed3\u679c\u6765\u770b\uff0c\u8fd4\u56de\u5927\u6982\u5728 500 \u00b5s<\/strong> \u5de6\u53f3\u3002<\/p>\n\n\n\nselect*from t_coupon_task_fail where batch_id ='1830889785603571980'limit0,10;<\/code><\/pre>\n\n\n\n\u5982\u679c\u67e5\u8be2\u6700\u540e\u51e0\u6761\u6570\u636e\uff0c\u90a3\u4e48\u8fd9\u4e2a SQL \u7684\u5e73\u5747\u6548\u5e94\u65f6\u95f4\u662f 600 ms<\/strong>\uff0c\u76f8\u5bf9\u4e8e\u524d\u9762\u7684\u6570\u636e\u6027\u80fd\u76f8\u5dee\u4e86\u8fd1 1200 \u500d<\/strong>\uff01\u8fd9\u4e2a\u6570\u636e\u662f\u5f88\u6050\u6016\u7684\u3002<\/p>\n\n\n\nselect*from t_coupon_task_fail where batch_id ='1830889785603571980'limit999990,10;<\/code><\/pre>\n\n\n\n\n1 \u6beb\u79d2\uff08ms\uff09 = 1000 \u5fae\u79d2\uff08\u00b5s\uff09<\/em><\/p>\n<\/blockquote>\n\n\n\n\u5982\u679c\u6211\u4eec\u591a\u6267\u884c\u51e0\u6b21\u5b58\u50a8\u8fc7\u7a0b\uff0c\u8ba9\u6570\u636e\u6765\u5230 500 \u4e07\uff0c\u67e5\u8be2\u6027\u80fd\u6765\u5230\u4e86\u60ca\u4eba\u7684\u8fd1 5 \u79d2\u3002\u6240\u4ee5\uff0c\u5927\u5bb6\u5982\u679c\u5728\u9879\u76ee\u4e2d\u9047\u5230\u7c7b\u4f3c\u4e8e\u8fd9\u79cd\u5927\u6570\u636e\u91cf\u6df1\u5206\u9875\u7684\u60c5\u51b5\uff0c\u4e00\u5b9a\u8981\u7279\u522b\u6ce8\u610f\uff0c\u7a0d\u5fae\u4e0d\u5c0f\u5fc3\u5c31\u662f\u6027\u80fd\u6df1\u6e0a\u3002<\/p>\n\n\n\n\n![\"\"](\"https:\/\/oss.open8gu.com\/image-20240904140627135.png\" "\\"\\"\/")
<\/figure>\n<\/figure>\n\n\n\n\u6df1\u5206\u9875\u4e3b\u8981\u95ee\u9898\u4e0d\u662f\u8bfb\u53d6\u67d0\u4e00\u6b21\u6027\u80fd\u5dee\uff0c\u800c\u662f\u6211\u4eec\u8bfb\u53d6\u90fd\u540e\u9762\u7684\u6240\u6709\u8bb0\u5f55\u90fd\u5f88\u6162\uff0c\u8d8a\u5230\u540e\u9762\u8d8a\u6162<\/strong>\u3002\u4e3e\u4e2a\u4f8b\u5b50\uff0c\u5047\u8bbe\u6211\u4eec\u5171\u9700\u8981\u53bb\u6570\u636e\u5e93\u8bfb\u53d6 100 \u4e07\u6570\u636e\uff0c\u6bcf\u6b21\u8bfb\u53d6 1000 \u6761\uff0c\u53ef\u80fd\u5230 50 \u4e07\u5c31\u5f00\u59cb\u660e\u663e\u53d8\u6162\u4e86\uff0c\u6700\u540e\u5c31\u4f1a\u6f14\u53d8\u6210\u4f1a\u6162 50\u4e07 \/ 1000 \u6b21\u3002<\/p>\n\n\n\n\u5982\u4f55\u89e3\u51b3\u6df1\u5206\u9875\uff1f<\/h2>\n\n\n\n
\u4e3a\u4e86\u65b9\u4fbf\u5927\u5bb6\u5f88\u76f4\u89c2\u80fd\u7406\u89e3\u4e0d\u540c\u6df1\u5206\u9875\u7684\u6027\u80fd\u5dee\u8ddd\uff0c\u6211\u4eec\u63a5\u4e0b\u6765\u7684\u793a\u4f8b\u4f1a\u6309\u7167 500 \u4e07\u6570\u636e\u7684\u57fa\u6570\u8fdb\u884c\u6d4b\u8bd5\u3002<\/p>\n\n\n\n
1. \u5b50\u67e5\u8be2\u4f18\u5316<\/h3>\n\n\n\n
\u6211\u4eec\u901a\u8fc7\u5b50\u67e5\u8be2\u7684\u65b9\u5f0f\u8fdb\u884c\u4f18\u5316\uff0c\u4f18\u5316\u8bed\u53e5\u5982\u4e0b\uff1a<\/p>\n\n\n\n
mysql> select * from t_coupon_task_fail where id >=\n ->\n -> (SELECT id\n -> FROM t_coupon_task_fail\n -> WHERE batch_id = '1830889785603571980'\n -> ORDER BY id\n -> LIMIT 4999990, 1\n -> )\n ->\n -> limit 10;\n+---------+---------------------+--------------------------+\n| id | batch_id | json_object |\n+---------+---------------------+--------------------------+\n| 4999991 | 1830889785603571980 | {\"key\": \"value_999991\"} |\n| 4999992 | 1830889785603571980 | {\"key\": \"value_999992\"} |\n| 4999993 | 1830889785603571980 | {\"key\": \"value_999993\"} |\n| 4999994 | 1830889785603571980 | {\"key\": \"value_999994\"} |\n| 4999995 | 1830889785603571980 | {\"key\": \"value_999995\"} |\n| 4999996 | 1830889785603571980 | {\"key\": \"value_999996\"} |\n| 4999997 | 1830889785603571980 | {\"key\": \"value_999997\"} |\n| 4999998 | 1830889785603571980 | {\"key\": \"value_999998\"} |\n| 4999999 | 1830889785603571980 | {\"key\": \"value_999999\"} |\n| 5000000 | 1830889785603571980 | {\"key\": \"value_1000000\"} |\n+---------+---------------------+--------------------------+\n10 rows in set (0.61 sec)<\/code><\/pre>\n\n\n\n\u53ef\u4ee5\u770b\u5230\uff0c\u540c\u6837\u7684 SQL \u8bed\u53e5\uff0c\u6027\u80fd\u4ece\u8fd1 5 \u79d2\u4e0b\u964d\u5230\u4e86 610 \u6beb\u79d2\u3002<\/p>\n\n\n\n
\u90a3\u6211\u4eec\u518d\u901a\u8fc7 explain \u8bed\u53e5\uff0c\u5206\u6790\u4e0b\u4e3a\u4ec0\u4e48\u80fd\u591f\u4f18\u5316\u6df1\u5206\u9875\u95ee\u9898\uff1a<\/p>\n\n\n\n![\"\"](\"https:\/\/eve2333.top\/wp-content\/uploads\/2025\/09\/1758357252-image-1024x237.png\")
<\/figure>\n\n\n\n\u6839\u636e\u6267\u884c\u8ba1\u5212\u5f97\u77e5\uff0c\u5b50\u67e5\u8be2\u67e5\u8be2\u662f\u7528\u5230\u4e86\u7d22\u5f15\u3002\u9996\u5148\u5728\u7d22\u5f15\u4e0a\u62ff\u5230\u4e86\u805a\u96c6\u7d22\u5f15\u7684\u4e3b\u952e ID \u7701\u53bb\u4e86\u56de\u8868\u64cd\u4f5c<\/strong>\uff0c\u7136\u540e\u7b2c\u4e8c\u67e5\u8be2\u76f4\u63a5\u6839\u636e\u7b2c\u4e00\u4e2a\u67e5\u8be2\u7684 ID \u5f80\u540e\u518d\u53bb\u67e5\u5c31\u53ef\u4ee5\u4e86\u3002<\/p>\n\n\n\n\u4f46\u662f\uff0c\u6709\u4e2a\u4e0d\u597d\u7684\u6d88\u606f\uff0c\u8fd9\u79cd\u65b9\u5f0f\u6027\u80fd\u5e76\u4e0d\u662f\u6052\u5b9a\u7684\uff0c\u5982\u679c\u6211\u4eec\u67e5\u8be2 100 \u4e07\u6570\u636e\u540e\u7684 10 \u6761\u8bb0\u5f55\uff0c\u6027\u80fd\u8981\u628a\u8fd9\u4e2a\u66f4\u5feb\u3002<\/p>\n\n\n\n
mysql> select * from t_coupon_task_fail where id >=\n ->\n -> (SELECT id\n -> FROM t_coupon_task_fail\n -> WHERE batch_id = '1830889785603571980'\n -> ORDER BY id\n -> LIMIT 999990, 1\n -> )\n ->\n -> limit 10;\n+---------+---------------------+--------------------------+\n| id | batch_id | json_object |\n+---------+---------------------+--------------------------+\n| 999991 | 1830889785603571980 | {\"key\": \"value_999991\"} |\n| 999992 | 1830889785603571980 | {\"key\": \"value_999992\"} |\n| 999993 | 1830889785603571980 | {\"key\": \"value_999993\"} |\n| 999994 | 1830889785603571980 | {\"key\": \"value_999994\"} |\n| 999995 | 1830889785603571980 | {\"key\": \"value_999995\"} |\n| 999996 | 1830889785603571980 | {\"key\": \"value_999996\"} |\n| 999997 | 1830889785603571980 | {\"key\": \"value_999997\"} |\n| 999998 | 1830889785603571980 | {\"key\": \"value_999998\"} |\n| 999999 | 1830889785603571980 | {\"key\": \"value_999999\"} |\n| 1000000 | 1830889785603571980 | {\"key\": \"value_1000000\"} |\n+---------+---------------------+--------------------------+\n10 rows in set (0.15 sec)<\/code><\/pre>\n\n\n\n\u53ef\u4ee5\u770b\u5230\uff0c\u67e5\u8be2 100 \u4e07\u6570\u636e\u4ec5\u9700\u8981 150 \u6beb\u79d2\u3002\u8fd9\u4e5f\u5c31\u610f\u5473\u7740\u5982\u679c\u6570\u636e\u91cf\u8d85\u8fc7 500 \u4e07\uff0c\u6027\u80fd\u4f1a\u4e0b\u964d\u7684\u66f4\u591a\uff0c\u6240\u4ee5\uff0c\u8fd9\u79cd\u6df1\u5206\u9875\u89e3\u51b3\u65b9\u6848\u5e76\u4e0d\u53ef\u53d6\u3002<\/p>\n\n\n\n
2. \u5ef6\u8fdf\u5173\u8054<\/h3>\n\n\n\n
\u65b0\u7684\u89e3\u51b3\u65b9\u6848\u53eb\u6cd5\u662f\u5ef6\u8fdf\u5173\u8054\uff0c\u5176\u5b9e\u672c\u8d28\u4e0a\u662f\u901a\u8fc7 JOIN \u5173\u8054\u7684\u5f62\u5f0f\u8fdb\u884c\u7ed1\u5b9a\uff0cSQL \u8bed\u53e5\u5982\u4e0b\u6240\u793a\uff1a<\/p>\n\n\n\n
mysql> SELECT\n -> t1.id,\n -> t1.batch_id,\n -> t1.json_object\n -> FROM\n -> t_coupon_task_fail t1\n -> INNER JOIN (\n -> SELECT\n -> id\n -> FROM\n -> t_coupon_task_fail\n -> WHERE\n -> batch_id = '1830889785603571980'\n -> ORDER BY\n -> id\n -> LIMIT 4999990,\n -> 10) AS t2 on t1.id = t2.id\n -> LIMIT 10;\n+---------+---------------------+--------------------------+\n| id | batch_id | json_object |\n+---------+---------------------+--------------------------+\n| 4999991 | 1830889785603571980 | {\"key\": \"value_999991\"} |\n| 4999992 | 1830889785603571980 | {\"key\": \"value_999992\"} |\n| 4999993 | 1830889785603571980 | {\"key\": \"value_999993\"} |\n| 4999994 | 1830889785603571980 | {\"key\": \"value_999994\"} |\n| 4999995 | 1830889785603571980 | {\"key\": \"value_999995\"} |\n| 4999996 | 1830889785603571980 | {\"key\": \"value_999996\"} |\n| 4999997 | 1830889785603571980 | {\"key\": \"value_999997\"} |\n| 4999998 | 1830889785603571980 | {\"key\": \"value_999998\"} |\n| 4999999 | 1830889785603571980 | {\"key\": \"value_999999\"} |\n| 5000000 | 1830889785603571980 | {\"key\": \"value_1000000\"} |\n+---------+---------------------+--------------------------+\n10 rows in set (0.52 sec)<\/code><\/pre>\n\n\n\n\u6027\u80fd\u5dee\u4e0d\u591a\u4e5f\u662f 500 \u6beb\u79d2\u5de6\u53f3\uff0c\u548c\u5b50\u67e5\u8be2\u4f18\u5316\u4e00\u6837\uff0c\u4f1a\u968f\u7740\u6570\u636e\u91cf\u7684\u589e\u591a\uff0c\u6027\u80fd\u4e5f\u4f1a\u4e0b\u964d\u3002<\/p>\n\n\n\n
\u6027\u80fd\u4f18\u5316\u601d\u8def\u4e0e\u5b50\u67e5\u8be2\u57fa\u672c\u4e00\u81f4\uff0c\u53ea\u4e0d\u8fc7\u91c7\u7528\u4e86 JOIN \u7684\u5f62\u5f0f\u6267\u884c SQL\u3002<\/p>\n\n\n\n![\"\"](\"https:\/\/eve2333.top\/wp-content\/uploads\/2025\/09\/1758357180-image-1024x358.png\")
<\/figure>\n\n\n\n3. \u4e66\u7b7e\u8bb0\u5f55<\/h3>\n\n\n\n
\u4e0a\u9762\u7684\u4e24\u79cd\u65b9\u5f0f\u5176\u5b9e\u89e3\u51b3\u6df1\u5206\u9875\u7684\u601d\u8def\u662f\u4e00\u81f4\u7684\uff0c\u63a5\u4e0b\u6765\u8981\u8bf4\u7684\u4e66\u7b7e\u8bb0\u5f55\u7684\u65b9\u5f0f\u53ef\u4ee5\u8bf4\u662f\u6027\u80fd\u6700\u5f3a\u7684\u3002<\/p>\n\n\n\n
\u4e66\u7b7e\u8bb0\u5f55\u53eb\u8d77\u6765\u6709\u70b9\u7ed5\uff0c\u5f88\u591a\u540c\u5b66\u4e0d\u80fd\u7b2c\u4e00\u65f6\u95f4\u77e5\u9053\u662f\u4ec0\u4e48\uff0c\u4ece\u539f\u7406\u4e0a\u8bf4\uff0c\u5c5e\u4e8e\u662f\u4e00\u79cd\u6eda\u52a8\u67e5\u8be2\u3002\u4e5f\u5c31\u662f\u8bf4\u6211\u4eec\u5fc5\u987b\u4ece\u7b2c\u4e00\u9875\u5f00\u59cb\u67e5\u8be2\uff0c\u7136\u540e\u83b7\u53d6\u672c\u9875\u6700\u5927\u7684\u8bb0\u5f55 ID\uff0c\u7136\u540e\u518d\u6839\u636e\u5927\u4e8e\u6700\u5927\u8bb0\u5f55 ID \u7684\u6570\u636e\u5411\u540e\u6301\u7eed\u6eda\u52a8\u3002\u4e5f\u5c31\u662f\u8bf4\uff0c\u6211\u4eec\u5982\u679c\u60f3\u67e5\u8be2\u5927\u4e8e 4999990 \u540e\u8bb0\u5f55\u7684 10 \u6761\uff0c\u90a3\u6211\u4eec\u5c31\u5f97\u77e5\u9053 4999990 \u6761\u7684 ID\u3002\u56e0\u4e3a\u6211\u4eec ID \u662f\u9012\u589e\u7684\uff0c\u6240\u4ee5\u76f4\u63a5\u67e5\u8be2\u5373\u53ef\u3002<\/p>\n\n\n\n
mysql> SELECT\n -> *\n -> FROM\n -> t_coupon_task_fail\n -> WHERE\n -> batch_id = '1830889785603571980'\n -> AND id > 4999990\n -> LIMIT 10;\n+---------+---------------------+--------------------------+\n| id | batch_id | json_object |\n+---------+---------------------+--------------------------+\n| 4999991 | 1830889785603571980 | {\"key\": \"value_999991\"} |\n| 4999992 | 1830889785603571980 | {\"key\": \"value_999992\"} |\n| 4999993 | 1830889785603571980 | {\"key\": \"value_999993\"} |\n| 4999994 | 1830889785603571980 | {\"key\": \"value_999994\"} |\n| 4999995 | 1830889785603571980 | {\"key\": \"value_999995\"} |\n| 4999996 | 1830889785603571980 | {\"key\": \"value_999996\"} |\n| 4999997 | 1830889785603571980 | {\"key\": \"value_999997\"} |\n| 4999998 | 1830889785603571980 | {\"key\": \"value_999998\"} |\n| 4999999 | 1830889785603571980 | {\"key\": \"value_999999\"} |\n| 5000000 | 1830889785603571980 | {\"key\": \"value_1000000\"} |\n+---------+---------------------+--------------------------+\n10 rows in set (0.00 sec)<\/code><\/pre>\n\n\n\n\u53ef\u4ee5\u770b\u5230\uff0c\u6211\u4eec\u7684\u8bb0\u5f55\u7edf\u8ba1\u6700\u5c0f\u65f6\u95f4\u662f\u79d2\uff0c\u4f46\u662f\u6267\u884c\u65f6\u95f4\u4e00\u4f46\u662f\u5fae\u79d2\uff08\u00b5s\uff09\u5c31\u6ca1\u529e\u6cd5\u663e\u793a\u4e86\uff0c\u6211\u901a\u8fc7\u6570\u636e\u5e93\u53ef\u89c6\u5316\u5de5\u5177\u770b\u4e86\u4e0b\uff0c\u5927\u6982\u662f 500 \u5fae\u79d2\u5de6\u53f3\u3002<\/p>\n\n\n\n
\u8fd9\u4e2a\u65f6\u5019\u518d\u7ed9\u5927\u5bb6\u5e26\u6765\u4e00\u4e2a\u95ee\u9898\uff0c\u5982\u679c\u6570\u636e\u91cf\u5728\u51e0\u5343\u4e07\u7ea7\u522b\uff0c\u5b83\u8fd8\u80fd\u4fdd\u8bc1\u5fae\u5999\u7ea7\u522b\u7684\u67e5\u8be2\u4e48\uff1f\u6211\u4eec\u4fee\u6539\u4e0b\u5b58\u50a8\u8fc7\u7a0b\uff0c\u9020\u5927\u6982 4000 \u4e07\u6570\u636e\u8bd5\u8bd5\u3002<\/p>\n\n\n\n
mysql> select count(*) from t_coupon_task_fail;\n+----------+\n| count(*) |\n+----------+\n| 40000000 |\n+----------+\n1 row in set (3.12 sec)\n\nmysql> SELECT\n -> *\n -> FROM\n -> t_coupon_task_fail\n -> WHERE\n -> batch_id = '1830889785603571980'\n -> AND id > 39999990\n -> LIMIT 10;\n+----------+---------------------+---------------------------+\n| id | batch_id | json_object |\n+----------+---------------------+---------------------------+\n| 39999991 | 1830889785603571980 | {\"key\": \"value_19999991\"} |\n| 39999992 | 1830889785603571980 | {\"key\": \"value_19999992\"} |\n| 39999993 | 1830889785603571980 | {\"key\": \"value_19999993\"} |\n| 39999994 | 1830889785603571980 | {\"key\": \"value_19999994\"} |\n| 39999995 | 1830889785603571980 | {\"key\": \"value_19999995\"} |\n| 39999996 | 1830889785603571980 | {\"key\": \"value_19999996\"} |\n| 39999997 | 1830889785603571980 | {\"key\": \"value_19999997\"} |\n| 39999998 | 1830889785603571980 | {\"key\": \"value_19999998\"} |\n| 39999999 | 1830889785603571980 | {\"key\": \"value_19999999\"} |\n| 40000000 | 1830889785603571980 | {\"key\": \"value_20000000\"} |\n+----------+---------------------+---------------------------+\n10 rows in set (0.00 sec)<\/code><\/pre>\n\n\n\n\u53ef\u4ee5\u770b\u5230\u6211\u4eec\u67e5\u8be2 4000 \u4e07\u8bb0\u5f55\uff0c\u6027\u80fd\u4f9d\u65e7\u662f\u5fae\u5999\u7ea7\uff0c\u57fa\u672c\u4e0a\u53ef\u4ee5\u8ba4\u5b9a\u8fd9\u4e2a\u6027\u80fd\u662f\u6052\u5b9a\u7684\u3002<\/p>\n\n\n\n
\u4f46\u662f\u8fd9\u4e2a\u6709\u70b9\u4e0d\u597d\u7684\u5730\u65b9\u5728\u4e8e\uff0c\u4e0d\u652f\u6301\u8df3\u9875\uff0c\u53ea\u80fd\u4e0a\u4e00\u9875\u548c\u4e0b\u4e00\u9875\u3002\u4e0d\u8fc7\u5bf9\u6211\u4eec\u7cfb\u7edf\u6765\u8bf4\u65e0\u6240\u8c13\uff0c\u53cd\u6b63\u662f\u8bfb\u53d6\u6240\u6709\u5931\u8d25\u5206\u53d1\u7684\u8bb0\u5f55\u751f\u6210 Excel \u5c31\u597d\u3002<\/p>\n\n\n\n
\u5206\u53d1\u5931\u8d25\u8bb0\u5f55\u751f\u6210 Excel<\/h2>\n\n\n\n
\u6211\u4eec\u5728 Excel \u89e3\u6790\u5b8c\u6210\u540e\u53d1\u9001\u7684\u6d88\u606f\u961f\u5217\u6d88\u8d39\u8005\u91cc\uff0c\u5c06\u5206\u53d1\u5931\u8d25\u6570\u636e\u4ee5\u4e66\u7b7e\u8bb0\u5f55\u7684\u5f62\u5f0f\u8bfb\u53d6\u5230\uff0c\u7136\u540e\u5c01\u88c5\u4e3a\u65b0\u7684\u5931\u8d25 Excel\uff0c\u5e76\u5c06\u5730\u5740\u4fdd\u5b58\u5230\u5206\u53d1\u4efb\u52a1\u8bb0\u5f55\u4e2d\u3002<\/p>\n\n\n\n
@Transactional(rollbackFor = Exception.class)\n@Override\npublic void onMessage(MessageWrapper<CouponTemplateDistributionEvent> messageWrapper) {\n \/\/ ......\n \/\/ \u8fd9\u91cc\u662f\u5206\u53d1\u4efb\u52a1\u7ed3\u675f\u6807\u8bc6\u4e3a TRUE\uff0c\u4ee3\u8868\u5df2\u7ecf\u6ca1\u6709 Excel \u8bb0\u5f55\n long initId = 0;\n boolean isFirstIteration = true; \/\/ \u7528\u4e8e\u6807\u8bc6\u662f\u5426\u4e3a\u7b2c\u4e00\u6b21\u8fed\u4ee3\n String failFileAddress = excelPath + \"\/\u7528\u6237\u5206\u53d1\u8bb0\u5f55\u5931\u8d25Excel-\" + event.getCouponTaskBatchId() + \".xlsx\";\n\n \/\/ \u8fd9\u91cc\u5e94\u8be5\u4e0a\u4f20\u4e91 OSS \u6216\u8005 MinIO \u7b49\u5b58\u50a8\u5e73\u53f0\uff0c\u4f46\u662f\u589e\u52a0\u90e8\u7f72\u6210\u529f\u5e76\u4e14\u4e0d\u592a\u597d\u5f80\u7b80\u5386\u5199\u5c31\u4ec5\u5199\u5165\u672c\u5730\n try (ExcelWriter excelWriter = EasyExcel.write(failFileAddress, UserCouponTaskFailExcelObject.class).build()) {\n WriteSheet writeSheet = EasyExcel.writerSheet(\"\u7528\u6237\u5206\u53d1\u5931\u8d25Sheet\").build();\n while (true) {\n List<CouponTaskFailDO> couponTaskFailDOList = listUserCouponTaskFail(event.getCouponTaskBatchId(), initId);\n if (CollUtil.isEmpty(couponTaskFailDOList)) {\n \/\/ \u5982\u679c\u662f\u7b2c\u4e00\u6b21\u8fed\u4ee3\u4e14\u96c6\u5408\u4e3a\u7a7a\uff0c\u5219\u8bbe\u7f6e failFileAddress \u4e3a null\n if (isFirstIteration) {\n failFileAddress = null;\n }\n break;\n }\n\n \/\/ \u6807\u8bb0\u7b2c\u4e00\u6b21\u8fed\u4ee3\u5df2\u7ecf\u5b8c\u6210\n isFirstIteration = false;\n\n \/\/ \u5c06\u5931\u8d25\u884c\u6570\u548c\u5931\u8d25\u539f\u56e0\u5199\u5165 Excel \u6587\u4ef6\n List<UserCouponTaskFailExcelObject> excelDataList = couponTaskFailDOList.stream()\n .map(each -> JSONObject.parseObject(each.getJsonObject(), UserCouponTaskFailExcelObject.class))\n .toList();\n excelWriter.write(excelDataList, writeSheet);\n\n \/\/ \u67e5\u8be2\u51fa\u6765\u7684\u6570\u636e\u5982\u679c\u5c0f\u4e8e BATCH_USER_COUPON_SIZE \u610f\u5473\u7740\u540e\u9762\u5c06\u4e0d\u518d\u6709\u6570\u636e\uff0c\u8fd4\u56de\u5373\u53ef\n if (couponTaskFailDOList.size() < BATCH_USER_COUPON_SIZE) {\n break;\n }\n\n \/\/ \u66f4\u65b0 initId \u4e3a\u5f53\u524d\u5217\u8868\u4e2d\u6700\u5927 ID\n initId = couponTaskFailDOList.stream()\n .mapToLong(CouponTaskFailDO::getId)\n .max()\n .orElse(initId);\n }\n }\n\n \/\/ \u786e\u4fdd\u6240\u6709\u7528\u6237\u90fd\u5df2\u7ecf\u63a5\u5230\u4f18\u60e0\u5238\u540e\uff0c\u8bbe\u7f6e\u4f18\u60e0\u5238\u63a8\u9001\u4efb\u52a1\u5b8c\u6210\u65f6\u95f4\n CouponTaskDO couponTaskDO = CouponTaskDO.builder()\n .id(event.getCouponTaskId())\n .status(CouponTaskStatusEnum.SUCCESS.getStatus())\n .completionTime(new Date())\n .failFileAddress(failFileAddress)\n .build();\n couponTaskMapper.updateById(couponTaskDO);\n}\n\n\/**\n * \u67e5\u8be2\u7528\u6237\u5206\u53d1\u4efb\u52a1\u5931\u8d25\u8bb0\u5f55\n *\n * @param batchId \u5206\u53d1\u4efb\u52a1\u6279\u6b21 ID\n * @param maxId \u4e0a\u6b21\u8bfb\u53d6\u6700\u5927 ID\n * @return \u7528\u6237\u5206\u53d1\u4efb\u52a1\u5931\u8d25\u8bb0\u5f55\u96c6\u5408\n *\/\nprivate List<CouponTaskFailDO> listUserCouponTaskFail(Long batchId, Long maxId) {\n LambdaQueryWrapper<CouponTaskFailDO> queryWrapper = Wrappers.lambdaQuery(CouponTaskFailDO.class)\n .eq(CouponTaskFailDO::getBatchId, batchId)\n .gt(CouponTaskFailDO::getId, maxId)\n .last(\"LIMIT \" + BATCH_USER_COUPON_SIZE);\n return couponTaskFailMapper.selectList(queryWrapper);\n}<\/code><\/pre>\n\n\n\n\u53ef\u80fd\u6709\u540c\u5b66\u6709\u7591\u95ee\uff0c\u5728\u4e0d\u67e5\u8be2\u662f\u5426\u6709\u5206\u53d1\u5931\u8d25\u8bb0\u5f55\u7684\u65f6\u5019\u5c31\u521b\u5efa EasyExcel \u5bf9\u8c61\uff0c\u662f\u5426\u6709\u95ee\u9898\uff1f<\/p>\n\n\n\n
\u5176\u5b9e\u4e0d\u4f1a\u7684\uff0c\u53ea\u6709\u5728\u7b2c\u4e00\u6b21\u8c03\u7528 excelWriter.write(xx, xx)<\/code> \u65b9\u6cd5\u624d\u4f1a\u521b\u5efa Excel \u6587\u4ef6\uff0c\u6240\u4ee5\u4e0d\u7528\u62c5\u5fc3\u521b\u5efa\u7a7a\u8bb0\u5f55 Excel \u6587\u4ef6\u3002\u5982\u679c\u5199\u5165 Excel \u6587\u4ef6\u6210\u529f\u540e\uff0c\u5c31\u80fd\u5728\u725b\u5238\u6839\u76ee\u5f55 \/tmp \u6587\u4ef6\u5939\u4e0b\u770b\u5230\u6211\u4eec\u7684\u8bb0\u5f55\u3002<\/p>\n\n\n\n\u2514\u2500\u2500 tmp\n \u251c\u2500\u2500 oneCoupon\u4efb\u52a1\u63a8\u9001Excel.xlsx\n \u251c\u2500\u2500 \u7528\u6237\u5206\u53d1\u8bb0\u5f55\u5931\u8d25Excel-1831284632528740352.xlsx<\/code><\/pre>\n\n\n\n\u6211\u4eec\u53ef\u4ee5\u770b\u5230\u751f\u6210\u7684 Excel \u6587\u4ef6\u5185\u5bb9\u5982\u4e0b\u6240\u793a\uff1a<\/p>\n\n\n\n\n![\"\"](\"https:\/\/oss.open8gu.com\/image-20240904222349112.png\" "\\"\\"\/")
<\/figure>\n<\/figure>\n\n\n\n\u6587\u672b\u603b\u7ed3<\/h2>\n\n\n\n
\u6587\u7ae0\u4ecb\u7ecd\u4e86\u6df1\u5206\u9875\u7684\u4e1a\u52a1\u573a\u666f\uff0c\u540c\u65f6\u5462\u4ecb\u7ecd\u4e09\u79cd\u6df1\u5206\u9875\u7684\u89e3\u51b3\u65b9\u6848\uff0c\u5176\u4e2d\u4e66\u7b7e\u8bb0\u5f55\u7684\u65b9\u5f0f\u5728\u5e94\u5bf9\u6df1\u5206\u9875\u573a\u666f\u4e0b\u6027\u80fd\u6700\u9ad8\uff0c\u5728\u6a21\u62df\u7684 4000 \u4e07\u884c\u8bb0\u5f55\u4e2d\u4f9d\u7136\u80fd\u591f\u4fdd\u6301\u5fae\u79d2\u67e5\u8be2\u6027\u80fd\u3002\u6700\u540e\u5c06\u5206\u53d1\u5931\u8d25\u7684\u7528\u6237\u9886\u5238\u8bb0\u5f55\u4fdd\u5b58\u5230\u4e86 Excel \u4e2d\uff0c\u5e76\u8d4b\u503c\u5230\u4f18\u60e0\u5238\u6a21\u677f\u5206\u53d1\u8bb0\u5f55\u4efb\u52a1\u4e2d\u3002<\/p>\n\n\n\n
\u5b8c\u7ed3\uff0c\u6492\u82b1 \ud83c\udf89<\/p>\n\n\n\n
\u4e0d\u652f\u6301\u8df3\u9875\uff1a\u4e0d\u80fd\u83b7\u5f97\u6307\u5b9a\u9875\u7684\u6570\u636e\uff0c\u56e0\u4e3a\u67e5\u8be2\u7b2cn\u9875\u9700\u8981\u7b2cn+1\u6216\u8005\u7b2cn-1\u9875\u7684\u6570\u636e<\/p>\n\n\n\n
\u4e2a\u4eba\u8ba4\u4e3a\u8fd9\u91cc\u8fd8\u662f\u6a21\u62df\u4e86\u4e00\u4e2a\u573a\u666f\u6765\u8bb2\u89e3\u6df1\u5206\u9875\u95ee\u9898\uff0c\u5b9e\u9645\u4e0a\u8fd9\u79cd\u6781\u7aef\u573a\u666f\u5f88\u96be\u89c1\u5230\u3002\u5728\u9a6c\u4e01\u54e5\u7684\u793a\u4f8b\u4e2d\uff0c\u662f\u5148\u6307\u5b9abatchId\uff08\u5206\u53d1\u4efb\u52a1\u6279\u6b21ID\uff09\uff0c\u518d\u67e5\u8be2\u5931\u8d25\u6570\u636e\u3002\u4ece\u4e1a\u52a1\u4e0a\u770b\uff0c\u6bcf\u4e00\u6b21\u5206\u53d1\u4efb\u52a1\u7684\u6279\u6b21ID\u90fd\u662f\u4e0d\u540c\uff0c\u4e0d\u53ef\u80fd\u4e0a\u4e00\u6b21\u5206\u53d1\u4efb\u52a1\u7684\u6279\u6b21ID\u662f49001\uff0c\u8fc7\u4e86\u4e24\u4e2a\u6708\u53c8\u6709\u4e00\u4e2a49001\u7684\u6279\u6b21ID\u3002\u800c\u8981\u5728\u4e00\u6b21\u5206\u53d1\u4efb\u52a1\u4e2d\uff0c\u8fbe\u52304000w\u7684\u5931\u8d25\u6570\u91cf\uff0c\u90a3\u5408\u7406\u53cd\u63a8\u6709\u53ef\u80fd\u662f\u5f53\u6b21\u5206\u53d1\u5168\u90e8\u5931\u8d25\u4e86\uff0c\u8fd9\u79cd\u4e1a\u52a1\u573a\u666f\u4e0d\u597d\u89c1\u5230\u7684\u5427<\/p>\n\n\n\n
\u672c\u8282\u60f3\u8868\u8fbe\u7684\u610f\u601d\u6ca1\u592a\u770b\u61c2\uff0c\u770b\u4e0b\u6765\u662f\u672c\u9879\u76ee\u662f\u9009\u7528\u4fdd\u5b58Excel\u7684\u65b9\u6848\uff0c\u90a3\u5c31\u6ca1\u6709\u6df1\u5206\u9875\u7684\u95ee\u9898\u5427\uff1f\u5982\u679c\u662f\u9009\u7528\u6570\u636e\u5e93\u6301\u4e45\u5316\u7684\u65b9\u6848\uff0c\u6587\u4e2d\u4e5f\u8bf4\u4e86\uff0c\u5931\u8d25\u7684\u573a\u666f\u5e76\u4e0d\u5e38\u89c1\uff0c\u6df1\u5206\u9875\u5728\u8fd9\u6709\u70b9\u5927\u6750\u5c0f\u7528\u3002\u611f\u89c9\u8fd9\u91cc\u66f4\u591a\u7684\u662f\u8ba9\u540c\u5b66\u4eec\u4e86\u89e3\u4e00\u4e0b\u6df1\u5206\u9875\u7684\u4e00\u4e9b\u5e38\u89c1\u7684\u89e3\u51b3\u65b9\u6848\uff0c\u5982\u679c\u60f3\u8ddf\u9762\u8bd5\u5b98\u804a\u9879\u76ee\u4e2d\u662f\u5426\u9047\u5230\u6df1\u5206\u9875\u95ee\u9898\uff0c\u6700\u597d\u4e0d\u8981\u4e3e\u8fd9\u4e2a\u4f8b\u5b50\u3002<\/p>\n\n\n\n
\u7b2c22\u5c0f\u8282\uff1a\u57fa\u4e8e\u6ce8\u89e3\u5b9e\u73b0\u53bb\u91cd\u8868\u6d88\u606f\u9632\u6b62\u91cd\u590d\u6d88\u8d39<\/h2>\n\n\n\n\u4e1a\u52a1\u80cc\u666f<\/h2>\n\n\n\n
\u5f53\u4f7f\u7528\u6d88\u606f\u961f\u5217\u65f6\uff0c\u5ba2\u6237\u7aef\u91cd\u590d\u6d88\u8d39\u53ef\u80fd\u4f1a\u6210\u4e3a\u4e00\u4e2a\u4e25\u91cd\u7684\u95ee\u9898\u3002<\/p>\n\n\n\n
\u8fd9\u662f\u56e0\u4e3a\u6d88\u606f\u961f\u5217\u5177\u6709\u6301\u4e45\u6027\u548c\u53ef\u9760\u6027\u7684\u7279\u6027\uff0c\u786e\u4fdd\u6d88\u606f\u80fd\u591f\u88ab\u6210\u529f\u4f20\u9012\u7ed9\u6d88\u8d39\u8005\u3002\u7136\u800c\uff0c\u8fd9\u4e5f\u4f1a\u5bfc\u81f4\u5ba2\u6237\u7aef\u5728\u67d0\u4e9b\u60c5\u51b5\u4e0b\u91cd\u590d\u6d88\u8d39\u6d88\u606f\uff0c\u4f8b\u5982\u7f51\u7edc\u6545\u969c\uff08\u6216\u5ef6\u8fdf\uff09\u3001\u5ba2\u6237\u7aef\u5d29\u6e83\u3001\u6d88\u606f\u5904\u7406\u5931\u8d25\u7b49\u60c5\u51b5\u3002<\/p>\n\n\n\n
\u4e3a\u4e86\u907f\u514d\u8fd9\u79cd\u60c5\u51b5\u53d1\u751f\uff0c\u9700\u8981\u5728\u5ba2\u6237\u7aef\u5b9e\u73b0\u4e00\u4e9b\u673a\u5236\u6765\u786e\u4fdd\u6d88\u606f\u4e0d\u4f1a\u88ab\u91cd\u590d\u6d88\u8d39\uff0c\u4f8b\u5982\u8bb0\u5f55\u6d88\u8d39\u8005\u5df2\u7ecf\u5904\u7406\u7684\u6d88\u606f ID\u3001\u4f7f\u7528\u5206\u5e03\u5f0f\u9501\u6765\u63a7\u5236\u6d88\u8d39\u8fdb\u7a0b\u7684\u552f\u4e00\u6027\u7b49\u3002\u8fd9\u4e9b\u673a\u5236\u80fd\u591f\u4fdd\u8bc1\u6d88\u606f\u88ab\u6210\u529f\u5904\u7406\uff0c\u540c\u65f6\u4e5f\u80fd\u591f\u63d0\u9ad8\u7cfb\u7edf\u7684\u53ef\u9760\u6027\u548c\u7a33\u5b9a\u6027\u3002\u672c\u5c0f\u8282\u5c06\u63a2\u8ba8\u5982\u4f55\u786e\u4fdd\u6d88\u606f\u961f\u5217\u4e2d\u7684\u6d88\u606f\u4e0d\u4f1a\u88ab\u91cd\u590d\u6d88\u8d39\uff0c\u4e0b\u6587\u5c06\u4ee5 RocketMQ \u4e3a\u4f8b\u8bf4\u660e\u3002<\/p>\n\n\n\n
\u6d88\u606f\u5e42\u7b49\u6027<\/h2>\n\n\n\n
\u5728\u4f7f\u7528\u6d88\u606f\u961f\u5217 RocketMQ \u5b9e\u73b0\u5f02\u6b65\u5316\u3001\u89e3\u8026\u3001\u524a\u5cf0\u7b49\u529f\u80fd\u7684\u60c5\u51b5\u4e0b\uff0c\u6211\u4eec\u8ba4\u4e3a\u6d88\u606f\u4e2d\u95f4\u4ef6\u662f\u4e00\u4e2a\u53ef\u9760\u7684\u7ec4\u4ef6\uff0c\u8fd9\u91cc\u7684\u53ef\u9760\u6027\u6307\u7684\u662f\uff0c\u53ea\u8981\u6d88\u606f\u88ab\u6210\u529f\u6295\u9012\u5230\u4e86\u6d88\u606f\u4e2d\u95f4\u4ef6\uff0c\u5b83\u5c31\u4e0d\u4f1a\u4e22\u5931\uff0c\u81f3\u5c11\u80fd\u591f\u88ab\u6d88\u8d39\u8005\u6210\u529f\u6d88\u8d39\u4e00\u6b21\u3002\u8fd9\u662f\u6d88\u606f\u4e2d\u95f4\u4ef6\u6700\u57fa\u672c\u7684\u7279\u6027\u4e4b\u4e00\uff0c\u4e5f\u5c31\u662f\u6211\u4eec\u901a\u5e38\u6240\u8bf4\u7684 \u201cAT LEAST ONCE\u201d<\/strong>\uff0c\u5373\u6d88\u606f\u81f3\u5c11\u4f1a\u88ab\u6210\u529f\u6d88\u8d39\u4e00\u904d\u3002<\/p>\n\n\n\n\u4e3e\u4e2a\u4f8b\u5b50\uff0c\u5047\u8bbe\u4e00\u4e2a\u6d88\u606f M \u88ab\u53d1\u9001\u5230\u6d88\u606f\u4e2d\u95f4\u4ef6\u5e76\u88ab\u6d88\u8d39\u7a0b\u5e8f A \u63a5\u6536\u5230\uff0cA \u5f00\u59cb\u6d88\u8d39\u8fd9\u4e2a\u6d88\u606f\uff0c\u4f46\u662f\u5728\u6d88\u8d39\u8fc7\u7a0b\u4e2d\u7a0b\u5e8f\u91cd\u542f\u4e86\u3002\u7531\u4e8e\u8fd9\u4e2a\u6d88\u606f\u6ca1\u6709\u88ab\u6807\u8bb0\u4e3a\u5df2\u7ecf\u88ab\u6d88\u8d39\u6210\u529f\uff0c\u6d88\u606f\u4e2d\u95f4\u4ef6\u4f1a\u6301\u7eed\u5730\u5c06\u8fd9\u4e2a\u6d88\u606f\u6295\u9012\u7ed9\u6d88\u8d39\u8005\uff0c\u76f4\u5230\u6d88\u606f\u88ab\u6210\u529f\u6d88\u8d39\u4e3a\u6b62\u3002<\/p>\n\n\n\n
\u7136\u800c\uff0c\u8fd9\u79cd\u53ef\u9760\u6027\u7279\u6027\u4e5f\u4f1a\u5bfc\u81f4\u6d88\u606f\u88ab\u591a\u6b21\u6295\u9012\u7684\u60c5\u51b5\u3002\u4e3e\u4e2a\u4f8b\u5b50\uff0c\u4ecd\u7136\u4ee5\u4e4b\u524d\u7684\u4f8b\u5b50\u4e3a\u4f8b\uff0c\u5982\u679c\u6d88\u8d39\u7a0b\u5e8f A \u63a5\u6536\u5e76\u5b8c\u6210\u6d88\u606f M \u7684\u6d88\u8d39\u903b\u8f91\u540e\uff0c\u6b63\u51c6\u5907\u901a\u77e5\u6d88\u606f\u4e2d\u95f4\u4ef6\u201c\u6211\u5df2\u7ecf\u6d88\u8d39\u6210\u529f\u4e86\u201d\uff0c\u4f46\u5728\u6b64\u4e4b\u524d\u7a0b\u5e8fA\u53c8\u91cd\u542f\u4e86\uff0c\u90a3\u4e48\u5bf9\u4e8e\u6d88\u606f\u4e2d\u95f4\u4ef6\u6765\u8bf4\uff0c\u8fd9\u4e2a\u6d88\u606f M \u5e76\u6ca1\u6709\u88ab\u6210\u529f\u6d88\u8d39\u8fc7\uff0c\u56e0\u6b64\u6d88\u606f\u4e2d\u95f4\u4ef6\u4f1a\u7ee7\u7eed\u6295\u9012\u8fd9\u4e2a\u6d88\u606f\u3002\u800c\u5bf9\u4e8e\u6d88\u8d39\u7a0b\u5e8fA\u6765\u8bf4\uff0c\u5c3d\u7ba1\u5b83\u5df2\u7ecf\u6210\u529f\u6d88\u8d39\u4e86\u8fd9\u4e2a\u6d88\u606f\uff0c\u4f46\u7531\u4e8e\u7a0b\u5e8f\u91cd\u542f\u5bfc\u81f4\u6d88\u606f\u4e2d\u95f4\u4ef6\u7ee7\u7eed\u6295\u9012\uff0c\u770b\u8d77\u6765\u5c31\u597d\u50cf\u8fd9\u4e2a\u6d88\u606f\u8fd8\u6ca1\u6709\u88ab\u6210\u529f\u6d88\u8d39\u8fc7\u4e00\u6837\u3002<\/p>\n\n\n\n
\u5728 RockectMQ \u7684\u573a\u666f\u4e2d\uff0c\u8fd9\u610f\u5473\u7740\u540c\u4e00\u4e2a messageId \u7684\u6d88\u606f\u4f1a\u88ab\u91cd\u590d\u6295\u9012\u3002\u7531\u4e8e\u6d88\u606f\u7684\u53ef\u9760\u6295\u9012\u662f\u66f4\u91cd\u8981\u7684\uff0c\u6240\u4ee5\u907f\u514d\u6d88\u606f\u91cd\u590d\u6295\u9012\u7684\u4efb\u52a1\u8f6c\u79fb\u7ed9\u4e86\u5e94\u7528\u7a0b\u5e8f\u81ea\u8eab\u6765\u5b9e\u73b0\u3002\u8fd9\u4e5f\u662f RocketMQ \u6587\u6863\u5f3a\u8c03\u6d88\u8d39\u903b\u8f91\u9700\u8981\u81ea\u884c\u5b9e\u73b0\u5e42\u7b49\u6027\u7684\u539f\u56e0\u3002\u5b9e\u9645\u4e0a\uff0c\u8fd9\u80cc\u540e\u7684\u903b\u8f91\u662f\uff1a\u5728\u5206\u5e03\u5f0f\u573a\u666f\u4e0b\uff0c\u4fdd\u8bc1\u6d88\u606f\u4e0d\u4e22\u548c\u907f\u514d\u6d88\u606f\u91cd\u590d\u6295\u9012\u662f\u77db\u76fe\u7684\uff0c\u4f46\u662f\u6d88\u606f\u91cd\u590d\u6295\u9012\u662f\u53ef\u4ee5\u89e3\u51b3\u7684\uff0c\u800c\u6d88\u606f\u4e22\u5931\u5219\u975e\u5e38\u9ebb\u70e6\u3002<\/p>\n\n\n\n
Git \u5206\u652f<\/h2>\n\n\n\n
20240905_dev_coupon-distribute-v4_idempotent_ding.ma<\/p>\n\n\n\n
\u5e42\u7b49\u8bbe\u8ba1<\/h2>\n\n\n\n
\u4e0b\u8ff0\u65b9\u6848\u7684\u4f18\u70b9\u5728\u4e8e\uff0c\u4f7f\u7528 Redis \u6d88\u606f\u53bb\u91cd\u8868\uff0c\u4e0d\u4f9d\u8d56\u4e8b\u52a1\uff0c\u9488\u5bf9\u6d88\u606f\u8868\u672c\u8eab\u505a\u4e86\u72b6\u6001\u7684\u533a\u5206\uff1a\u6d88\u8d39\u4e2d\u3001\u6d88\u8d39\u5b8c\u6210\u3002<\/p>\n\n\n\n
\u5982\u679c\u6d88\u606f\u5df2\u7ecf\u5728\u6d88\u8d39\u4e2d\uff0c\u629b\u51fa\u5f02\u5e38\uff0c\u6d88\u606f\u4f1a\u89e6\u53d1\u5ef6\u8fdf\u6d88\u8d39\uff0c\u5728 RocketMQ \u7684\u573a\u666f\u4e0b\u5982\u679c\u6d88\u606f\u6d88\u8d39\u5931\u8d25\uff0c\u4f1a\u95f4\u9694\u65f6\u95f4\u540e\u518d\u6b21\u53d1\u8d77\u6d88\u8d39\u6d41\u7a0b\u3002<\/p>\n\n\n\n![\"\"](\"https:\/\/oss.open8gu.com\/image-20240905220757945.png\" "\\"\\"\/")
<\/figure>\n\n\n\n\u901a\u8fc7\u8be5\u65b9\u6848\u53ef\u4ee5\u89e3\u51b3\u4ec0\u4e48\u95ee\u9898\uff1f<\/p>\n\n\n\n
\n- 1.\u6d88\u606f\u5df2\u7ecf\u6d88\u8d39\u6210\u529f\u4e86\uff0c\u7b2c\u4e8c\u6761\u6d88\u606f\u5c06\u88ab\u76f4\u63a5\u5e42\u7b49\u5904\u7406\u6389\uff08\u6d88\u8d39\u6210\u529f\uff09\u3002<\/li>\n\n\n\n
- 2.\u5e76\u53d1\u573a\u666f\u4e0b\u7684\u6d88\u606f\uff0c\u4f9d\u65e7\u80fd\u6ee1\u8db3\u4e0d\u4f1a\u51fa\u73b0\u6d88\u606f\u91cd\u590d\uff0c\u5373\u7a7f\u900f\u5e42\u7b49\u6321\u677f\u7684\u95ee\u9898\u3002<\/li>\n\n\n\n
- 3.\u652f\u6301\u4e0a\u6e38\u4e1a\u52a1\u751f\u4ea7\u8005\u91cd\u53d1\u7684\u4e1a\u52a1\u91cd\u590d\u7684\u6d88\u606f\u5e42\u7b49\u95ee\u9898\u3002<\/li>\n<\/ol>\n\n\n\n
\u4e3a\u4ec0\u4e48\u8981\u7ed9\u521d\u59cb\u5316\u7684\u5e42\u7b49\u6807\u8bc6\u65b0\u589e 10 \u5206\u949f\u8fc7\u671f\u65f6\u95f4\uff1f<\/p>\n\n\n\n
\u5728\u5e76\u53d1\u573a\u666f\u4e0b\uff0c\u6211\u4eec\u4f7f\u7528\u6d88\u606f\u72b6\u6001\u6765\u5b9e\u73b0\u5e76\u53d1\u63a7\u5236\uff0c\u4ee5\u4f7f\u7b2c\u4e8c\u6761\u6d88\u606f\u88ab\u4e0d\u65ad\u5ef6\u8fdf\u6d88\u8d39\uff08\u5373\u91cd\u8bd5\uff09\u3002\u4f46\u5982\u679c\u5728\u6b64\u671f\u95f4\u7b2c\u4e00\u6761\u6d88\u606f\u4e5f\u56e0\u67d0\u4e9b\u5f02\u5e38\u539f\u56e0\uff08\u4f8b\u5982\u673a\u5668\u91cd\u542f\u6216\u5916\u90e8\u5f02\u5e38\uff09\u672a\u6210\u529f\u6d88\u8d39\uff0c\u8be5\u600e\u4e48\u529e\u5462\uff1f\u56e0\u4e3a\u6bcf\u6b21\u67e5\u8be2\u65f6\u90fd\u4f1a\u663e\u793a\u6d88\u8d39\u4e2d\u7684\u72b6\u6001\uff0c\u6240\u4ee5\u5ef6\u8fdf\u6d88\u8d39\u4f1a\u4e00\u76f4\u8fdb\u884c\u4e0b\u53bb\uff0c\u76f4\u5230\u6700\u7ec8\u88ab\u89c6\u4e3a\u6d88\u8d39\u5931\u8d25\u5e76\u88ab\u6295\u9012\u5230\u6b7b\u4fe1 Topic \u4e2d\uff08RocketMQ \u9ed8\u8ba4\u6700\u591a\u53ef\u4ee5\u91cd\u590d\u6d88\u8d39 16 \u6b21\uff09\u3002<\/p>\n\n\n\n
\u9488\u5bf9\u8fd9\u4e2a\u95ee\u9898\uff0c\u6211\u4eec\u91c7\u53d6\u4e86\u4e00\u79cd\u89e3\u51b3\u65b9\u6848\uff1a\u5728\u63d2\u5165\u6d88\u606f\u8868\u65f6\uff0c\u5fc5\u987b\u4e3a\u6bcf\u6761\u6d88\u606f\u8bbe\u7f6e\u4e00\u4e2a\u6700\u957f\u6d88\u8d39\u8fc7\u671f\u65f6\u95f4\uff0c\u4f8b\u5982 10 \u5206\u949f\u3002\u8fd9\u610f\u5473\u7740\uff0c\u5982\u679c\u67d0\u4e2a\u6d88\u606f\u5728\u6d88\u8d39\u8fc7\u7a0b\u4e2d\u8d85\u8fc7\u4e86 10 \u5206\u949f\uff0c\u5c31\u4f1a\u88ab\u89c6\u4e3a\u6d88\u8d39\u5931\u8d25\u5e76\u4ece\u6d88\u606f\u8868\u4e2d\u5220\u9664\u3002<\/p>\n\n\n\n
\u62bd\u8c61\u901a\u7528\u5e42\u7b49\u7ec4\u4ef6<\/h2>\n\n\n\n
\u6d88\u606f\u9632\u91cd\u590d\u6d88\u8d39\u5e42\u7b49\u7ec4\u4ef6\u662f\u901a\u7528\u7684\uff0c\u63a5\u4e0b\u6765\u7684\u4ee3\u7801\u5f00\u53d1\u8fd8\u662f\u4f1a\u653e\u5230 framework<\/code> \u57fa\u7840\u67b6\u6784\u7ec4\u4ef6\u91cc\u3002<\/p>\n\n\n\n![\"\"](\"https:\/\/oss.open8gu.com\/image-20240906101941114.png\" "\\"\\"\/")
<\/figure>\n\n\n\n1. \u81ea\u5b9a\u4e49\u5e42\u7b49\u6ce8\u89e3<\/h3>\n\n\n\n
\u6211\u4eec\u63d0\u4f9b\u4e86\u4e00\u79cd\u901a\u7528\u7684\u5e42\u7b49\u6ce8\u89e3\uff0c\u5e76\u901a\u8fc7 SpEL \u7684\u5f62\u5f0f\u751f\u6210\u53bb\u91cd\u8868\u5168\u5c40\u552f\u4e00 Key\u3002\u5982\u679c\u5bf9 SpEL \u4e0d\u719f\u6089\u7684\u540c\u5b66\uff0c\u79fb\u6b65\u67e5\u770b \u5386\u53f2\u7ae0\u8282<\/a> \u8fdb\u884c\u5b66\u4e60\u3002<\/p>\n\n\n\n\n@Target(ElementType.METHOD)\n@Retention(RetentionPolicy.RUNTIME)\npublic @interface NoMQDuplicateConsume {\n\u200b\n \/**\n * \u8bbe\u7f6e\u9632\u91cd\u4ee4\u724c Key \u524d\u7f00\n *\/\n String keyPrefix() default \"\";\n\u200b\n \/**\n * \u901a\u8fc7 SpEL \u8868\u8fbe\u5f0f\u751f\u6210\u7684\u552f\u4e00 Key\n *\/\n String key();\n\u200b\n \/**\n * \u8bbe\u7f6e\u9632\u91cd\u4ee4\u724c Key \u8fc7\u671f\u65f6\u95f4\uff0c\u5355\u4f4d\u79d2\uff0c\u9ed8\u8ba4 1 \u5c0f\u65f6\n *\/\n long keyTimeout() default 3600L;\n}<\/code><\/pre>\n\n\n\n2. \u5b9a\u4e49 AOP \u903b\u8f91\u589e\u5f3a<\/h3>\n\n\n\n
\u4e0a\u9762\u6211\u4eec\u6709\u8bf4\u5230\uff0c\u5e42\u7b49\u9700\u8981\u8bbe\u7f6e\u4e24\u4e2a\u72b6\u6001\uff0c\u6d88\u8d39\u4e2d\u548c\u5df2\u6d88\u8d39\uff0c\u521b\u5efa\u5bf9\u5e94\u7684\u679a\u4e3e\uff1a<\/p>\n\n\n\n
\n@RequiredArgsConstructor\npublic enum IdempotentMQConsumeStatusEnum {\n\u200b\n \/**\n * \u6d88\u8d39\u4e2d\n *\/\n CONSUMING(\"0\"),\n\u200b\n \/**\n * \u5df2\u6d88\u8d39\n *\/\n CONSUMED(\"1\");\n\u200b\n @Getter\n private final String code;\n\u200b\n \/**\n * \u5982\u679c\u6d88\u8d39\u72b6\u6001\u7b49\u4e8e\u6d88\u8d39\u4e2d\uff0c\u8fd4\u56de\u5931\u8d25\n *\n * @param consumeStatus \u6d88\u8d39\u72b6\u6001\n * @return \u662f\u5426\u6d88\u8d39\u5931\u8d25\n *\/\n public static boolean isError(String consumeStatus) {\n return Objects.equals(CONSUMING.code, consumeStatus);\n }\n}<\/code><\/pre>\n\n\n\n\u63a5\u4e0b\u6765\u901a\u8fc7 AOP \u7684\u65b9\u5f0f\u8fdb\u884c\u589e\u5f3a\u6ce8\u89e3\uff0c\u5982\u679c\u8bf4\u65b9\u6cd5\u4e0a\u52a0\u4e86\u6ce8\u89e3\uff0c\u4f1a\u88ab\u8fd9\u6bb5 AOP \u4ee3\u7801\u4ee5\u73af\u7ed5\u589e\u5f3a\u65b9\u5f0f\u6267\u884c\u3002<\/p>\n\n\n\n
\n@Slf4j\n@Aspect\n@RequiredArgsConstructor\npublic final class NoMQDuplicateConsumeAspect {\n\u200b\n private final StringRedisTemplate stringRedisTemplate;\n\u200b\n private static final String LUA_SCRIPT = \"\"\"\n local key = KEYS[1]\n local value = ARGV[1]\n local expire_time_ms = ARGV[2]\n return redis.call('SET', key, value, 'NX', 'GET', 'PX', expire_time_ms)\n \"\"\";\n\u200b\n \/**\n * \u589e\u5f3a\u65b9\u6cd5\u6807\u8bb0 {@link NoMQDuplicateConsume} \u6ce8\u89e3\u903b\u8f91\n *\/\n @Around(\"@annotation(com.nageoffer.onecoupon.framework.idempotent.NoMQDuplicateConsume)\")\n public Object noMQRepeatConsume(ProceedingJoinPoint joinPoint) throws Throwable {\n NoMQDuplicateConsume noMQDuplicateConsume = getNoMQDuplicateConsumeAnnotation(joinPoint);\n String uniqueKey = noMQDuplicateConsume.keyPrefix() + SpELUtil.parseKey(noMQDuplicateConsume.key(), ((MethodSignature) joinPoint.getSignature()).getMethod(), joinPoint.getArgs());\n\u200b\n String absentAndGet = stringRedisTemplate.execute(\n RedisScript.of(LUA_SCRIPT, String.class),\n List.of(uniqueKey),\n IdempotentMQConsumeStatusEnum.CONSUMING.getCode(),\n String.valueOf(TimeUnit.SECONDS.toMillis(noMQDuplicateConsume.keyTimeout()))\n );\n\u200b\n \/\/ \u5982\u679c\u4e0d\u4e3a\u7a7a\u8bc1\u660e\u5df2\u7ecf\u6709\n if (Objects.nonNull(absentAndGet)) {\n boolean errorFlag = IdempotentMQConsumeStatusEnum.isError(absentAndGet);\n log.warn(\"[{}] MQ repeated consumption, {}.\", uniqueKey, errorFlag ? \"Wait for the client to delay consumption\" : \"Status is completed\");\n if (errorFlag) {\n throw new ServiceException(String.format(\"\u6d88\u606f\u6d88\u8d39\u8005\u5e42\u7b49\u5f02\u5e38\uff0c\u5e42\u7b49\u6807\u8bc6\uff1a%s\", uniqueKey));\n }\n return null;\n }\n\u200b\n Object result;\n try {\n \/\/ \u6267\u884c\u6807\u8bb0\u4e86\u6d88\u606f\u961f\u5217\u9632\u91cd\u590d\u6d88\u8d39\u6ce8\u89e3\u7684\u65b9\u6cd5\u539f\u903b\u8f91\n result = joinPoint.proceed();\n\u200b\n \/\/ \u8bbe\u7f6e\u9632\u91cd\u4ee4\u724c Key \u8fc7\u671f\u65f6\u95f4\uff0c\u5355\u4f4d\u79d2\n stringRedisTemplate.opsForValue().set(uniqueKey, IdempotentMQConsumeStatusEnum.CONSUMED.getCode(), noMQDuplicateConsume.keyTimeout(), TimeUnit.SECONDS);\n } catch (Throwable ex) {\n \/\/ \u5220\u9664\u5e42\u7b49 Key\uff0c\u8ba9\u6d88\u606f\u961f\u5217\u6d88\u8d39\u8005\u91cd\u8bd5\u903b\u8f91\u8fdb\u884c\u91cd\u65b0\u6d88\u8d39\n stringRedisTemplate.delete(uniqueKey);\n throw ex;\n }\n return result;\n }\n\u200b\n \/**\n * @return \u8fd4\u56de\u81ea\u5b9a\u4e49\u9632\u91cd\u590d\u6d88\u8d39\u6ce8\u89e3\n *\/\n public static NoMQDuplicateConsume getNoMQDuplicateConsumeAnnotation(ProceedingJoinPoint joinPoint) throws NoSuchMethodException {\n MethodSignature methodSignature = (MethodSignature) joinPoint.getSignature();\n Method targetMethod = joinPoint.getTarget().getClass().getDeclaredMethod(methodSignature.getName(), methodSignature.getMethod().getParameterTypes());\n return targetMethod.getAnnotation(NoMQDuplicateConsume.class);\n }\n}<\/code><\/pre>\n\n\n\n\u53ef\u80fd\u6709\u4e9b\u540c\u5b66\u4e0d\u592a\u719f\u6089 Lua \u811a\u672c\u8fd9\u4e2a\u547d\u4ee4\u4ee3\u8868\u7740\u4ec0\u4e48\uff0c\u6211\u4eec\u89e3\u91ca\u4e0b\u8fd9\u4e2a\u6982\u5ff5\uff0c\u8bed\u53e5\u5982\u4e0b\uff1a<\/p>\n\n\n\n
local key =KEYS[1] # \u7b2c\u4e00\u4e2a Key\uff0c\u5373\u5e42\u7b49\u552f\u4e00\u6807\u8bc6 uniqueKey\nlocal value =ARGV[1] # \u7b2c\u4e00\u4e2a\u53c2\u6570\uff0c\u5373\u521d\u59cb\u5316\u5e42\u7b49\u6d88\u8d39\u72b6\u6001\uff0c\u4e3a\u6d88\u8d39\u4e2d\nlocal expire_time_ms =ARGV[2] # \u7b2c\u4e8c\u4e2a\u53c2\u6570\uff0c\u5373\u5e42\u7b49 Key \u8fc7\u671f\u65f6\u95f4\n\u200b\nreturn redis.call('SET', key, value,'NX','GET','PX', expire_time_ms)<\/code><\/pre>\n\n\n\n\u6700\u91cd\u8981\u7684\u662f\u8fd4\u56de\u503c\u90a3\u4e00\u884c\uff1a<\/p>\n\n\n\n
\nSET key value<\/code>: \u5728 Redis \u4e2d\u8bbe\u7f6e key<\/code> \u5bf9\u5e94\u7684\u503c\u4e3a value<\/code>\u3002<\/li>\n\n\n\n'NX'<\/code>: \u8868\u793a\u53ea\u6709\u5728 key<\/code> \u4e0d\u5b58\u5728\u65f6\u624d\u6267\u884c\u8bbe\u7f6e\u64cd\u4f5c\uff0c\u9632\u6b62\u8986\u76d6\u5df2\u6709\u503c\u3002<\/li>\n\n\n\n'GET'<\/code>: \u8868\u793a\u5728\u8bbe\u7f6e\u65b0\u503c\u4e4b\u524d\uff0c\u83b7\u53d6\u5e76\u8fd4\u56de\u8bbe\u7f6e\u524d\u7684\u65e7\u503c\uff08Redis 6.2 \u5f00\u59cb\u652f\u6301 SET<\/code> \u547d\u4ee4\u7684 GET<\/code> \u9009\u9879\uff09\u3002<\/li>\n\n\n\n'PX expire_time_ms'<\/code>: \u8bbe\u7f6e key<\/code> \u7684\u8fc7\u671f\u65f6\u95f4\uff0c\u5355\u4f4d\u662f\u6beb\u79d2\u3002<\/li>\n<\/ul>\n\n\n\n\u8be5\u811a\u672c\u7684\u4e3b\u8981\u4f5c\u7528\u662f\uff1a\u5728 Redis \u4e2d\u5c1d\u8bd5\u4ee5 NX<\/code> \u65b9\u5f0f\u8bbe\u7f6e\u4e00\u4e2a\u952e\uff0c\u5373\u5982\u679c\u952e\u4e0d\u5b58\u5728\uff0c\u5219\u8bbe\u7f6e\u65b0\u503c\uff0c\u5e76\u8fd4\u56de\u8bbe\u7f6e\u4e4b\u524d\u7684\u65e7\u503c\uff0c\u540c\u65f6\u4e3a\u8be5\u952e\u8bbe\u7f6e\u8fc7\u671f\u65f6\u95f4\uff08\u4ee5\u6beb\u79d2\u4e3a\u5355\u4f4d\uff09\u3002<\/p>\n\n\n\n\u83b7\u53d6\u5230 Redis \u91cc\u9762\u7684 Key \u503c\u540e\uff0c\u53ef\u80fd\u4f1a\u6709\u4e09\u4e2a\u6d41\u7a0b\u6267\u884c\uff1a<\/p>\n\n\n\n
\nabsentAndGet<\/code> \u4e3a\u7a7a\uff1a\u4ee3\u8868\u6d88\u606f\u662f\u7b2c\u4e00\u6b21\u5230\u8fbe\uff0c\u6267\u884c\u5b8c LUA \u811a\u672c\u540e\uff0c\u4f1a\u5728 Redis \u8bbe\u7f6e Key \u7684 Value \u503c\u4e3a 0\uff0c\u6d88\u8d39\u4e2d\u72b6\u6001\u3002<\/li>\n\n\n\nabsentAndGet<\/code> \u4e3a 0\uff1a\u4ee3\u8868\u5df2\u7ecf\u6709\u76f8\u540c\u6d88\u606f\u5230\u8fbe\u5e76\u4e14\u8fd8\u6ca1\u6709\u5904\u7406\u5b8c\uff0c\u4f1a\u901a\u8fc7\u629b\u5f02\u5e38\u7684\u5f62\u5f0f\u8ba9 RocketMQ \u91cd\u8bd5\u3002<\/li>\n\n\n\nabsentAndGet<\/code> \u4e3a 1\uff1a\u4ee3\u8868\u5df2\u7ecf\u6709\u76f8\u540c\u6d88\u606f\u6d88\u8d39\u5b8c\u6210\uff0c\u8fd4\u56de\u7a7a\u8868\u793a\u4e0d\u6267\u884c\u4efb\u4f55\u5904\u7406\u3002<\/li>\n<\/ul>\n\n\n\n3. \u6ce8\u518c\u4e3a Spring Bean<\/h3>\n\n\n\n
\u56e0\u4e3a\u4e4b\u524d Web \u63a5\u53e3\u9632\u91cd\u590d\u63d0\u4ea4\u6211\u4eec\u5df2\u7ecf\u8bbe\u7f6e\u4e86\u5e42\u7b49\u914d\u7f6e\u7c7b\uff0c\u6240\u4ee5\u8ffd\u52a0\u4e00\u4e2a @Bean \u5c31\u53ef\u4ee5\u4e86\u3002<\/p>\n\n\n\n
\npublic class IdempotentConfiguration {\n\u200b\n \/**\n * \u9632\u6b62\u7528\u6237\u91cd\u590d\u63d0\u4ea4\u8868\u5355\u4fe1\u606f\u5207\u9762\u63a7\u5236\u5668\n *\/\n @Bean\n public NoDuplicateSubmitAspect noDuplicateSubmitAspect(RedissonClient redissonClient) {\n return new NoDuplicateSubmitAspect(redissonClient);\n }\n\u200b\n \/**\n * \u9632\u6b62\u6d88\u606f\u961f\u5217\u6d88\u8d39\u8005\u91cd\u590d\u6d88\u8d39\u6d88\u606f\u5207\u9762\u63a7\u5236\u5668\n *\/\n @Bean\n public NoMQDuplicateConsumeAspect noMQDuplicateConsumeAspect(StringRedisTemplate stringRedisTemplate) {\n return new NoMQDuplicateConsumeAspect(stringRedisTemplate);\n }\n}<\/code><\/pre>\n\n\n\norg.springframework.boot.autoconfigure.AutoConfiguration.imports<\/code> \u6587\u4ef6\u4fdd\u6301\u4e0d\u53d8\u5c31\u597d\u4e86\u3002<\/p>\n\n\n\n4. \u5b9e\u9645\u4f7f\u7528\u573a\u666f<\/h3>\n\n\n\n
\u8fd9\u4e2a\u6d88\u606f\u9632\u91cd\u590d\u6ce8\u89e3\u9700\u8981\u52a0\u5230\u6211\u4eec\u7684 CouponTaskExecuteConsumer<\/code> \u6d88\u8d39\u8005\u4e0a\uff0c\u56e0\u4e3a\u5982\u679c\u89e6\u53d1\u4e86\u91cd\u590d\u6d88\u8d39\uff0c\u610f\u5473\u7740\u4e00\u4e2a\u4f18\u60e0\u5238\u5206\u53d1\u4efb\u52a1\u4f1a\u6267\u884c\u4e24\u6b21\u3002<\/p>\n\n\n\n@Component\n@RequiredArgsConstructor\n@RocketMQMessageListener(\n topic = DistributionRocketMQConstant.TEMPLATE_TASK_EXECUTE_TOPIC_KEY,\n consumerGroup = DistributionRocketMQConstant.TEMPLATE_TASK_EXECUTE_CG_KEY\n)\n@Slf4j(topic = \"CouponTaskExecuteConsumer\")\npublic class CouponTaskExecuteConsumer implements RocketMQListener<MessageWrapper<CouponTaskExecuteEvent>> {\n\u200b\n @NoMQDuplicateConsume(\n keyPrefix = \"coupon_task_execute:idempotent:\",\n key = \"#messageWrapper.message.couponTaskId\",\n keyTimeout = 120\n )\n @Override\n public void onMessage(MessageWrapper<CouponTaskExecuteEvent> messageWrapper) {\n \/\/ ......\n }\n}<\/code><\/pre>\n\n\n\nkeyPrefix<\/code> \u548c key<\/code> \u7ec4\u88c5\u6210\u5168\u5c40\u552f\u4e00\u7684\u5e42\u7b49\u6807\u8bc6\uff0ckeyTimeout \u610f\u5473\u7740\u6211\u4eec\u53ef\u4ee5\u4fdd\u6301 2 \u5206\u949f\u7684\u5e42\u7b49\u3002<\/p>\n\n\n\n\u5e38\u89c1\u95ee\u9898\u7b54\u7591<\/h2>\n\n\n\n1. \u4e3a\u4ec0\u4e48\u8981\u8bbe\u7f6e 2 \u5206\u949f\u5e42\u7b49\uff1f10 \u5206\u949f\u4e0d\u884c\u4e48\uff1f<\/h3>\n\n\n\n
\u8fd9\u4e2a 2 \u5206\u949f\u662f\u4e2a\u7ecf\u9a8c\u503c\uff0c\u4e5f\u5c31\u662f\u8bf4\u4f60\u8fd9\u4e2a\u6d88\u606f\u6d88\u8d39\u7684\u65f6\u95f4\u662f\u5426\u80fd\u591f\u5728 2 \u5206\u949f\u5185\u6267\u884c\u5b8c\u6210\uff0c\u5982\u679c\u4e0d\u884c\u9700\u8981\u8bbe\u7f6e\u66f4\u957f\u7684\u65f6\u95f4\u3002<\/p>\n\n\n\n
2. \u5982\u679c 2 \u5206\u949f\u5e42\u7b49\u7ed3\u675f\u540e\u6709\u65b0\u7684\u4e00\u6a21\u4e00\u6837\u7684\u8bf7\u6c42\u5462\uff1f<\/h3>\n\n\n\n
\u8fd9\u662f\u4e2a\u4f2a\u547d\u9898\uff0c\u4e00\u822c\u7684\u5e42\u7b49\u90fd\u662f\u56e0\u4e3a\u7f51\u7edc\u6296\u52a8\u540c\u65f6\u5230\u8fbe\uff0c\u4e0d\u592a\u53ef\u80fd\u4e00\u4e2a\u6d88\u606f\u90fd\u6267\u884c\u5b8c\u4e86\u633a\u957f\u65f6\u95f4\uff0c\u7136\u540e\u53c8\u6709\u4e00\u6a21\u4e00\u6837\u7684\u6d88\u606f\u518d\u6765\u6d88\u8d39\u3002<\/p>\n\n\n\n
\u5982\u679c\u9762\u8bd5\u5b98\u975e\u8981\u63ea\u7740\u8fd9\u4e2a\u70b9\u4e0d\u653e\u7684\u8bdd\uff0c\u53ef\u4ee5\u628a\u8fd9\u4e2a\u5e42\u7b49\u6807\u8bc6\u5b58\u653e\u5230 MySQL \u6570\u636e\u5e93\uff0c\u8fdb\u884c\u5206\u8868\u5b58\u50a8\u3002\u8fd9\u6837\u5b58\u4e2a 10 \u5929\u534a\u4e2a\u6708\u4e5f\u4e0d\u6015\u3002\u4f46\u662f\u8981\u6ce8\u610f\uff0cMySQL \u662f\u6ca1\u6709\u5230\u671f\u5220\u9664\u673a\u5236\u7684\uff0c\u8fd8\u5f97\u914d\u5408\u5b9a\u65f6\u4efb\u52a1\u5220\u9664\u4e4b\u524d\u7684\u65e0\u6548\u6570\u636e\u3002<\/p>\n\n\n\n
3. \u600e\u4e48\u6d4b\u8bd5\u5e42\u7b49\uff1f<\/h3>\n\n\n\n
\u6211\u4eec\u628a Debug \u65ad\u70b9\u6253\u5230 NoMQDuplicateConsumeAspect#noMQRepeatConsume<\/code> \u65b9\u6cd5\u91cc\uff0c\u7136\u540e\u5728\u771f\u6b63\u6267\u884c\u524d\uff0c\u53bb Redis \u53ef\u89c6\u5316\u5de5\u5177\u4e2d\u65b0\u589e\u5e42\u7b49\u503c\u3002<\/p>\n\n\n\n![\"\"](\"https:\/\/oss.open8gu.com\/image-20240906102955481.png\" "\\"\\"\/")
<\/figure>\n\n\n\n\u56e0\u4e3a\u8fd9\u4e2a\u5de5\u5177\u4e0d\u652f\u6301\u521b\u5efa Key \u7684\u65f6\u5019\u8bbe\u7f6e Value\uff0c\u6240\u4ee5\u6211\u4eec\u521b\u5efa\u597d\u540e\uff0c\u8fd8\u9700\u8981\u53bb\u8bbe\u7f6e\u4e0b\u5bf9\u5e94\u7684 Value \u4e3a 0 \u6216\u8005 1\uff0c\u8fd9\u6837\u5c31\u80fd\u6d4b\u8bd5\u5bf9\u5e94\u7684\u6d41\u7a0b\u4e86\u3002<\/p>\n\n\n\n![\"\"](\"https:\/\/oss.open8gu.com\/image-20240906103508999.png\" "\\"\\"\/")
<\/figure>\n\n\n\n\u66f4\u590d\u6742\u7684\u5e42\u7b49\u573a\u666f<\/h2>\n\n\n\n1. \u5e42\u7b49\u4e0d\u662f\u4e07\u80fd\u7684<\/h3>\n\n\n\n
\u5230\u8fd9\u91cc\uff0c\u65b9\u6848\u770b\u8d77\u6765\u975e\u5e38\u5b8c\u7f8e\uff0c\u6240\u6709\u7684\u6d88\u606f\u90fd\u53ef\u4ee5\u5feb\u901f\u63a5\u5165\u53bb\u91cd\uff0c\u800c\u4e14\u4e0e\u5177\u4f53\u4e1a\u52a1\u5b9e\u73b0\u5b8c\u5168\u89e3\u8026\u3002\u4f46\u662f\uff0c\u662f\u5426\u8fd9\u6837\u5c31\u53ef\u4ee5\u5b8c\u7f8e\u5730\u5b8c\u6210\u53bb\u91cd\u7684\u6240\u6709\u4efb\u52a1\u5462\uff1f<\/p>\n\n\n\n
\u5f88\u9057\u61be\uff0c\u5b9e\u9645\u4e0a\u5e76\u975e\u5982\u6b64\u3002\u56e0\u4e3a\u9700\u8981\u786e\u4fdd\u6d88\u606f\u81f3\u5c11\u6210\u529f\u6d88\u8d39\u4e00\u6b21\uff0c\u56e0\u6b64\u6d88\u606f\u5728\u6d88\u8d39\u8fc7\u7a0b\u4e2d\u6709\u53ef\u80fd\u5931\u8d25\u5e76\u89e6\u53d1\u91cd\u8bd5\u3002<\/p>\n\n\n\n
\u8fd8\u662f\u4ee5\u4e0a\u9762\u7684\u4f8b\u5b50\uff0c\u5047\u8bbe\u6d88\u606f\u6d88\u8d39\u7684\u6d41\u7a0b\u5305\u542b\uff1a<\/p>\n\n\n\n
\n- 1.\u68c0\u67e5\u5e93\u5b58\uff08RPC\uff09<\/li>\n\n\n\n
- 2.\u9501\u5e93\u5b58\uff08RPC\uff09<\/li>\n\n\n\n
- 3.\u5f00\u542f\u4e8b\u52a1\uff0c\u63d2\u5165\u8ba2\u5355\u8868\uff08MySQL\uff09<\/li>\n\n\n\n
- 4.\u8c03\u7528\u67d0\u4e9b\u5176\u4ed6\u4e0b\u6e38\u670d\u52a1\uff08RPC\uff09<\/li>\n\n\n\n
- 5.\u66f4\u65b0\u8ba2\u5355\u72b6\u6001<\/li>\n\n\n\n
- 6.commit \u4e8b\u52a1\uff08MySQL\uff09<\/li>\n<\/ol>\n\n\n\n
\u5f53\u6d88\u606f\u6d88\u8d39\u5230\u7b2c\u4e09\u6b65\u7684\u65f6\u5019\u5047\u8bbe MySQL \u5f02\u5e38\u5bfc\u81f4\u5931\u8d25\u4e86\uff0c\u89e6\u53d1\u6d88\u606f\u91cd\u8bd5\u3002\u5728\u91cd\u8bd5\u524d\u6211\u4eec\u4f1a\u5220\u9664\u5e42\u7b49\u8868\u7684\u8bb0\u5f55\uff0c\u6240\u4ee5\u6d88\u606f\u91cd\u8bd5\u7684\u65f6\u5019\u5c31\u4f1a\u91cd\u65b0\u8fdb\u5165\u6d88\u8d39\u4ee3\u7801\uff0c\u90a3\u4e48\u6b65\u9aa4 1 \u548c\u6b65\u9aa4 2 \u5c31\u4f1a\u91cd\u65b0\u518d\u6267\u884c\u4e00\u904d\u3002<\/p>\n\n\n\n
\u5982\u679c\u6b65\u9aa4 2 \u672c\u8eab\u4e0d\u662f\u5e42\u7b49\u7684\uff0c\u90a3\u4e48\u8fd9\u4e2a\u4e1a\u52a1\u6d88\u606f\u6d88\u8d39\u4f9d\u65e7\u6ca1\u6709\u505a\u597d\u5b8c\u6574\u7684\u5e42\u7b49\u5904\u7406\u3002<\/p>\n\n\n\n
2. \u901a\u7528\u65b9\u6cd5\u5b9e\u73b0\u4ef7\u503c<\/h3>\n\n\n\n
\u5c3d\u7ba1\u8fd9\u79cd\u65b9\u5f0f\u5e76\u4e0d\u80fd\u5b8c\u5168\u89e3\u51b3\u6d88\u606f\u5e42\u7b49\u95ee\u9898\uff08\u4e8b\u5b9e\u4e0a\uff0c\u8f6f\u4ef6\u5de5\u7a0b\u9886\u57df\u91cc\u5f88\u5c11\u6709\u94f6\u5f39\u53ef\u4ee5\u5b8c\u5168\u89e3\u51b3\u95ee\u9898\uff09\uff0c\u4f46\u5b83\u4ecd\u7136\u5177\u6709\u5f88\u5927\u7684\u4ef7\u503c\u3002\u901a\u8fc7\u8fd9\u79cd\u7b80\u4fbf\u7684\u65b9\u5f0f\uff0c\u6211\u4eec\u80fd\u591f\u89e3\u51b3\u4ee5\u4e0b\u95ee\u9898\uff1a<\/p>\n\n\n\n
\n- 1.\u5404\u79cd\u7531\u4e8e Broker\u3001\u8d1f\u8f7d\u5747\u8861\u7b49\u539f\u56e0\u5bfc\u81f4\u7684\u6d88\u606f\u91cd\u6295\u9012\u7684\u91cd\u590d\u95ee\u9898\u3002<\/li>\n\n\n\n
- 2.\u5404\u79cd\u4e0a\u6e38\u751f\u4ea7\u8005\u5bfc\u81f4\u7684\u4e1a\u52a1\u7ea7\u522b\u6d88\u606f\u91cd\u590d\u95ee\u9898\u3002<\/li>\n\n\n\n
- 3.\u91cd\u590d\u6d88\u606f\u5e76\u53d1\u6d88\u8d39\u7684\u63a7\u5236\u7a97\u53e3\u95ee\u9898\uff0c\u5c31\u7b97\u91cd\u590d\uff0c\u91cd\u590d\u4e5f\u4e0d\u53ef\u80fd\u540c\u4e00\u65f6\u95f4\u8fdb\u5165\u6d88\u8d39\u903b\u8f91\u3002<\/li>\n<\/ol>\n\n\n\n
\u4f7f\u7528\u8fd9\u79cd\u65b9\u6cd5\u53ef\u4ee5\u786e\u4fdd\u5728\u6b63\u5e38\u7684\u6d88\u8d39\u903b\u8f91\u573a\u666f\u4e0b\uff08\u65e0\u5f02\u5e38\uff0c\u65e0\u5f02\u5e38\u9000\u51fa\uff09\uff0c\u6d88\u606f\u7684\u5e42\u7b49\u6027\u5168\u90e8\u5f97\u5230\u89e3\u51b3\uff0c\u65e0\u8bba\u662f\u4e1a\u52a1\u91cd\u590d\u8fd8\u662f RocketMQ \u7279\u6027\u5e26\u6765\u7684\u91cd\u590d\u3002\u867d\u7136\u5b83\u4e0d\u662f\u89e3\u51b3\u6d88\u606f\u5e42\u7b49\u6027\u7684\u94f6\u5f39\uff0c\u4f46\u5b83\u4ee5\u4e00\u79cd\u7b80\u5355\u548c\u4fbf\u6377\u7684\u65b9\u5f0f\u63d0\u4f9b\u4e86\u89e3\u51b3\u65b9\u6848\u3002<\/p>\n\n\n\n
\u5b9e\u9645\u4e0a\uff0c\u8fd9\u79cd\u65b9\u6cd5\u5df2\u7ecf\u53ef\u4ee5\u89e3\u51b3 99% \u7684\u6d88\u606f\u91cd\u590d\u95ee\u9898\u4e86\uff0c\u56e0\u4e3a\u5f02\u5e38\u3001\u5b95\u673a\u7b49\u60c5\u51b5\u901a\u5e38\u662f\u5c11\u6570\u60c5\u51b5\u3002<\/p>\n\n\n\n
\u5b8c\u7ed3\uff0c\u6492\u82b1 \ud83c\udf89<\/p>\n\n\n\n
<\/p>\n\n\n\n
6.2.6\u7684redis.call\u4e0d\u652f\u6301\u90a3\u4e48\u591a\u53c2\u6570\uff0cSET key val PX time NX GET\u4f1a\u62a5\u8bed\u6cd5\u9519\u8bef\uff0c\u53ea\u8ffd\u52a0NX\u6216GET\u4e2d\u7684\u4e00\u4e2a\u662f\u6ca1\u6709\u95ee\u9898\u7684\uff0c\u661f\u7403\u63d0\u4f9b\u76847.2.5\u662f\u53ef\u4ee5\u540c\u65f6\u8ffd\u52a0NX\u548cGET\u7684<\/p>\n\n\n\n![\"\"](\"https:\/\/eve2333.top\/wp-content\/uploads\/2025\/09\/1758357740-image-1024x213.png\")
<\/figure>\n\n\n\n\u6211\u561e\u4e2a\u8c46\uff0c\u5e38\u89c1\u95ee\u9898\u7684\u7b2c\u4e8c\u4e2a\u95ee\u9898\uff0c\u5c31\u662f\u5f53\u65f6\u9762\u8bd5\u5b98\u95ee\u6211\u7684\u95ee\u9898\uff08\u77ed\u94fe\u63a5\u7684\u9879\u76ee\uff09\uff0c\u6211\u5f53\u65f6\u786e\u5b9e\u5f80\u8fd9\u65b9\u9762\u60f3\u4e86\uff0c\u89c9\u5f97\u4e0d\u592a\u53ef\u80fd\u4f1a\u51fa\u73b0\u8fd9\u79cd\u60c5\u51b5\uff0c\u4f46\u662f\u5948\u4f55\u5f53\u65f6\u9762\u8bd5\u7684\u65f6\u5019\u7d27\u5f20+\u5634\u7b28\uff0c\u6ca1\u8bf4\u51fa\u6765= =<\/p>\n\n\n\n
\uacfc\ubaa9th\ud5c8jlS* \u56de\u590d \u5730\u4fe1\u54e5\uff1a\u5730\u4fe1\u54e5\uff0c\u6211\u770b\u5230rocketmq\u7684\u8d85\u65f6\u65f6\u95f4\u662f15min\uff0c\u5982\u679c\u6d88\u8d39\u8005\u6210\u529f\u6d88\u8d39\uff0c\u4f46\u662f\u6ca1\u6709\u8fd4\u56de\u7ed9broker ack\uff0c15min\u540e\u91cd\u65b0\u6295\u9012\uff0c\u90a3\u4e0d\u662f\u5e42\u7b49\u5931\u6548\u4e86\uff08\u5e42\u7b49\u7ec4\u4ef6\u624d2min\uff09<\/p>\n\n\n\n
\n\n\n\n\u5982\u679c\u53d1\u73b0\u6d88\u606f\u5904\u4e8econsuming\u72b6\u6001\uff0c\u4e0d\u5c31\u8bf4\u660emq\u4e2d\u6709\u4e24\u4e2a\u6216\u4ee5\u4e0a\u7684\u540c\u79cd\u6d88\u606f\u5417\uff0c\u8ba9\u4e00\u6761\u6d88\u606f\u53bb\u6d88\u8d39\u4e0d\u5c31\u53ef\u4ee5\u4e86\uff0c\u53e6\u5916\u7684\u6d88\u606f\u76f4\u63a5\u653e\u5f03\uff0c\u5982\u679c\u4e0d\u653e\u5f03\u53cd\u800c\u91cd\u65b0\u6295\u9012\u7684\u8bdd\u4e0d\u4f1a\u5360\u7528\u8d44\u6e90\u5417\uff0c\u5982\u679c\u7b2c\u4e00\u6761\u6d88\u606f\u6d88\u8d39\u5931\u8d25\u4e86\uff0cmq\u4e5f\u80fd\u91cd\u65b0\u6295\u9012<\/p>\n\n\n\n
\u4e01\u82b1\u54e5 \u56de\u590d rebcaaaaaa*\uff1a\u4f60\u8fd9\u4e2a\u6709\u903b\u8f91\u6f0f\u6d1e\uff0c\u5149\u770b\u4f60\u8bf4\u7684\u8fd9\u4e2a\u597d\u50cf\u6ca1\u6709\u95ee\u9898\u3002\u524d\u63d0\u6761\u4ef6\uff1a\u5c31\u662f\u4e00\u9047\u5230consuming\u72b6\u6001\u5c31\u8fd4\u56de\u6210\u529f(\u5e94\u8be5\u7406\u89e3\u6ca1\u6709\u9519\u5427)\u3002\u5047\u8bbe\u6d88\u606fM\uff0c\u521a\u88ab\u4e00\u6b21\u6d88\u8d39A\u6d88\u8d39\uff0credis\u72b6\u6001\u6539\u4e3aconsuming\uff0c\u5176\u4ed6\u64cd\u4f5c\u8fd8\u6ca1\u6709\u8fdb\u884c\uff0c\u5982\u679c\u8fd9\u4e2a\u65f6\u5019\u8fd9\u4e2a\u673a\u5668\u5b95\u673a\u4e86\uff0c\u90a3\u4e48\u4e0b\u6b21\u91cd\u65b0\u6295\u9012\u7ed9\u6d88\u8d39B\uff0c\u6d88\u8d39\u65f6redis\u72b6\u6001\u5df2\u7ecf\u662fconsuming\uff0c\u76f4\u63a5\u8fd4\u56de\u6210\u529f\uff0c\u8fd9\u6761\u6d88\u606f\u5c31\u6ca1\u6709\u6d88\u8d39\u8fc7\u3002<\/p>\n\n\n\n
\n\n\n\n\u634b\u4e00\u4e0b\u601d\u8def\u3002\u76f4\u63a5\u4eceNoMQDuplicateConsumeAspect\u5207\u9762\u7c7b\u4e2d\u7684\u5f00\u59cb \u5728noMQRepeatConsume\u65b9\u6cd5\u4e2d\u9996\u5148\u6267\u884cgetNoMQDuplicateConsumeAnnotation\u65b9\u6cd5\u83b7\u53d6\u5207\u9762\u65b9\u6cd5\u4e0a\u9762\u7684\u6ce8\u89e3 \u7136\u540e\u5c06\u6ce8\u89e3\u4e0a\u9762\u7684keyPrefix\u548c\u6267\u884cSpELUtil.parseKey\u65b9\u6cd5\u83b7\u53d6\u5230\u7684messageWrapper.message.couponTaskId\u503c\u62fc\u63a5\u8d77\u6765\u4f5c\u4e3auniqueKey \u7136\u540e\u6267\u884clua\u811a\u672c\u83b7\u53d6\u5230redis\u8be5key\u7684\u503c\uff0c\u8be5lua\u811a\u672c\u7684\u6d41\u7a0b\u5c31\u662f\u83b7\u53d6\u539f\u59cb\u7684\u503c\uff0c\u5982\u679c\u6ca1\u6709\u5c31\u8bbe\u7f6e\u65b0\u7684\u503c\u548c\u8fc7\u671f\u65f6\u95f4 \u83b7\u53d6lua\u811a\u672c\u6267\u884c\u540e\u7684\u7ed3\u679c\u8d4b\u503c\u7ed9absentAndGet absentAndGet\u7684\u503c\u6709\u4e09\u79cd\u60c5\u51b5\uff1a \u5982\u679c\u4e3a\u7a7a\uff1a\u4ee3\u8868\u6d88\u606f\u662f\u7b2c\u4e00\u6b21\u5230\u8fbe\uff0c\u6267\u884c\u5b8c LUA \u811a\u672c\u540e\uff0c\u4f1a\u5728 Redis \u8bbe\u7f6e Key \u7684 Value \u503c\u4e3a 0\uff0c\u6d88\u8d39\u4e2d\u72b6\u6001\u3002 \u5982\u679c\u4e3a 0\uff1a\u4ee3\u8868\u5df2\u7ecf\u6709\u76f8\u540c\u6d88\u606f\u5230\u8fbe\u5e76\u4e14\u8fd8\u6ca1\u6709\u5904\u7406\u5b8c\uff0c\u4f1a\u901a\u8fc7\u629b\u5f02\u5e38\u7684\u5f62\u5f0f\u8ba9 RocketMQ \u91cd\u8bd5 \u5982\u679c\u4e3a 1\uff1a\u4ee3\u8868\u5df2\u7ecf\u6709\u76f8\u540c\u6d88\u606f\u6d88\u8d39\u5b8c\u6210\uff0c\u8fd4\u56de\u7a7a\u8868\u793a\u4e0d\u6267\u884c\u4efb\u4f55\u5904\u7406 \u5982\u679c\u4e0d\u4e3a\u7a7a\uff0c\u90a3\u5c31\u8bc1\u660e\u8be5\u6d88\u606f\u6b63\u5728\u6d88\u8d39\u6216\u8005\u6d88\u8d39\u5b8c\u6210\u3002 \u7136\u540e\u5224\u65ad\u662f\u5426\u662f\u6d88\u8d39\u4e2d\uff0c\u5982\u679c\u6d88\u8d39\u4e2d\u5c31\u624b\u52a8\u629b\u51faServiceException \u5982\u679c\u662f\u6d88\u8d39\u6210\u529f\uff0c\u90a3\u5c31\u76f4\u63a5return \u5982\u679c\u4e3a\u7a7a\uff0c\u90a3\u6b64\u65f6\u6d88\u606f\u5c31\u662f\u7b2c\u4e00\u6b21\u5230\u8fbe\uff0c\u90a3\u5c31\u5f00\u59cb\u6267\u884c\u6807\u8bb0\u4e86\u6d88\u606f\u961f\u5217\u9632\u91cd\u590d\u6d88\u8d39\u6ce8\u89e3\u7684\u65b9\u6cd5\u539f\u903b\u8f91 \u7531\u4e8e\u5728lua\u811a\u672c\u4e2d\u5c31\u5df2\u7ecf\u8ba9key\u7684\u503c\u8bbe\u7f6e\u4e3a\u6d88\u8d39\u4e2d\u4e86\uff0c\u6240\u4ee5\u5982\u679c\u5728\u6267\u884c\u7684\u8fc7\u7a0b\u4e2d\u6709\u6d88\u606f\u8fc7\u6765\u5c31\u4fdd\u8bc1\u4e0d\u4f1a\u91cd\u590d\u6d88\u8d39 \u6267\u884c\u5b8c\u4e86\u5c31\u8ba9\u7f13\u5b58\u4e2d\u7684\u503c\u8bbe\u7f6e\u4e3a\u6d88\u8d39\u5b8c\u6210\uff0c\u6267\u884c\u5b8c\u8fd4\u56de\u7ed3\u679c \u8fd9\u91cc\u6ce8\u610f\u4e00\u70b9\uff0c\u5982\u679cabsentAndGet\u4e0d\u4e3a\u7a7a\uff0c\u5e76\u4e14\u662f\u5728\u6d88\u8d39\u4e2d\u7684\u60c5\u51b5\uff0c\u4e0d\u80fd\u76f4\u63a5return\u3002(\u8bc4\u8bba\u533a\u7684\u4e00\u4f4d\u540c\u5b66\u7684\u4f8b\u5b50)\u5047\u8bbe\u6d88\u606fM\u7b2c\u4e00\u6b21\u88ab\u6d88\u8d39\u8005A\u6d88\u8d39\uff0credis\u72b6\u6001\u6539\u4e3aconsuming\uff0c\u5728\u6d88\u606f\u6d88\u8d39\u6210\u529f\u4e4b\u524d\uff0c\u5982\u679c\u8fd9\u4e2a\u65f6\u5019\u670d\u52a1\u5668\u5b95\u673a\u4e86\uff0c\u4e0b\u6b21\u91cd\u65b0\u6295\u9012\u7ed9\u6d88\u8d39\u8005A\uff0c\u7531\u4e8e\u6b64\u65f6redis\u72b6\u6001\u5df2\u7ecf\u662fconsuming\u4e86\uff0c\u90a3\u76f4\u63a5return\u7684\u8bdd\uff0c\u8fd9\u6761\u6d88\u606f\u4e4b\u540e\u5c31\u4e0d\u4f1a\u88ab\u6d88\u8d39\u6210\u529f\uff0c\u8fd9\u5c31\u662f\u4e00\u4e2abug\u3002\u4f46\u662f\u5982\u679c\u5728\u6d88\u8d39\u4e2d\u7684\u60c5\u51b5\u4e0b\u6211\u4eec\u629b\u51fa\u5f02\u5e38\uff0c\u53ef\u4ee5\u6210\u529f\u907f\u514d\u4e0a\u9762\u7684\u95ee\u9898\uff0c\u5e76\u4e14\uff0c\u5982\u679c\u6d88\u8d39\u8005A\u6d88\u8d39\u6210\u529f\u4e86\uff0c\u6839\u636e\u6211\u4eec\u7684\u4ee3\u7801\u53ef\u4ee5\u76f4\u63a5return\uff0c\u4e5f\u4e0d\u4f1a\u51fa\u73b0\u91cd\u590d\u6d88\u8d39\u3002<\/p>\n\n\n\n
\u7b2c23\u5c0f\u8282\uff1a\u5f00\u53d1\u5151\u6362\/\u79d2\u6740\u4f18\u60e0\u5238\u529f\u80fd\uff08\u4e00\uff09<\/h2>\n\n\n\n\u4e1a\u52a1\u80cc\u666f<\/h2>\n\n\n\n
\u901a\u8fc7\u4e4b\u524d\u7684\u7ae0\u8282\uff0c\u6211\u4eec\u5df2\u7ecf\u628a\u4f18\u60e0\u5238\u76f8\u5173\u7684\u4e1a\u52a1\u94fa\u57ab\u7684\u5dee\u4e0d\u591a\u4e86\uff0c\u63a5\u4e0b\u6765\u6211\u4eec\u6b63\u5f0f\u5f00\u542f\u5f15\u64ce\u670d\u52a1\u7684\u4f18\u60e0\u5238\u5151\u6362\/\u79d2\u6740\u4e1a\u52a1\u3002<\/p>\n\n\n\n
\u666e\u901a\u5151\u6362\u81ea\u7136\u6ca1\u6709\u90a3\u4e48\u591a\u5f2f\u5f2f\u7ed5\u7ed5\uff0c\u4f46\u662f\u6d89\u53ca\u5230\u4e00\u4e9b\u6bd4\u8f83\u5927\u989d\u6216\u8005\u6709\u5438\u5f15\u529b\u7684\u4f18\u60e0\u5238\u6765\u8bf4\uff0c\u5c31\u4e0d\u4e00\u6837\u4e86\uff0c\u4f1a\u9762\u4e34\u5927\u91cf\u7528\u6237\u62a2\u8d2d\u5c11\u91cf\u7684\u5e93\u5b58\uff0c\u4e5f\u5c31\u662f\u6211\u4eec\u5e38\u8bf4\u7684\u79d2\u6740\u67b6\u6784\u3002\u548c\u5e38\u89c4\u7684\u79d2\u6740\u7cfb\u7edf\u4e00\u6837\uff0c\u6211\u4eec\u4e5f\u662f\u91c7\u7528\u4e86\u7f13\u5b58\u6297\u5e76\u53d1\u3001\u7136\u540e\u6263\u51cf\u7f13\u5b58\u6210\u529f\u7684\u8bf7\u6c42\u53ef\u4ee5\u8fdb\u884c\u6263\u51cf\u6570\u636e\u5e93\uff0c\u5e76\u5c06\u4f18\u60e0\u5238\u6dfb\u52a0\u5230\u7528\u6237\u7684\u9886\u5238\u8bb0\u5f55\u4e2d\u3002<\/p>\n\n\n\n
\n\u6709\u4e00\u70b9\u9700\u8981\u548c\u5927\u5bb6\u5148\u8bf4\u660e\u4e0b\uff0c\u56e0\u4e3a\u4f18\u60e0\u5238\u7684\u9886\u53d6\u4e0d\u50cf 12306 \u4e00\u6837\u9700\u8981\u4fdd\u969c\u5f3a\u4e00\u81f4\u6027\uff0c\u6240\u4ee5\uff0c\u7406\u8bba\u4e0a\u53ef\u4ee5\u4ece\u6280\u672f\u65b9\u6848\u4e0a\u505a\u51cf\u6cd5\uff0c\u4f1a\u6709\u4e00\u4e9b\u5bb9\u5fcd\u6545\u969c\u3002<\/em><\/p>\n\n\n\n\u518d\u548c\u5927\u5bb6\u591a\u626f\u4e00\u53e5\uff0c\u90a3\u5c31\u662f\u9762\u8bd5\u53ef\u4ee5\u9020\u706b\u7bad\uff0c\u4f46\u662f\u4f60\u5f97\u77e5\u9053\u590d\u6742\u6280\u672f\u65b9\u6848\u5e26\u6765\u7684\u843d\u5730\u96be\u5ea6\u95ee\u9898\u3002\u6709\u65f6\u5019\u9488\u5bf9\u6ca1\u90a3\u4e48\u91cd\u8981\u7684\u573a\u666f\uff0c\u65b9\u6848\u7b80\u5355\u7c97\u66b4\u4e00\u70b9\u5e76\u6ca1\u6709\u95ee\u9898\u3002\u5f88\u591a\u540c\u5b66\u4f1a\u8bf4\u7f13\u5b58\u5b95\u673a\u4e86\u600e\u4e48\u529e\uff1f\u7f13\u5b58\u4e3b\u4ece\u5f02\u6b65\u540c\u6b65\u4e22\u5931\u6570\u636e\u600e\u4e48\u529e\uff1f\u7f13\u5b58\u6263\u51cf\u6210\u529f\u6570\u636e\u5e93\u6ca1\u6263\u51cf\u65f6\u5e94\u7528\u5b95\u673a\u4e86\u600e\u4e48\u529e\uff1f\u8bf8\u5982\u6b64\u7c7b\uff0c\u53ea\u662f\u4e00\u5f20\u4f18\u60e0\u5238\u800c\u5df2\uff0c\u5176\u5b9e\u6ca1\u6709\u5565\u95ee\u9898\u3002<\/em><\/p>\n\n\n\n\u867d\u7136\u6211\u4eec\u662f\u8fd9\u4e48\u8bf4\uff0c\u4f46\u8fd8\u662f\u4f1a\u4ee5\u8f83\u4e25\u8c28\u7684\u65b9\u5f0f\u7ed9\u5927\u5bb6\u8bb2\u89e3\u725b\u5238\u7684\u79d2\u6740\u67b6\u6784\u3002<\/em><\/p>\n<\/blockquote>\n\n\n\nGit \u5206\u652f<\/h2>\n\n\n\n
20240908_dev_acquire-coupon_seckill_ding.ma<\/p>\n\n\n\n
\u79d2\u6740\u4e1a\u52a1\u96be\u70b9<\/h2>\n\n\n\n
\u5728\u6211\u4eec\u5151\u6362\/\u79d2\u6740\u4f18\u60e0\u5238\u6a21\u677f\u7684\u63a5\u53e3\u4e2d\uff0c\u53ef\u80fd\u4f1a\u5b58\u5728\u4ee5\u4e0b\u4e09\u4e2a\u96be\u70b9\uff1a<\/p>\n\n\n\n
\n- \u9ad8\u5e76\u53d1\u6d41\u91cf\u538b\u529b\uff1a\u79d2\u6740\u6d3b\u52a8\u5f80\u5f80\u4f1a\u77ac\u95f4\u5438\u5f15\u5927\u91cf\u7528\u6237\u8bbf\u95ee\u7cfb\u7edf\uff0c\u5bfc\u81f4\u6d41\u91cf\u9aa4\u589e\uff0c\u5982\u679c\u76f4\u63a5\u8bbf\u95ee\u6570\u636e\u5e93\uff0c\u53ef\u80fd\u4f1a\u8ba9\u6570\u636e\u5e93\u8d1f\u8f7d\u8fc7\u91cd\uff0c\u751a\u81f3\u5bfc\u81f4\u5b95\u673a\u3002<\/li>\n\n\n\n
- \u5e93\u5b58\u8d85\u5356\u95ee\u9898\uff1a\u7531\u4e8e\u5e76\u53d1\u8bf7\u6c42\uff0c\u591a\u4e2a\u7528\u6237\u540c\u65f6\u62a2\u8d2d\u53ef\u80fd\u4f1a\u5bfc\u81f4\u7cfb\u7edf\u8d85\u5356\uff0c\u5373\u591a\u4e2a\u7528\u6237\u540c\u65f6\u8d2d\u4e70\u5230\u540c\u4e00\u5e93\u5b58\u3002<\/li>\n\n\n\n
- \u7528\u6237\u8d85\u9886\u95ee\u9898\uff1a\u4f18\u60e0\u5238\u4e2d\u4f1a\u6709\u4e00\u4e2a\u9650\u5236\uff0c\u6bcf\u4e2a\u7528\u6237\u9650\u6d41\u51e0\u5f20\uff0c\u5e94\u8be5\u5982\u4f55\u907f\u514d\u7528\u6237\u9886\u53d6\u8d85\u8fc7\u8fd9\u4e2a\u9650\u5236\u3002<\/li>\n<\/ul>\n\n\n\n
\u5728\u63a5\u4e0b\u6765\u7684\u8bb2\u89e3\u4e2d\uff0c\u6211\u4eec\u4f1a\u9010\u4e00\u5b8c\u6210\u8fd9\u4e9b\u96be\u70b9\u8bf4\u660e\u548c\u89e3\u51b3\u65b9\u6848\u8bb2\u89e3\u3002<\/p>\n\n\n\n
\u4f18\u60e0\u5238\u79d2\u6740\u524d\u7f6e\u62e6\u622a<\/h2>\n\n\n\n1. \u9a8c\u8bc1\u4f18\u60e0\u5238<\/h3>\n\n\n\n
\u9996\u5148\u5462\uff0c\u6211\u4eec\u5e94\u8be5\u5bf9\u524d\u7aef\u4f20\u6765\u7684\u6570\u636e\u79c9\u627f\u7740\u5b8c\u5168\u4e0d\u53ef\u4fe1\u539f\u5219\uff0c\u9996\u5148\u9a8c\u8bc1\u662f\u5426\u5b58\u5728\uff0c\u5176\u6b21\u5462\u9a8c\u8bc1\u4f18\u60e0\u5238\u662f\u5426\u6709\u6548\u6d3b\u52a8\u671f\u95f4\u3002<\/p>\n\n\n\n
\u4ee3\u7801\u5982\u4e0b\u6240\u793a\uff1a<\/p>\n\n\n\n
@OverridepublicvoidredeemUserCoupon(CouponTemplateRedeemReqDTO requestParam){\/\/ \u9a8c\u8bc1\u7f13\u5b58\u662f\u5426\u5b58\u5728\uff0c\u4fdd\u969c\u6570\u636e\u5b58\u5728\u5e76\u4e14\u7f13\u5b58\u4e2d\u5b58\u5728CouponTemplateQueryRespDTO couponTemplate = couponTemplateService.findCouponTemplate(BeanUtil.toBean(requestParam,CouponTemplateQueryReqDTO.class));\n\u200b\n \/\/ \u9a8c\u8bc1\u9886\u53d6\u7684\u4f18\u60e0\u5238\u662f\u5426\u5728\u6d3b\u52a8\u6709\u6548\u65f6\u95f4boolean isInTime =DateUtil.isIn(newDate(), couponTemplate.getValidStartTime(), couponTemplate.getValidEndTime());if(!isInTime){\/\/ \u4e00\u822c\u6765\u8bf4\u4f18\u60e0\u5238\u9886\u53d6\u65f6\u95f4\u4e0d\u5230\u7684\u65f6\u5019\uff0c\u524d\u7aef\u4e0d\u4f1a\u653e\u5f00\u8c03\u7528\u8bf7\u6c42\uff0c\u53ef\u4ee5\u7406\u89e3\u8fd9\u662f\u7528\u6237\u8c03\u7528\u63a5\u53e3\u5728\u201c\u653b\u51fb\u201dthrownewClientException(\"\u4e0d\u6ee1\u8db3\u4f18\u60e0\u5238\u9886\u53d6\u65f6\u95f4\");}}<\/code><\/pre>\n\n\n\n2. \u6263\u51cf\u7f13\u5b58<\/h3>\n\n\n\n
\u5982\u679c\u9a8c\u8bc1\u4f18\u60e0\u5238\u6a21\u677f\u6ca1\u6709\u95ee\u9898\uff0c\u90a3\u6211\u4eec\u5f00\u59cb\u8fdb\u884c\u5e93\u5b58\u6263\u51cf\u548c\u9a8c\u8bc1\u7528\u6237\u662f\u5426\u9886\u53d6\u4f18\u60e0\u5238\u8d85\u989d\u3002<\/p>\n\n\n\n
\u4ee3\u7801\u5982\u4e0b\u6240\u793a\uff1a<\/p>\n\n\n\n
privatefinalstaticStringSTOCK_DECREMENT_AND_SAVE_USER_RECEIVE_LUA_PATH=\"lua\/stock_decrement_and_save_user_receive.lua\";@OverridepublicvoidredeemUserCoupon(CouponTemplateRedeemReqDTO requestParam){\/\/ ......\/\/ \u83b7\u53d6 LUA \u811a\u672c\uff0c\u5e76\u4fdd\u5b58\u5230 Hutool \u7684\u5355\u4f8b\u7ba1\u7406\u5bb9\u5668\uff0c\u4e0b\u6b21\u76f4\u63a5\u83b7\u53d6\u4e0d\u9700\u8981\u52a0\u8f7dDefaultRedisScript<Long> buildLuaScript =Singleton.get(STOCK_DECREMENT_AND_SAVE_USER_RECEIVE_LUA_PATH,()->{DefaultRedisScript<Long> redisScript =newDefaultRedisScript<>();\n redisScript.setScriptSource(newResourceScriptSource(newClassPathResource(STOCK_DECREMENT_AND_SAVE_USER_RECEIVE_LUA_PATH)));\n redisScript.setResultType(Long.class);return redisScript;});\/\/ \u9a8c\u8bc1\u7528\u6237\u662f\u5426\u7b26\u5408\u4f18\u60e0\u5238\u9886\u53d6\u6761\u4ef6JSONObject receiveRule =JSON.parseObject(couponTemplate.getReceiveRule());String limitPerPerson = receiveRule.getString(\"limitPerPerson\");\/\/ \u6267\u884c LUA \u811a\u672c\u8fdb\u884c\u6263\u51cf\u5e93\u5b58\u4ee5\u53ca\u589e\u52a0 Redis \u7528\u6237\u9886\u5238\u8bb0\u5f55\u6b21\u6570String couponTemplateCacheKey =String.format(EngineRedisConstant.COUPON_TEMPLATE_KEY, requestParam.getCouponTemplateId());String userCouponTemplateLimitCacheKey =String.format(EngineRedisConstant.USER_COUPON_TEMPLATE_LIMIT_KEY,UserContext.getUserId(), requestParam.getCouponTemplateId());Long stockDecrementLuaResult = stringRedisTemplate.execute(\n buildLuaScript,ListUtil.of(couponTemplateCacheKey, userCouponTemplateLimitCacheKey),String.valueOf(couponTemplate.getValidEndTime().getTime()), limitPerPerson\n );\/\/ \u5224\u65ad LUA \u811a\u672c\u6267\u884c\u8fd4\u56de\u7c7b\uff0c\u5982\u679c\u5931\u8d25\u6839\u636e\u7c7b\u578b\u8fd4\u56de\u62a5\u9519\u63d0\u793along firstField =StockDecrementReturnCombinedUtil.extractFirstField(stockDecrementLuaResult);if(RedisStockDecrementErrorEnum.isFail(firstField)){thrownewServiceException(RedisStockDecrementErrorEnum.fromType(firstField));}}<\/code><\/pre>\n\n\n\n\u4e3a\u4e86\u907f\u514d\u8bbf\u95ee\u5e93\u5b58\u6263\u51cf\u548c\u5224\u65ad\u7528\u6237\u662f\u5426\u5df2\u8d85\u989d\u9886\u53d6\u4f18\u60e0\u5238\u591a\u6b21 Redis \u8bf7\u6c42\uff0c\u6240\u4ee5\u6211\u4eec\u8fd8\u662f\u4f9d\u7136\u91c7\u7528 Redis Lua \u811a\u672c\u6267\u884c\u3002<\/p>\n\n\n\n
Lua \u811a\u672c\u5982\u4e0b\u6240\u793a\uff1a<\/p>\n\n\n\n
--Lua \u811a\u672c: \u68c0\u67e5\u7528\u6237\u662f\u5426\u8fbe\u5230\u4f18\u60e0\u5238\u9886\u53d6\u4e0a\u9650\u5e76\u8bb0\u5f55\u9886\u53d6\u6b21\u6570\n\n-- \u53c2\u6570\u5217\u8868\uff1a\n--KEYS[1]: \u4f18\u60e0\u5238\u5e93\u5b58\u952e (coupon_stock_key)--KEYS[2]: \u7528\u6237\u9886\u53d6\u8bb0\u5f55\u952e (user_coupon_key)--ARGV[1]: \u4f18\u60e0\u5238\u6709\u6548\u671f\u7ed3\u675f\u65f6\u95f4 (timestamp)--ARGV[2]: \u7528\u6237\u9886\u53d6\u4e0a\u9650 (limit)\n\nlocal function combineFields(firstField, secondField)-- \u786e\u5b9a SECOND_FIELD_BITS \u4e3a 14\uff0c\u56e0\u4e3a secondField \u6700\u5927\u4e3a 9999\n local SECOND_FIELD_BITS=14-- \u6839\u636e firstField \u7684\u5b9e\u9645\u503c\uff0c\u8ba1\u7b97\u5176\u5bf9\u5e94\u7684\u4e8c\u8fdb\u5236\u8868\u793a\n -- \u7531\u4e8e firstField \u7684\u8303\u56f4\u662f0-2\uff0c\u6211\u4eec\u53ef\u4ee5\u76f4\u63a5\u4f7f\u7528\u5b83\u7684\u503c\n local firstFieldValue = firstField\n\n -- \u6a21\u62df\u4f4d\u79fb\u64cd\u4f5c\uff0c\u5c06 firstField \u7684\u503c\u5de6\u79fb SECOND_FIELD_BITS \u4f4d\n local shiftedFirstField = firstFieldValue *(2^SECOND_FIELD_BITS)-- \u5c06 secondField \u7684\u503c\u4e0e\u4f4d\u79fb\u540e\u7684 firstField \u503c\u76f8\u52a0\n return shiftedFirstField + secondField\nend\n\n-- \u83b7\u53d6\u5f53\u524d\u5e93\u5b58\nlocal stock =tonumber(redis.call('HGET',KEYS[1],'stock'))-- \u5224\u65ad\u5e93\u5b58\u662f\u5426\u5927\u4e8e 0if stock <=0 then\n returncombineFields(1,0)-- \u5e93\u5b58\u4e0d\u8db3\nend\n\n-- \u83b7\u53d6\u7528\u6237\u9886\u53d6\u7684\u4f18\u60e0\u5238\u6b21\u6570\nlocal userCouponCount =tonumber(redis.call('GET',KEYS[2]))-- \u5982\u679c\u7528\u6237\u9886\u53d6\u6b21\u6570\u4e0d\u5b58\u5728\uff0c\u5219\u521d\u59cb\u5316\u4e3a 0if userCouponCount == nil then\n userCouponCount =0\nend\n\n-- \u5224\u65ad\u7528\u6237\u662f\u5426\u5df2\u7ecf\u8fbe\u5230\u9886\u53d6\u4e0a\u9650\nif userCouponCount >=tonumber(ARGV[2]) then\n returncombineFields(2, userCouponCount)-- \u7528\u6237\u5df2\u7ecf\u8fbe\u5230\u9886\u53d6\u4e0a\u9650\nend\n\n-- \u589e\u52a0\u7528\u6237\u9886\u53d6\u7684\u4f18\u60e0\u5238\u6b21\u6570\nif userCouponCount ==0 then\n -- \u5982\u679c\u7528\u6237\u7b2c\u4e00\u6b21\u9886\u53d6\uff0c\u5219\u9700\u8981\u6dfb\u52a0\u8fc7\u671f\u65f6\u95f4\n redis.call('SET',KEYS[2],1)\n redis.call('EXPIRE',KEYS[2],ARGV[1])else-- \u56e0\u4e3a\u7b2c\u4e00\u6b21\u9886\u53d6\u5df2\u7ecf\u8bbe\u7f6e\u4e86\u8fc7\u671f\u65f6\u95f4\uff0c\u7b2c\u4e8c\u6b21\u9886\u53d6\u6cbf\u7528\u4e4b\u524d\u5373\u53ef\n redis.call('INCR',KEYS[2])\nend\n\n-- \u51cf\u5c11\u4f18\u60e0\u5238\u5e93\u5b58\nredis.call('HINCRBY',KEYS[1],'stock',-1)returncombineFields(0, userCouponCount)<\/code><\/pre>\n\n\n\n\u8fd9\u91cc\u6211\u4eec\u8fd8\u662f\u91c7\u7528\u4e86\u4e4b\u524d\u7684\u7b56\u7565\uff0c\u5c06\u8fd4\u56de\u7684\u4e24\u4e2a\u53c2\u6570\u5305\u88c5\u4e3a\u4e00\u4e2a long \u7c7b\u578b\u7684\u6570\u636e\uff0c\u5e76\u8fdb\u884c\u62c6\u5206\u3002\u4e24\u4e2a\u53c2\u6570\u5206\u522b\u5982\u4e0b\uff1a<\/p>\n\n\n\n
\n- \u8bf7\u6c42\u662f\u5426\u6210\u529f\uff1a\u6709 3 \u4e2a\u53c2\u6570\uff0c0 \u4ee3\u8868\u8bf7\u6c42\u6210\u529f\uff0c1 \u4ee3\u8868\u4f18\u60e0\u5238\u5df2\u88ab\u9886\u53d6\u5b8c\u5566\uff0c2 \u4ee3\u8868\u7528\u6237\u5df2\u7ecf\u8fbe\u5230\u9886\u53d6\u4e0a\u9650\u3002<\/li>\n\n\n\n
- \u7528\u6237\u9886\u53d6\u6b21\u6570\uff1a\u521d\u59cb\u5316\u4e3a 0\uff0c\u6bcf\u6b21\u9886\u53d6\u6210\u529f\u540e\u81ea\u589e\u52a0 1\u3002<\/li>\n<\/ul>\n\n\n\n
\u5982\u679c\u8fd4\u56de 0,x \u4ee3\u8868\u8bf7\u6c42\u6210\u529f\uff0cx \u5c31\u662f\u76ee\u524d\u7528\u6237\u5df2\u9886\u53d6\u4f18\u60e0\u5238\u7684\u6b21\u6570\uff0c\u4f1a\u628a\u8fd9\u4e2a x \u4fdd\u5b58\u5230\u6570\u636e\u5e93\u8868 t_user_coupon<\/code> \u7684\u9886\u53d6\u6b21\u6570 receive_count \u5b57\u6bb5\u4e2d\u3002<\/code><\/p>\n\n\n\n\u4f18\u60e0\u5238\u4fdd\u5b58\u6570\u636e\u5e93<\/h2>\n\n\n\n1. \u6263\u51cf MySQL \u4f18\u60e0\u5238\u5e93\u5b58<\/h3>\n\n\n\n
\u56e0\u4e3a\u6211\u4eec\u8981\u52a0\u4e8b\u52a1\uff0c\u4e2d\u95f4\u9047\u5230\u95ee\u9898\u53ef\u4ee5\u56de\u6eda\u6570\u636e\u5e93\u4f18\u60e0\u5238\u6a21\u677f\u5e93\u5b58\uff0c\u4f46\u662f\u5982\u679c\u52a0\u5230\u6574\u4e2a\u65b9\u6cd5\u611f\u89c9\u53c8\u4e0d\u662f\u5f88\u5408\u9002\uff0c\u56e0\u4e3a\u524d\u9762\u7684\u9a8c\u8bc1\u662f\u4e0d\u9700\u8981\u4e8b\u52a1\u7684\u3002\u6240\u4ee5\uff0c\u6211\u4eec\u91c7\u7528\u7f16\u7a0b\u5f0f\u4e8b\u52a1\uff0c\u81ea\u5df1\u5f00\u542f\u3001\u63d0\u4ea4\u548c\u56de\u6eda\u4e8b\u52a1\u3002<\/p>\n\n\n\n
\u4ee3\u7801\u5982\u4e0b\u6240\u793a\uff1a<\/p>\n\n\n\n
privatefinalTransactionTemplate transactionTemplate;@OverridepublicvoidredeemUserCoupon(CouponTemplateRedeemReqDTO requestParam){\/\/ ......\/\/ \u901a\u8fc7\u7f16\u7a0b\u5f0f\u4e8b\u52a1\u6267\u884c\u4f18\u60e0\u5238\u5e93\u5b58\u81ea\u51cf\u4ee5\u53ca\u589e\u52a0\u7528\u6237\u4f18\u60e0\u5238\u9886\u53d6\u8bb0\u5f55long extractSecondField =StockDecrementReturnCombinedUtil.extractSecondField(stockDecrementLuaResult);\n transactionTemplate.executeWithoutResult(status ->{try{int decremented = couponTemplateMapper.decrementCouponTemplateStock(Long.parseLong(requestParam.getShopNumber()),Long.parseLong(requestParam.getCouponTemplateId()),1L);if(!SqlHelper.retBool(decremented)){thrownewServiceException(\"\u4f18\u60e0\u5238\u5df2\u88ab\u9886\u53d6\u5b8c\u5566\");}\/\/ \u6dfb\u52a0 Redis \u7528\u6237\u9886\u53d6\u7684\u4f18\u60e0\u5238\u8bb0\u5f55\u5217\u8868Date now =newDate();DateTime validEndTime =DateUtil.offsetHour(now,JSON.parseObject(couponTemplate.getConsumeRule()).getInteger(\"validityPeriod\"));UserCouponDO userCouponDO =UserCouponDO.builder().couponTemplateId(Long.parseLong(requestParam.getCouponTemplateId())).userId(Long.parseLong(UserContext.getUserId())).source(requestParam.getSource()).receiveCount(Long.valueOf(extractSecondField).intValue()).status(UserCouponStatusEnum.UNUSED.getCode()).receiveTime(now).validStartTime(now).validEndTime(validEndTime).build();\n userCouponMapper.insert(userCouponDO);}catch(Exception ex){\n status.setRollbackOnly();\/\/ \u4f18\u60e0\u5238\u5df2\u88ab\u9886\u53d6\u5b8c\u4e1a\u52a1\u5f02\u5e38if(ex instanceofServiceException){throw(ServiceException) ex;}if(ex instanceofDuplicateKeyException){\n log.error(\"\u7528\u6237\u91cd\u590d\u9886\u53d6\u4f18\u60e0\u5238\uff0c\u7528\u6237ID\uff1a{}\uff0c\u4f18\u60e0\u5238\u6a21\u677fID\uff1a{}\",UserContext.getUserId(), requestParam.getCouponTemplateId());thrownewServiceException(\"\u7528\u6237\u91cd\u590d\u9886\u53d6\u4f18\u60e0\u5238\");}thrownewServiceException(\"\u4f18\u60e0\u5238\u9886\u53d6\u5f02\u5e38\uff0c\u8bf7\u7a0d\u5019\u518d\u8bd5\");}});}<\/code><\/pre>\n\n\n\n\u6211\u4eec\u5728\u8fdb\u884c\u5e93\u5b58\u6263\u51cf\u65f6\uff0c\u91c7\u7528 MySQL \u7684\u884c\u8bb0\u5f55\u9501\u673a\u5236\u8fdb\u884c\u6263\u51cf\u3002\u5e76\u4e14\u5728\u6263\u51cf\u7684\u57fa\u7840\u4e0a\uff0c\u4e3a\u4e86\u907f\u514d\u88ab\u591a\u6263\uff0c\u5728\u5224\u65ad\u6761\u4ef6\u91cc\uff0c\u6211\u4eec\u52a0\u4e0a\u4e86\u5fc5\u987b\u5927\u4e8e\u7b49\u4e8e\u5f53\u524d\u5e93\u5b58\u624d\u53ef\u4ee5\u6263\u51cf\u6210\u529f\u3002<\/p>\n\n\n\n
\n\u4ece\u96f6\u5230\u4e00\u5206\u652f\u91cc\u6ce8\u91ca\u5199\u9519\u4e86\uff0c\u4ee5\u672c\u7ae0\u8282\u6ce8\u91ca\u4e3a\u4e3b\u3002<\/em><\/p>\n<\/blockquote>\n\n\n\nSQL \u5982\u4e0b\u6240\u793a\uff1a<\/p>\n\n\n\n
<!-- \u901a\u8fc7 MySQL \u7684\u884c\u8bb0\u5f55\u9501\u673a\u5236\u539f\u5b50\u6263\u51cf\u4f18\u60e0\u5238\u6a21\u677f\u5e93\u5b58 --><update id=\"decrementCouponTemplateStock\">UPDATE t_coupon_template\n SET stock = stock - #{decrementStock}WHERE shop_number = #{shopNumber}AND id = #{couponTemplateId}AND stock >= #{decrementStock}<\/update><\/code><\/pre>\n\n\n\n\u901a\u8fc7\u4e4b\u524d\u7684\u7ae0\u8282\u8bc1\u660e\uff0c\u8fd9\u4e2a SQL \u8bb0\u5f55\u672c\u8d28\u4e0a\u5e95\u5c42\u8fd8\u662f MySQL \u884c\u9501\uff0c\u907f\u514d\u6263\u51cf\u51b2\u7a81\u3002<\/p>\n\n\n\n
\n\u8be6\u60c5\u67e5\u770b\u725b\u5238\u4e4b\u524d\u7684 \u5386\u53f2\u6587\u7ae0<\/a> \u6587\u672b\u5185\u5bb9\uff0c\u6709\u8be6\u7ec6\u7684\u56fe\u6587\u8bb2\u89e3\u3002<\/em><\/p>\n<\/blockquote>\n\n\n\n2. \u6dfb\u52a0\u7528\u6237\u9886\u5238\u8bb0\u5f55<\/h3>\n\n\n\n
\u5982\u679c\u6263\u51cf\u6570\u636e\u5e93\u6210\u529f\uff0c\u90a3\u6211\u4eec\u5219\u5c06\u4f18\u60e0\u5238\u9886\u53d6\u8bb0\u5f55\u4fdd\u5b58\u5230 t_user_coupon<\/code> \u8868\u4e2d\u3002<\/p>\n\n\n\n\n\u6e29\u99a8\u63d0\u793a\uff0c\u56e0\u4e3a\u6211\u4eec\u662f\u5728\u914d\u7f6e\u4e2d\u56fa\u5b9a\u5199\u7684\u7528\u6237 ID\uff0c\u6240\u4ee5\u6570\u636e\u90fd\u4f1a\u5199\u5230 0 \u5e93\u7684 t_user_coupon_13<\/code> \u8868\u3002<\/em><\/p>\n<\/blockquote>\n\n\n\n\u5728\u8fd9\u91cc\uff0c\u6211\u4eec\u52a0\u4e86\u4e00\u4e9b\u4f18\u5316\uff0c\u90a3\u5c31\u662f\u6dfb\u52a0\u4f18\u60e0\u5238\u65f6\uff0c\u53ef\u80fd\u4f1a\u6709\u7528\u6237\u91cd\u590d\u9886\u5238\u51b2\u7a81\u3001\u518d\u6bd4\u5982\u6570\u636e\u5e93\u5b95\u673a\u4e4b\u7c7b\u7684\u95ee\u9898\uff0c\u6240\u4ee5\u6211\u4eec\u9488\u5bf9\u4e0d\u540c\u7684\u5f02\u5e38\u8fdb\u884c\u4e86\u524d\u7aef\u62a5\u9519\u4fe1\u606f\u63d0\u793a\u3002<\/p>\n\n\n\n
\u4ee3\u7801\u5982\u4e0b\u6240\u793a\uff1a<\/p>\n\n\n\n
if(ex instanceofServiceException){throw(ServiceException) ex;}if(ex instanceofDuplicateKeyException){\n log.error(\"\u7528\u6237\u91cd\u590d\u9886\u53d6\u4f18\u60e0\u5238\uff0c\u7528\u6237ID\uff1a{}\uff0c\u4f18\u60e0\u5238\u6a21\u677fID\uff1a{}\",UserContext.getUserId(), requestParam.getCouponTemplateId());thrownewServiceException(\"\u7528\u6237\u91cd\u590d\u9886\u53d6\u4f18\u60e0\u5238\");}thrownewServiceException(\"\u4f18\u60e0\u5238\u9886\u53d6\u5f02\u5e38\uff0c\u8bf7\u7a0d\u5019\u518d\u8bd5\");<\/code><\/pre>\n\n\n\n3. \u4fdd\u5b58\u7528\u6237\u9886\u5238\u7f13\u5b58<\/h3>\n\n\n\n
\u6dfb\u52a0\u6570\u636e\u5e93\u5982\u679c\u6ca1\u6709\u5f02\u5e38\u7684\u8bdd\uff0c\u90a3\u6211\u4eec\u5e94\u8be5\u5c06\u7528\u6237\u5df2\u9886\u53d6\u7684\u4f18\u60e0\u5238\u6dfb\u52a0\u5230 Redis \u7f13\u5b58\u4e2d\u3002<\/p>\n\n\n\n
\u4ee3\u7801\u5982\u4e0b\u6240\u793a\uff1a<\/p>\n\n\n\n
privatefinalTransactionTemplate transactionTemplate;@OverridepublicvoidredeemUserCoupon(CouponTemplateRedeemReqDTO requestParam){\/\/ ......\/\/ \u901a\u8fc7\u7f16\u7a0b\u5f0f\u4e8b\u52a1\u6267\u884c\u4f18\u60e0\u5238\u5e93\u5b58\u81ea\u51cf\u4ee5\u53ca\u589e\u52a0\u7528\u6237\u4f18\u60e0\u5238\u9886\u53d6\u8bb0\u5f55long extractSecondField =StockDecrementReturnCombinedUtil.extractSecondField(stockDecrementLuaResult);\n transactionTemplate.executeWithoutResult(status ->{try{\/\/ ......\/\/ \u6dfb\u52a0\u7528\u6237\u9886\u53d6\u4f18\u60e0\u5238\u6a21\u677f\u7f13\u5b58\u8bb0\u5f55String userCouponListCacheKey =String.format(EngineRedisConstant.USER_COUPON_TEMPLATE_LIST_KEY,UserContext.getUserId());String userCouponItemCacheKey =StrUtil.builder().append(requestParam.getCouponTemplateId()).append(\"_\").append(userCouponDO.getId()).toString();\n stringRedisTemplate.opsForZSet().add(userCouponListCacheKey, userCouponItemCacheKey, now.getTime());}catch(Exception ex){\n status.setRollbackOnly();\/\/ \u4f18\u60e0\u5238\u5df2\u88ab\u9886\u53d6\u5b8c\u4e1a\u52a1\u5f02\u5e38if(ex instanceofServiceException){throw(ServiceException) ex;}if(ex instanceofDuplicateKeyException){\n log.error(\"\u7528\u6237\u91cd\u590d\u9886\u53d6\u4f18\u60e0\u5238\uff0c\u7528\u6237ID\uff1a{}\uff0c\u4f18\u60e0\u5238\u6a21\u677fID\uff1a{}\",UserContext.getUserId(), requestParam.getCouponTemplateId());thrownewServiceException(\"\u7528\u6237\u91cd\u590d\u9886\u53d6\u4f18\u60e0\u5238\");}thrownewServiceException(\"\u4f18\u60e0\u5238\u9886\u53d6\u5f02\u5e38\uff0c\u8bf7\u7a0d\u5019\u518d\u8bd5\");}});}<\/code><\/pre>\n\n\n\n\u5927\u5bb6\u90fd\u77e5\u9053\uff0c\u5982\u679c\u4fdd\u5b58 Redis \u540e\uff0cRedis \u5373\u4f7f\u8fd4\u56de\u7ed9\u4f60\u6210\u529f\uff0c\u4f46\u662f\u6570\u636e\u4e0d\u4e00\u5b9a\u662f\u80fd\u6301\u4e45\u5316\u6210\u529f\u7684\uff0c\u56e0\u4e3a\u5728\u6781\u7aef\u5b95\u673a\u60c5\u51b5\u4e0b\uff0c\u6301\u4e45\u5316\u914d\u7f6e\u4e2d AOF \u6700\u4f18\u7ed3\u679c\u4e0b\uff0c\u4e5f\u662f\u4f1a\u4e22\u4e00\u6761\u6570\u636e\u7684\u3002<\/p>\n\n\n\n
\n\u8be6\u60c5\u67e5\u770b\uff1a\u5927\u8bdd\u9762\u8bd5\uff1aRedis\u5b95\u673a\u6570\u636e\u4f1a\u4e22\u5931\u4e48\uff1f<\/a><\/em><\/p>\n<\/blockquote>\n\n\n\n\u9664\u4e86\u6301\u4e45\u5316\u914d\u7f6e\uff0cRedis \u5982\u679c\u662f\u4e3b\u4ece\u914d\u7f6e\uff0c\u4e3b\u4ece\u6570\u636e\u540c\u6b65\u662f\u5f02\u6b65\u7684\uff0c\u5982\u679c\u4e3b\u8282\u70b9\u5199\u5165\u6210\u529f\uff0c\u8fd4\u56de\u5ba2\u6237\u7aef\u6210\u529f\uff0c\u8fd8\u6ca1\u6765\u5f97\u53ca\u540c\u6b65\u4ece\u8282\u70b9\u5b95\u673a\u4e86\uff0c\u4ece\u8282\u70b9\u6210\u4e3a\u4e3b\u8282\u70b9\uff0c\u90a3\u4e48\u8fd9\u4e2a\u6570\u636e\u5c31\u6210\u7cca\u6d82\u8d26\u4e86\u3002<\/p>\n\n\n\n
\u4e3a\u6b64\uff0c\u6211\u4eec\u5199\u4e86\u4e00\u4e2a\u5f88\u516b\u80a1\u7684\u5199\u6cd5\uff0c\u90a3\u5c31\u662f\u901a\u8fc7\u5148\u5199\u518d\u67e5\u3002<\/p>\n\n\n\n
\u4ee3\u7801\u5982\u4e0b\u6240\u793a\uff1a<\/p>\n\n\n\n
privatefinalTransactionTemplate transactionTemplate;@OverridepublicvoidredeemUserCoupon(CouponTemplateRedeemReqDTO requestParam){\/\/ ......\/\/ \u901a\u8fc7\u7f16\u7a0b\u5f0f\u4e8b\u52a1\u6267\u884c\u4f18\u60e0\u5238\u5e93\u5b58\u81ea\u51cf\u4ee5\u53ca\u589e\u52a0\u7528\u6237\u4f18\u60e0\u5238\u9886\u53d6\u8bb0\u5f55long extractSecondField =StockDecrementReturnCombinedUtil.extractSecondField(stockDecrementLuaResult);\n transactionTemplate.executeWithoutResult(status ->{try{\/\/ ......\/\/ \u6dfb\u52a0\u7528\u6237\u9886\u53d6\u4f18\u60e0\u5238\u6a21\u677f\u7f13\u5b58\u8bb0\u5f55String userCouponListCacheKey =String.format(EngineRedisConstant.USER_COUPON_TEMPLATE_LIST_KEY,UserContext.getUserId());String userCouponItemCacheKey =StrUtil.builder().append(requestParam.getCouponTemplateId()).append(\"_\").append(userCouponDO.getId()).toString();\n stringRedisTemplate.opsForZSet().add(userCouponListCacheKey, userCouponItemCacheKey, now.getTime());\/\/ \u7531\u4e8e Redis \u5728\u6301\u4e45\u5316\u6216\u4e3b\u4ece\u590d\u5236\u7684\u6781\u7aef\u60c5\u51b5\u4e0b\u53ef\u80fd\u4f1a\u51fa\u73b0\u6570\u636e\u4e22\u5931\uff0c\u800c\u6211\u4eec\u5bf9\u6307\u4ee4\u4e22\u5931\u51e0\u4e4e\u65e0\u6cd5\u5bb9\u5fcd\uff0c\u56e0\u6b64\u6211\u4eec\u91c7\u7528\u7ecf\u5178\u7684\u5199\u540e\u67e5\u8be2\u7b56\u7565\u6765\u5e94\u5bf9\u8fd9\u4e00\u95ee\u9898Double scored;try{\n scored = stringRedisTemplate.opsForZSet().score(userCouponListCacheKey, userCouponItemCacheKey);\/\/ scored \u4e3a\u7a7a\u610f\u5473\u7740\u53ef\u80fd Redis Cluster \u4e3b\u4ece\u540c\u6b65\u4e22\u5931\u4e86\u6570\u636e\uff0c\u6bd4\u5982 Redis \u4e3b\u8282\u70b9\u8fd8\u6ca1\u6709\u540c\u6b65\u5230\u4ece\u8282\u70b9\u5c31\u5b95\u673a\u4e86\uff0c\u89e3\u51b3\u65b9\u6848\u5c31\u662f\u518d\u65b0\u589e\u4e00\u6b21if(scored ==null){\/\/ \u5982\u679c\u8fd9\u91cc\u4e5f\u65b0\u589e\u5931\u8d25\u4e86\u600e\u4e48\u529e\uff1f\u6211\u4eec\u5927\u6982\u7387\u505a\u4e0d\u5230\u7edd\u5bf9\u7684\u4e07\u65e0\u4e00\u5931\uff0c\u53ea\u80fd\u5c3d\u53ef\u80fd\u589e\u52a0\u6210\u529f\u7387\n stringRedisTemplate.opsForZSet().add(userCouponListCacheKey, userCouponItemCacheKey, now.getTime());}}catch(Throwable ex){\n log.warn(\"\u67e5\u8be2Redis\u7528\u6237\u4f18\u60e0\u5238\u8bb0\u5f55\u4e3a\u7a7a\u6216\u629b\u5f02\u5e38\uff0c\u53ef\u80fdRedis\u5b95\u673a\u6216\u4e3b\u4ece\u590d\u5236\u6570\u636e\u4e22\u5931\uff0c\u57fa\u7840\u9519\u8bef\u4fe1\u606f\uff1a{}\", ex.getMessage());\/\/ \u5982\u679c\u76f4\u63a5\u629b\u5f02\u5e38\u5927\u6982\u7387 Redis \u5b95\u673a\u4e86\uff0c\u6240\u4ee5\u5e94\u8be5\u5199\u4e2a\u5ef6\u65f6\u961f\u5217\u5411 Redis \u91cd\u8bd5\u653e\u5165\u503c\u3002\u4e3a\u4e86\u907f\u514d\u4ee3\u7801\u590d\u6742\u6027\uff0c\u8fd9\u91cc\u76f4\u63a5\u5199\u65b0\u589e\uff0c\u5927\u5bb6\u77e5\u9053\u6700\u4f18\u89e3\u51b3\u65b9\u6848\u5373\u53ef\n stringRedisTemplate.opsForZSet().add(userCouponListCacheKey, userCouponItemCacheKey, now.getTime());}}catch(Exception ex){\n status.setRollbackOnly();\/\/ \u4f18\u60e0\u5238\u5df2\u88ab\u9886\u53d6\u5b8c\u4e1a\u52a1\u5f02\u5e38if(ex instanceofServiceException){throw(ServiceException) ex;}if(ex instanceofDuplicateKeyException){\n log.error(\"\u7528\u6237\u91cd\u590d\u9886\u53d6\u4f18\u60e0\u5238\uff0c\u7528\u6237ID\uff1a{}\uff0c\u4f18\u60e0\u5238\u6a21\u677fID\uff1a{}\",UserContext.getUserId(), requestParam.getCouponTemplateId());thrownewServiceException(\"\u7528\u6237\u91cd\u590d\u9886\u53d6\u4f18\u60e0\u5238\");}thrownewServiceException(\"\u4f18\u60e0\u5238\u9886\u53d6\u5f02\u5e38\uff0c\u8bf7\u7a0d\u5019\u518d\u8bd5\");}});}<\/code><\/pre>\n\n\n\n4. \u53d1\u9001\u4f18\u60e0\u5238\u5230\u671f\u4e8b\u4ef6<\/h3>\n\n\n\n
\u5728\u4e0a\u9762\u4ee3\u7801\u7684\u57fa\u7840\u4e0a\uff0c\u5982\u679c\u90fd\u6267\u884c\u6210\u529f\uff0c\u6211\u4eec\u9700\u8981\u53d1\u9001\u4e2a RocketMQ \u5ef6\u65f6\u961f\u5217\uff0c\u5728\u6307\u5b9a\u65f6\u95f4\u540e\u5c06\u4f18\u60e0\u5238\u6a21\u677f\u7684\u72b6\u6001\u8bbe\u7f6e\u4e3a\u5df2\u8fc7\u671f\u72b6\u6001\u3002<\/p>\n\n\n\n
\u4ee3\u7801\u5982\u4e0b\u6240\u793a\uff1a<\/p>\n\n\n\n
privatefinalTransactionTemplate transactionTemplate;\n\u200b\n@OverridepublicvoidredeemUserCoupon(CouponTemplateRedeemReqDTO requestParam){\/\/ ......\n\u200b\n \/\/ \u901a\u8fc7\u7f16\u7a0b\u5f0f\u4e8b\u52a1\u6267\u884c\u4f18\u60e0\u5238\u5e93\u5b58\u81ea\u51cf\u4ee5\u53ca\u589e\u52a0\u7528\u6237\u4f18\u60e0\u5238\u9886\u53d6\u8bb0\u5f55long extractSecondField =StockDecrementReturnCombinedUtil.extractSecondField(stockDecrementLuaResult);\n transactionTemplate.executeWithoutResult(status ->{try{\/\/ ......\n\u200b\n \/\/ \u6dfb\u52a0\u7528\u6237\u9886\u53d6\u4f18\u60e0\u5238\u6a21\u677f\u7f13\u5b58\u8bb0\u5f55String userCouponListCacheKey =String.format(EngineRedisConstant.USER_COUPON_TEMPLATE_LIST_KEY,UserContext.getUserId());String userCouponItemCacheKey =StrUtil.builder().append(requestParam.getCouponTemplateId()).append(\"_\").append(userCouponDO.getId()).toString();\n stringRedisTemplate.opsForZSet().add(userCouponListCacheKey, userCouponItemCacheKey, now.getTime());\n\u200b\n \/\/ \u7531\u4e8e Redis \u5728\u6301\u4e45\u5316\u6216\u4e3b\u4ece\u590d\u5236\u7684\u6781\u7aef\u60c5\u51b5\u4e0b\u53ef\u80fd\u4f1a\u51fa\u73b0\u6570\u636e\u4e22\u5931\uff0c\u800c\u6211\u4eec\u5bf9\u6307\u4ee4\u4e22\u5931\u51e0\u4e4e\u65e0\u6cd5\u5bb9\u5fcd\uff0c\u56e0\u6b64\u6211\u4eec\u91c7\u7528\u7ecf\u5178\u7684\u5199\u540e\u67e5\u8be2\u7b56\u7565\u6765\u5e94\u5bf9\u8fd9\u4e00\u95ee\u9898Double scored;try{\n scored = stringRedisTemplate.opsForZSet().score(userCouponListCacheKey, userCouponItemCacheKey);\/\/ scored \u4e3a\u7a7a\u610f\u5473\u7740\u53ef\u80fd Redis Cluster \u4e3b\u4ece\u540c\u6b65\u4e22\u5931\u4e86\u6570\u636e\uff0c\u6bd4\u5982 Redis \u4e3b\u8282\u70b9\u8fd8\u6ca1\u6709\u540c\u6b65\u5230\u4ece\u8282\u70b9\u5c31\u5b95\u673a\u4e86\uff0c\u89e3\u51b3\u65b9\u6848\u5c31\u662f\u518d\u65b0\u589e\u4e00\u6b21if(scored ==null){\/\/ \u5982\u679c\u8fd9\u91cc\u4e5f\u65b0\u589e\u5931\u8d25\u4e86\u600e\u4e48\u529e\uff1f\u6211\u4eec\u5927\u6982\u7387\u505a\u4e0d\u5230\u7edd\u5bf9\u7684\u4e07\u65e0\u4e00\u5931\uff0c\u53ea\u80fd\u5c3d\u53ef\u80fd\u589e\u52a0\u6210\u529f\u7387\n stringRedisTemplate.opsForZSet().add(userCouponListCacheKey, userCouponItemCacheKey, now.getTime());}}catch(Throwable ex){\n log.warn(\"\u67e5\u8be2Redis\u7528\u6237\u4f18\u60e0\u5238\u8bb0\u5f55\u4e3a\u7a7a\u6216\u629b\u5f02\u5e38\uff0c\u53ef\u80fdRedis\u5b95\u673a\u6216\u4e3b\u4ece\u590d\u5236\u6570\u636e\u4e22\u5931\uff0c\u57fa\u7840\u9519\u8bef\u4fe1\u606f\uff1a{}\", ex.getMessage());\/\/ \u5982\u679c\u76f4\u63a5\u629b\u5f02\u5e38\u5927\u6982\u7387 Redis \u5b95\u673a\u4e86\uff0c\u6240\u4ee5\u5e94\u8be5\u5199\u4e2a\u5ef6\u65f6\u961f\u5217\u5411 Redis \u91cd\u8bd5\u653e\u5165\u503c\u3002\u4e3a\u4e86\u907f\u514d\u4ee3\u7801\u590d\u6742\u6027\uff0c\u8fd9\u91cc\u76f4\u63a5\u5199\u65b0\u589e\uff0c\u5927\u5bb6\u77e5\u9053\u6700\u4f18\u89e3\u51b3\u65b9\u6848\u5373\u53ef\n stringRedisTemplate.opsForZSet().add(userCouponListCacheKey, userCouponItemCacheKey, now.getTime());}\n\u200b\n \/\/ \u53d1\u9001\u5ef6\u65f6\u6d88\u606f\u961f\u5217\uff0c\u7b49\u5f85\u4f18\u60e0\u5238\u5230\u671f\u540e\uff0c\u5c06\u4f18\u60e0\u5238\u4fe1\u606f\u4ece\u7f13\u5b58\u4e2d\u5220\u9664UserCouponDelayCloseEvent userCouponDelayCloseEvent =UserCouponDelayCloseEvent.builder().couponTemplateId(requestParam.getCouponTemplateId()).userCouponId(String.valueOf(userCouponDO.getId())).userId(UserContext.getUserId()).delayTime(validEndTime.getTime()).build();SendResult sendResult = couponDelayCloseProducer.sendMessage(userCouponDelayCloseEvent);\n\u200b\n \/\/ \u53d1\u9001\u6d88\u606f\u5931\u8d25\u89e3\u51b3\u65b9\u6848\u7b80\u5355\u4e14\u9ad8\u6548\u7684\u903b\u8f91\u4e4b\u4e00\uff1a\u6253\u5370\u65e5\u5fd7\u5e76\u62a5\u8b66\uff0c\u901a\u8fc7\u65e5\u5fd7\u641c\u96c6\u5e76\u91cd\u65b0\u6295\u9012if(ObjectUtil.notEqual(sendResult.getSendStatus().name(),\"SEND_OK\")){\n log.warn(\"\u53d1\u9001\u4f18\u60e0\u5238\u5173\u95ed\u5ef6\u65f6\u961f\u5217\u5931\u8d25\uff0c\u6d88\u606f\u53c2\u6570\uff1a{}\",JSON.toJSONString(userCouponDelayCloseEvent));}}catch(Exception ex){\n status.setRollbackOnly();\/\/ \u4f18\u60e0\u5238\u5df2\u88ab\u9886\u53d6\u5b8c\u4e1a\u52a1\u5f02\u5e38if(ex instanceofServiceException){throw(ServiceException) ex;}if(ex instanceofDuplicateKeyException){\n log.error(\"\u7528\u6237\u91cd\u590d\u9886\u53d6\u4f18\u60e0\u5238\uff0c\u7528\u6237ID\uff1a{}\uff0c\u4f18\u60e0\u5238\u6a21\u677fID\uff1a{}\",UserContext.getUserId(), requestParam.getCouponTemplateId());thrownewServiceException(\"\u7528\u6237\u91cd\u590d\u9886\u53d6\u4f18\u60e0\u5238\");}thrownewServiceException(\"\u4f18\u60e0\u5238\u9886\u53d6\u5f02\u5e38\uff0c\u8bf7\u7a0d\u5019\u518d\u8bd5\");}});}<\/code><\/pre>\n\n\n\n\u91cd\u6784\u4f18\u60e0\u5238\u79d2\u6740\u65b9\u6848<\/h2>\n\n\n\n1. \u73b0\u6709\u6280\u672f\u65b9\u6848\u95ee\u9898<\/h3>\n\n\n\n
\u7ec6\u5fc3\u7684\u540c\u5b66\u53ef\u80fd\u53d1\u73b0\u4e86\u4e00\u4e2a\u95ee\u9898\uff0c\u5728\u5982\u6b64\u9ad8\u5e76\u53d1\u7684\u573a\u666f\u4e0b\uff0c\u5728\u4e00\u4e2a\u4e8b\u52a1\u4e2d\u64cd\u4f5c\u4e86\u8fd9\u4e48\u591a Redis \u548c RocketMQ\uff0c\u5c31\u4f1a\u5bfc\u81f4\u4e8b\u52a1\u65f6\u95f4\u5ef6\u957f\u4ee5\u53ca\u63a5\u53e3\u54cd\u5e94\u901f\u5ea6\u53d8\u6162\u7b49\u95ee\u9898\u3002<\/p>\n\n\n\n
\u6211\u4eec\u5728\u5151\u6362\/\u79d2\u6740\u4f18\u60e0\u5238\u63a5\u53e3\u7684\u4e8b\u52a1\u4e2d\u5171\u6267\u884c\u4e86\u4ee5\u4e0b\u903b\u8f91\uff1a<\/p>\n\n\n\n
\n- 1.\u64cd\u4f5c\u4f18\u60e0\u5238\u5e93\u5b58\u8868\u8fdb\u884c\u6263\u51cf\u5e93\u5b58\uff1b<\/li>\n\n\n\n
- 2.\u6dfb\u52a0\u4f18\u60e0\u5238\u6a21\u677f\u5230\u7528\u6237\u9886\u5238\u8868\uff1b<\/li>\n\n\n\n
- 3.\u4fdd\u5b58\u4f18\u60e0\u5238\u6a21\u677f\u5230\u7528\u6237 Redis \u9886\u5238\u8bb0\u5f55\u4e2d\uff1b<\/li>\n\n\n\n
- 4.\u67e5\u8be2\u7528\u6237 Redis \u9886\u5238\u8bb0\u5f55\u662f\u5426\u6301\u4e45\u5316\u6210\u529f\uff1b<\/li>\n\n\n\n
- 5.\u53d1\u9001 RocketMQ \u6d88\u606f\u961f\u5217\u5ef6\u65f6\u6d88\u606f\uff0c\u5230\u671f\u4fee\u6539\u7528\u6237\u4f18\u60e0\u5238\u72b6\u6001\u3002<\/li>\n<\/ol>\n\n\n\n
\u5176\u4e2d 3\u30014\u30015 \u6b65\u9aa4\u903b\u8f91\u90fd\u662f\u5728\u6570\u636e\u5e93\u64cd\u4f5c\u6210\u529f\u7684\u57fa\u7840\u4e0a\u6267\u884c\u7684\uff0c\u90a3\u6211\u4eec\u5c31\u53ef\u4ee5\u901a\u8fc7 Canal \u76d1\u542c Binlog \u673a\u5236\uff0c\u5f02\u6b65\u6267\u884c\u8fd9\u4e9b\u903b\u8f91\u5c31\u597d\u4e86\uff0c\u8fd9\u6837\u5c31\u80fd\u4e0d\u5360\u7528\u4e3b\u903b\u8f91\u7684\u4e8b\u52a1\u548c\u54cd\u5e94\u65f6\u95f4\u4e86\u3002<\/p>\n\n\n\n
2. Canal \u6539\u9020\u73b0\u6709\u79d2\u6740\u67b6\u6784<\/h3>\n\n\n\n2.1 \u4ec0\u4e48\u662f Canal<\/h4>\n\n\n\n
\u8bd1\u610f\u4e3a\u6c34\u9053\/\u7ba1\u9053\/\u6c9f\u6e20\uff0c\u4e3b\u8981\u7528\u9014\u662f\u57fa\u4e8e MySQL \u6570\u636e\u5e93\u589e\u91cf\u65e5\u5fd7\u89e3\u6790\uff0c\u63d0\u4f9b\u589e\u91cf\u6570\u636e\u8ba2\u9605\u548c\u6d88\u8d39\u3002<\/p>\n\n\n\n![\"\"](\"https:\/\/oss.open8gu.com\/68747470733a2f2f696d672d626c6f672e6373646e696d672e636e2f32303139313130343130313733353934372e706e67.png\" "\\"\\"\/")
<\/figure>\n\n\n\n\n\n\u57fa\u4e8e\u65e5\u5fd7\u589e\u91cf\u8ba2\u9605\u548c\u6d88\u8d39\u7684\u4e1a\u52a1\u5305\u62ec\uff1a<\/p>\n\n\n\n
\n- \u6570\u636e\u5e93\u955c\u50cf<\/li>\n\n\n\n
- \u6570\u636e\u5e93\u5b9e\u65f6\u5907\u4efd<\/li>\n\n\n\n
- \u7d22\u5f15\u6784\u5efa\u548c\u5b9e\u65f6\u7ef4\u62a4(\u62c6\u5206\u5f02\u6784\u7d22\u5f15\u3001\u5012\u6392\u7d22\u5f15\u7b49)<\/li>\n\n\n\n
- \u4e1a\u52a1 cache \u5237\u65b0<\/li>\n\n\n\n
- \u5e26\u4e1a\u52a1\u903b\u8f91\u7684\u589e\u91cf\u6570\u636e\u5904\u7406<\/li>\n<\/ul>\n\n\n\n
2.2 MySQL \u5f00\u542f Binlog \u76d1\u542c<\/h4>\n\n\n\n
\u5bf9\u4e8e\u81ea\u5efa MySQL , \u9700\u8981\u5148\u5f00\u542f Binlog \u5199\u5165\u529f\u80fd\uff0cmy.cnf \u4e2d\u914d\u7f6e\u9700\u8981\u5305\u542b\u5982\u4e0b\u4fe1\u606f\u3002<\/p>\n\n\n\n
[mysqld]\nlog-bin=mysql-bin # \u5f00\u542f binlog\nbinlog-format=ROW# \u9009\u62e9 ROW \u6a21\u5f0f\nserver_id=1# \u914d\u7f6e MySQL replaction \u9700\u8981\u5b9a\u4e49\uff0c\u4e0d\u8981\u548c canal \u7684 slaveId \u91cd\u590d<\/code><\/pre>\n\n\n\n\u914d\u7f6e\u4fee\u6539\u6210\u529f\u540e\uff0c\u91cd\u542f\u4e00\u4e0b MySQL\uff0c\u786e\u4fdd\u6240\u6709\u7684\u914d\u7f6e\u751f\u6548\u3002\u7136\u540e\u6267\u884c MySQL \u6267\u884c\u547d\u4ee4\u67e5\u770b\u662f\u5426\u4fee\u6539 Binlog \u6210\u529f\u3002<\/p>\n\n\n\n
# \u67e5\u770b binlog \u65e5\u5fd7\u662f\u5426\u5f00\u542fshow variables like'log_%';<\/code><\/pre>\n\n\n\n\u5982\u679c\u67e5\u8be2\u51fa\u7684\u9009\u578b log_bin \u6570\u636e\u4e3a ON\uff0cBinlog \u5373\u4e3a\u5f00\u542f\u72b6\u6001\u3002\u8f93\u51fa\u5982\u4e0b\uff1a<\/p>\n\n\n\n
mysql>show variables like'log_%';+----------------------------------------+-----------------------------------------+| Variable_name |Value|+----------------------------------------+-----------------------------------------+| log_bin |ON|| log_bin_basename |\/opt\/homebrew\/var\/mysql\/mysql-bin || log_bin_index |\/opt\/homebrew\/var\/mysql\/mysql-bin.index|| log_bin_trust_function_creators |OFF|| log_bin_use_v1_row_events |OFF|| log_builtin_as_identified_by_password |OFF|| log_error |.\/bogon.err || log_error_verbosity |3|| log_output |FILE|| log_queries_not_using_indexes |OFF|| log_slave_updates |OFF|| log_slow_admin_statements |OFF|| log_slow_slave_statements |OFF|| log_statements_unsafe_for_binlog |ON|| log_syslog |OFF|| log_syslog_facility | daemon || log_syslog_include_pid |ON|| log_syslog_tag ||| log_throttle_queries_not_using_indexes |0|| log_timestamps | UTC || log_warnings |2|+----------------------------------------+-----------------------------------------+21rowsinset(0.00 sec)<\/code><\/pre>\n\n\n\n\u6700\u540e\uff0cMySQL \u6267\u884c SQL \u8bed\u53e5\u521b\u5efa canal \u5355\u72ec\u4f7f\u7528\u7684\u8d26\u53f7\uff0c\u7528\u6765\u8fdb\u884c Binlog \u7684\u540c\u6b65\u548c\u76d1\u542c\u3002<\/p>\n\n\n\n
CREATEUSER canal IDENTIFIED BY'canal';GRANTSELECT,REPLICATION SLAVE,REPLICATION CLIENT ON*.*TO'canal'@'%';\nFLUSH PRIVILEGES;<\/code><\/pre>\n\n\n\n2.3 \u5b89\u88c5 Canal \u4e2d\u95f4\u4ef6<\/h4>\n\n\n\n
\u63a5\u4e0b\u6765\u5f00\u59cb\u914d\u7f6e Canal \u4e2d\u95f4\u4ef6\uff0c\u4e0b\u8f7d Canal \u5b89\u88c5\u5305\uff0c\u5176\u4e2d\u7684\u4e00\u4e9b\u914d\u7f6e\u90fd\u662f\u6211\u8c03\u8bd5\u540e\u7684\u3002<\/p>\n\n\n\n
\u901a\u8fc7\u7f51\u76d8\u5206\u4eab\u7684\u6587\u4ef6\uff1acanal.deployer-1.1.6-oneCoupon.zip \u94fe\u63a5: https:\/\/pan.baidu.com\/s\/1h9dLEl2g7oSdz9YuNC70rw?pwd=9tfb<\/a> \u63d0\u53d6\u7801: 9tfb<\/p>\n\n\n\n
\n\n\n\n\u5982\u679c\u672c\u5730 MySQL \u4e0d\u662f 127.0.0.1:3306<\/code> \u914d\u7f6e\uff0c\u9700\u8981\u5c06 instance.properties<\/code> \u914d\u7f6e\u6587\u4ef6\u4e2d\u7684 canal.instance.master.address<\/code> \u914d\u7f6e\u9879\u66ff\u6362\u4e3a\u771f\u5b9e\u7684 MySQL \u5730\u5740\u548c\u7aef\u53e3\u3002<\/p>\n\n\n\n![\"img\"](\"https:\/\/oss.open8gu.com\/1693188412856-1ee64d6f-1340-48c0-85c6-bec5962e3974.png\" "\\"img\\"\/")
<\/figure>\n\n\n\n\n\n\u5982\u679c\u4f60\u662f\u81ea\u5df1\u672c\u5730\u542f\u52a8\u7684 RocketMQ\uff0c\u5c06 canal.properties<\/code>\u6587\u4ef6\u4e2d\u7684 rocketmq.namesrv.addr<\/code> \u914d\u7f6e\u9879\u53d8\u66f4\u4e3a\u81ea\u5df1\u672c\u5730\u7684 RocketMQ \u914d\u7f6e\uff0c\u9ed8\u8ba4\u4e3a\u516c\u6709\u4e91\u4e2d\u95f4\u4ef6\u5730\u5740\u3002<\/p>\n\n\n\n\u5982\u679c\u4f60\u6b63\u5728\u4f7f\u7528\u516c\u6709\u4e91 RocketMQ\uff0cinstance.properties<\/code> \u914d\u7f6e\u6587\u4ef6\u4e2d\u7684 canal.mq.topic<\/code> \u4e5f\u9700\u8981\u53d8\u66f4\uff0c\u914d\u7f6e\u4e2d\u9ed8\u8ba4\u4e3a one-coupon_canal_engine-service_common-sync_topic-mading<\/code>\uff0c-mading<\/code> \u9700\u8981\u5927\u5bb6\u53d8\u66f4\u4e3a\u81ea\u5df1\u5728\u9879\u76ee\u542f\u52a8 VM \u53c2\u6570\u91cc\u7684\u503c\u3002\u5404\u81ea\u68c0\u67e5\u5e76\u8fdb\u884c\u66ff\u6362\u3002<\/p>\n\n\n\n-Dunique-name=-mading<\/code><\/pre>\n\n\n\n\n\u5982\u679c\u8fd9\u4e00\u6b65\u6709\u95ee\u9898\uff0c\u662f\u6ca1\u6709\u529e\u6cd5\u53d1\u9001\u5230 RocketMQ \u987a\u5229\u6d88\u8d39\u7684\u3002<\/em><\/p>\n<\/blockquote>\n\n\n\n\u5168\u90e8\u4e0a\u8ff0\u914d\u7f6e\u5927\u5bb6\u5168\u90fd\u641e\u5b9a\u540e\uff0c\u5f00\u59cb\u542f\u52a8 Canal \u8fdb\u884c\u6d4b\u8bd5\u3002\u5982\u679c\u662f Windows \u7cfb\u7edf\uff0c\u76f4\u63a5\u53cc\u51fb Canal \u6587\u4ef6\u5939\u4e0b bin \u76ee\u5f55\u7684 startup.bat<\/code> \u811a\u672c\u5373\u53ef\uff0c\u8981\u505c\u6b62 Canal \u5173\u95ed\u811a\u672c\u5f39\u6846\u3002\u5982\u679c\u662f Linux \u6216\u8005 Mac \u7cfb\u7edf\uff0c\u8fdb\u5165 bin \u76ee\u5f55\u4e0b\u6267\u884c sh startup.sh<\/code> \u547d\u4ee4\u3002\u5982\u679c\u662f Linux \u6216\u8005 Mac \u7cfb\u7edf\u8981\u505c\u6b62\u6267\u884c sh stop.sh<\/code>\u3002<\/p>\n\n\n\n\n\u6ce8\u610f\uff0cCanal \u5b89\u88c5\u8def\u5f84\u4e2d\u4e0d\u8981\u6709\u6587\u4ef6\u5939\u540d\u79f0\u662f\u4e2d\u6587\u3002\u9700\u8981\u4f7f\u7528 JDK8 \u542f\u52a8 Canal \u670d\u52a1\uff0c\u4e0d\u8981\u4f7f\u7528 JDK17\u3002<\/em><\/p>\n<\/blockquote>\n\n\n\n\u542f\u52a8\u5b8c\u6210\u540e\uff0c\u6253\u5f00 logs \u6587\u4ef6\u5939\u76ee\u5f55\u4e0b\u7684 canal\/canal.log \u6587\u4ef6\u3002<\/p>\n\n\n\n![\"\"](\"https:\/\/oss.open8gu.com\/1692516470662-57239ae0-69bd-422e-a565-c2ec8f10fdc8.png\" "\\"\\"\/")
<\/figure>\n\n\n\n\n\n\u67e5\u770b\u662f\u5426\u542f\u52a8\u6210\u529f\uff0c\u5982\u679c\u8f93\u51fa\u6253\u5370\u5982\u4e0b the canal server is running now<\/code>\uff0c\u5373\u4e3a\u6210\u529f\u3002<\/p>\n\n\n\n![\"\"](\"https:\/\/oss.open8gu.com\/1692516510577-0d0a3cda-ed76-4214-9880-0588bdb98d1a.png\" "\\"\\"\/")
<\/figure>\n\n\n\n\n\n\u7136\u540e\uff0c\u6211\u4eec\u53d8\u66f4\u6570\u636e\u5e93 t_user_coupon<\/code> \u8868\u4e2d\u4efb\u610f\u4e00\u6761\u8bb0\u5f55\u7684 status \u503c\uff0c\u6bd4\u5982\u4ece 0 \u53d8\u4e3a 1\uff0c\u6216\u8005\u4ece 1 \u53d8\u4e3a 0\u3002<\/p>\n\n\n\n\u63a5\u4e0b\u6765\u67e5\u770b RocketMQ \u63a7\u5236\u53f0\u3002<\/p>\n\n\n\n
\n- \u8bbf\u95ee\u5730\u5740\uff1ahttp:\/\/common-rocketmq-dev.magestack.cn:8088\/#\/message<\/a><\/li>\n<\/ul>\n\n\n\n
\u9875\u9762\u914d\u7f6e\u67e5\u8be2\u5982\u4e0b\uff0c\u9009\u62e9\u597d\u4e3b\u9898\u548c\u5f00\u59cb\u7ed3\u675f\u65f6\u95f4\uff08\u9ed8\u8ba4\u4f1a\u586b\u5145\uff09\u540e\uff0c\u70b9\u51fb\u641c\u7d22\u6309\u94ae\u3002<\/p>\n\n\n\n\n\n
\u6d88\u606f\u4f53\u683c\u5f0f\u4e3a JSON \u7c7b\u578b\u6570\u636e\uff0c\u793a\u4f8b\u6570\u636e\u5982\u4e0b\uff1a<\/p>\n\n\n\n
{\"data\":[{\"id\":\"1832782304792027137\",\"user_id\":\"1810518709471555585\",\"coupon_template_id\":\"1832782251755053058\",\"receive_time\":\"2024-09-08 22:05:28\",\"receive_count\":\"1\",\"valid_start_time\":\"2024-09-08 22:05:28\",\"valid_end_time\":\"2024-09-10 22:05:28\",\"use_time\":null,\"source\":\"0\",\"status\":\"1\",\"create_time\":\"2024-09-08 22:05:28\",\"update_time\":\"2024-09-08 22:05:28\",\"del_flag\":\"0\"}],\"database\":\"one_coupon_0\",\"es\":1725881100000,\"id\":2,\"isDdl\":false,\"mysqlType\":{\"id\":\"bigint(20)\",\"user_id\":\"bigint(20)\",\"coupon_template_id\":\"bigint(20)\",\"receive_time\":\"datetime\",\"receive_count\":\"int(3)\",\"valid_start_time\":\"datetime\",\"valid_end_time\":\"datetime\",\"use_time\":\"datetime\",\"source\":\"tinyint(1)\",\"status\":\"tinyint(1)\",\"create_time\":\"datetime\",\"update_time\":\"datetime\",\"del_flag\":\"tinyint(1)\"},\"old\":[{\"status\":\"0\"}],\"pkNames\":[\"id\"],\"sql\":\"\",\"sqlType\":{\"id\":-5,\"user_id\":-5,\"coupon_template_id\":-5,\"receive_time\":93,\"receive_count\":4,\"valid_start_time\":93,\"valid_end_time\":93,\"use_time\":93,\"source\":-6,\"status\":-6,\"create_time\":93,\"update_time\":93,\"del_flag\":-6},\"table\":\"t_user_coupon_13\",\"ts\":1725881101080,\"type\":\"UPDATE\"}<\/code><\/pre>\n\n\n\n\u5bf9\u5e94\u914d\u7f6e\u5b57\u6bb5\u4fe1\u606f\u7684\u8bed\u610f\u5982\u4e0b\uff1a<\/p>\n\n\n\n
\/**\n * Canal Binlog \u76d1\u542c\u89e6\u53d1\u4e8b\u4ef6\n *\/@DatapublicclassCanalBinlogEvent{\n\u200b\n \/**\n * \u53d8\u66f4\u6570\u636e\n *\/privateList<Map<String, Object>> data;\n\u200b\n \/**\n * \u6570\u636e\u5e93\u540d\u79f0\n *\/privateString database;\n\u200b\n \/**\n * es \u662f\u6307 Mysql Binlog \u91cc\u539f\u59cb\u7684\u65f6\u95f4\u6233\uff0c\u4e5f\u5c31\u662f\u6570\u636e\u539f\u59cb\u53d8\u66f4\u7684\u65f6\u95f4\n * Canal \u7684\u6d88\u8d39\u5ef6\u8fdf = ts - es\n *\/privateLong es;\n\u200b\n \/**\n * \u9012\u589e ID\uff0c\u4ece 1 \u5f00\u59cb\n *\/privateLong id;\n\u200b\n \/**\n * \u5f53\u524d\u53d8\u66f4\u662f\u5426\u662f DDL \u8bed\u53e5\n *\/privateBoolean isDdl;\n\u200b\n \/**\n * \u8868\u7ed3\u6784\u5b57\u6bb5\u7c7b\u578b\n *\/privateMap<String, Object> mysqlType;\n\u200b\n \/**\n * UPDATE \u6a21\u5f0f\u4e0b\u65e7\u6570\u636e\n *\/privateList<Map<String, Object>> old;\n\u200b\n \/**\n * \u4e3b\u952e\u540d\u79f0\n *\/privateList<String> pkNames;\n\u200b\n \/**\n * SQL \u8bed\u53e5\n *\/privateString sql;\n\u200b\n \/**\n * SQL \u7c7b\u578b\n *\/privateMap<String, Object> sqlType;\n\u200b\n \/**\n * \u8868\u540d\n *\/privateString table;\n\u200b\n \/**\n * ts \u662f\u6307 Canal \u6536\u5230\u8fd9\u4e2a Binlog\uff0c\u6784\u9020\u4e3a\u81ea\u5df1\u534f\u8bae\u5bf9\u8c61\u7684\u65f6\u95f4\n * \u5e94\u7528\u6d88\u8d39\u7684\u5ef6\u8fdf = now - ts\n *\/privateLong ts;\n\u200b\n \/**\n * INSERT\uff08\u65b0\u589e\uff09\u3001UPDATE\uff08\u66f4\u65b0\uff09\u3001DELETE\uff08\u5220\u9664\uff09\u7b49\u7b49\n *\/privateString type;}<\/code><\/pre>\n\n\n\n2.4 \u76d1\u542c Canal RocketMQ Topic<\/h4>\n\n\n\n
\u4e00\u822c\u6765\u8bf4\uff0c\u9488\u5bf9\u9ad8\u5e76\u53d1\u7684 Binlog \u76d1\u542c\uff0c\u6211\u4eec\u90fd\u662f\u5c06 Canal \u7684 Binlog \u6570\u636e\u4e22\u5230\u6d88\u606f\u961f\u5217\u4e2d\u3002Canal \u4f1a\u5c06 Binlog \u7684\u53d8\u66f4\u5185\u5bb9\u63a8\u9001\u5230\u6307\u5b9a\u7684 RocketMQ Topic\u3002\u56e0\u6b64\uff0c\u5728 Spring Boot \u5e94\u7528\u4e2d\uff0c\u6211\u4eec\u53ea\u9700\u8981\u4e0e RocketMQ \u8fdb\u884c\u5bf9\u63a5\u5373\u53ef\u3002<\/p>\n\n\n\n
\u4ee3\u7801\u5982\u4e0b\u6240\u793a\uff1a<\/p>\n\n\n\n
packagecom.nageoffer.onecoupon.engine.mq.consumer;\n\u200b\nimportcn.hutool.core.collection.CollUtil;importcn.hutool.core.date.DateUtil;importcn.hutool.core.util.ObjectUtil;importcn.hutool.core.util.StrUtil;importcom.alibaba.fastjson2.JSON;importcom.nageoffer.onecoupon.engine.common.constant.EngineRedisConstant;importcom.nageoffer.onecoupon.engine.common.constant.EngineRockerMQConstant;importcom.nageoffer.onecoupon.engine.mq.event.CanalBinlogEvent;importcom.nageoffer.onecoupon.engine.mq.event.UserCouponDelayCloseEvent;importcom.nageoffer.onecoupon.engine.mq.producer.UserCouponDelayCloseProducer;importlombok.RequiredArgsConstructor;importlombok.extern.slf4j.Slf4j;importorg.apache.rocketmq.client.producer.SendResult;importorg.apache.rocketmq.spring.annotation.RocketMQMessageListener;importorg.apache.rocketmq.spring.core.RocketMQListener;importorg.springframework.data.redis.core.StringRedisTemplate;importorg.springframework.stereotype.Component;\n\u200b\nimportjava.util.Date;importjava.util.Map;\n\u200b\n\/**\n * \u901a\u8fc7 Canal \u76d1\u542c\u7528\u6237\u4f18\u60e0\u5238\u8868 Binlog \u6295\u9012\u6d88\u606f\u961f\u5217\u6d88\u8d39\n * <p>\n * \u4f5c\u8005\uff1a\u9a6c\u4e01\n * \u52a0\u9879\u76ee\u7fa4\uff1a\u65e9\u52a0\u5165\u5c31\u662f\u4f18\u52bf\uff01500\u4eba\u5185\u90e8\u6c9f\u901a\u7fa4\uff0c\u5206\u4eab\u7684\u77e5\u8bc6\u603b\u6709\u4f60\u9700\u8981\u7684 <a href=\"https:\/\/t.zsxq.com\/cw7b9\" \/>\n * \u5f00\u53d1\u65f6\u95f4\uff1a2024-07-25\n *\/@Slf4j@Component@RequiredArgsConstructor@RocketMQMessageListener(\n topic =\"one-coupon_canal_engine-service_common-sync_topic${unique-name:}\",\n consumerGroup =\"one-coupon_canal_engine-service_common-sync_cg${unique-name:}\")publicclassCanalBinlogSyncUserCouponConsumerimplementsRocketMQListener<CanalBinlogEvent>{\n\u200b\n privatefinalStringRedisTemplate stringRedisTemplate;privatefinalUserCouponDelayCloseProducer couponDelayCloseProducer;\n\u200b\n @OverridepublicvoidonMessage(CanalBinlogEvent canalBinlogEvent){Map<String, Object> first =CollUtil.getFirst(canalBinlogEvent.getData());String couponTemplateId = first.get(\"coupon_template_id\").toString();String userCouponId = first.get(\"id\").toString();\/\/ \u7528\u6237\u4f18\u60e0\u5238\u521b\u5efa\u4e8b\u4ef6if(ObjectUtil.equal(canalBinlogEvent.getType(),\"INSERT\")){\/\/ \u6dfb\u52a0\u7528\u6237\u9886\u53d6\u4f18\u60e0\u5238\u6a21\u677f\u7f13\u5b58\u8bb0\u5f55String userCouponListCacheKey =String.format(EngineRedisConstant.USER_COUPON_TEMPLATE_LIST_KEY, first.get(\"user_id\").toString());String userCouponItemCacheKey =StrUtil.builder().append(couponTemplateId).append(\"_\").append(userCouponId).toString();Date receiveTime =DateUtil.parse(first.get(\"receive_time\").toString());\n stringRedisTemplate.opsForZSet().add(userCouponListCacheKey, userCouponItemCacheKey, receiveTime.getTime());\n\u200b\n \/\/ \u7531\u4e8e Redis \u5728\u6301\u4e45\u5316\u6216\u4e3b\u4ece\u590d\u5236\u7684\u6781\u7aef\u60c5\u51b5\u4e0b\u53ef\u80fd\u4f1a\u51fa\u73b0\u6570\u636e\u4e22\u5931\uff0c\u800c\u6211\u4eec\u5bf9\u6307\u4ee4\u4e22\u5931\u51e0\u4e4e\u65e0\u6cd5\u5bb9\u5fcd\uff0c\u56e0\u6b64\u6211\u4eec\u91c7\u7528\u7ecf\u5178\u7684\u5199\u540e\u67e5\u8be2\u7b56\u7565\u6765\u5e94\u5bf9\u8fd9\u4e00\u95ee\u9898Double scored;try{\n scored = stringRedisTemplate.opsForZSet().score(userCouponListCacheKey, userCouponItemCacheKey);\/\/ scored \u4e3a\u7a7a\u610f\u5473\u7740\u53ef\u80fd Redis Cluster \u4e3b\u4ece\u540c\u6b65\u4e22\u5931\u4e86\u6570\u636e\uff0c\u6bd4\u5982 Redis \u4e3b\u8282\u70b9\u8fd8\u6ca1\u6709\u540c\u6b65\u5230\u4ece\u8282\u70b9\u5c31\u5b95\u673a\u4e86\uff0c\u89e3\u51b3\u65b9\u6848\u5c31\u662f\u518d\u65b0\u589e\u4e00\u6b21if(scored ==null){\/\/ \u5982\u679c\u8fd9\u91cc\u4e5f\u65b0\u589e\u5931\u8d25\u4e86\u600e\u4e48\u529e\uff1f\u6211\u4eec\u5927\u6982\u7387\u505a\u4e0d\u5230\u7edd\u5bf9\u7684\u4e07\u65e0\u4e00\u5931\uff0c\u53ea\u80fd\u5c3d\u53ef\u80fd\u589e\u52a0\u6210\u529f\u7387\n stringRedisTemplate.opsForZSet().add(userCouponListCacheKey, userCouponItemCacheKey, receiveTime.getTime());}}catch(Throwable ex){\n log.warn(\"\u67e5\u8be2Redis\u7528\u6237\u4f18\u60e0\u5238\u8bb0\u5f55\u4e3a\u7a7a\u6216\u629b\u5f02\u5e38\uff0c\u53ef\u80fdRedis\u5b95\u673a\u6216\u4e3b\u4ece\u590d\u5236\u6570\u636e\u4e22\u5931\uff0c\u57fa\u7840\u9519\u8bef\u4fe1\u606f\uff1a{}\", ex.getMessage());\/\/ \u5982\u679c\u76f4\u63a5\u629b\u5f02\u5e38\u5927\u6982\u7387 Redis \u5b95\u673a\u4e86\uff0c\u6240\u4ee5\u5e94\u8be5\u5199\u4e2a\u5ef6\u65f6\u961f\u5217\u5411 Redis \u91cd\u8bd5\u653e\u5165\u503c\u3002\u4e3a\u4e86\u907f\u514d\u4ee3\u7801\u590d\u6742\u6027\uff0c\u8fd9\u91cc\u76f4\u63a5\u5199\u65b0\u589e\uff0c\u5927\u5bb6\u77e5\u9053\u6700\u4f18\u89e3\u51b3\u65b9\u6848\u5373\u53ef\n stringRedisTemplate.opsForZSet().add(userCouponListCacheKey, userCouponItemCacheKey, receiveTime.getTime());}\n\u200b\n \/\/ \u53d1\u9001\u5ef6\u65f6\u6d88\u606f\u961f\u5217\uff0c\u7b49\u5f85\u4f18\u60e0\u5238\u5230\u671f\u540e\uff0c\u5c06\u4f18\u60e0\u5238\u4fe1\u606f\u4ece\u7f13\u5b58\u4e2d\u5220\u9664UserCouponDelayCloseEvent userCouponDelayCloseEvent =UserCouponDelayCloseEvent.builder().couponTemplateId(couponTemplateId).userCouponId(userCouponId).userId(first.get(\"user_id\").toString()).delayTime(DateUtil.parse(first.get(\"valid_end_time\").toString()).getTime()).build();SendResult sendResult = couponDelayCloseProducer.sendMessage(userCouponDelayCloseEvent);\n\u200b\n \/\/ \u53d1\u9001\u6d88\u606f\u5931\u8d25\u89e3\u51b3\u65b9\u6848\u7b80\u5355\u4e14\u9ad8\u6548\u7684\u903b\u8f91\u4e4b\u4e00\uff1a\u6253\u5370\u65e5\u5fd7\u5e76\u62a5\u8b66\uff0c\u901a\u8fc7\u65e5\u5fd7\u641c\u96c6\u5e76\u91cd\u65b0\u6295\u9012if(ObjectUtil.notEqual(sendResult.getSendStatus().name(),\"SEND_OK\")){\n log.warn(\"\u53d1\u9001\u4f18\u60e0\u5238\u5173\u95ed\u5ef6\u65f6\u961f\u5217\u5931\u8d25\uff0c\u6d88\u606f\u53c2\u6570\uff1a{}\",JSON.toJSONString(userCouponDelayCloseEvent));}}}}<\/code><\/pre>\n\n\n\n\u901a\u8fc7\u8fd9\u79cd\u65b9\u5f0f\u6211\u4eec\u5c31\u80fd\u5c06\u63a5\u53e3\u7684\u541e\u5410\u91cf\u5927\u5e45\u5ea6\u63d0\u9ad8\u4e86\u3002<\/p>\n\n\n\n
3. \u7b80\u5316 Canal \u6d41\u7a0b<\/h3>\n\n\n\n
\u8003\u8651\u5230\u5f88\u591a\u540c\u5b66\u662f\u60f3\u5feb\u901f\u542f\u52a8\u725b\u5238\u9879\u76ee\uff0c\u4e3a\u4e86\u4e0d\u8ba9 Canal \u6210\u4e3a\u5f3a\u5236\u4f9d\u8d56\u7684\u7ec4\u4ef6\uff0c\u6211\u4eec\u6dfb\u52a0\u4e00\u4e2a\u914d\u7f6e\u3002<\/p>\n\n\n\n
application.yaml \u914d\u7f6e\u6587\u4ef6\u5982\u4e0b\uff1a<\/p>\n\n\n\n
one-coupon:user-coupon-list:\n save-cache:\n type: direct # \u6709\u4e24\u4e2a\u9009\u9879\uff1adirect \u5728\u6d41\u7a0b\u91cc\u76f4\u63a5\u64cd\u4f5c\uff0cbinlog \u901a\u8fc7\u89e3\u6790\u6570\u636e\u5e93\u65e5\u5fd7\u540e\u64cd\u4f5c<\/code><\/pre>\n\n\n\n\u5728 Service \u4ee3\u7801\u4e2d\u6dfb\u52a0\u4e00\u4e2a\u5224\u65ad\u5c31\u597d\uff0c\u4ee3\u7801\u5982\u4e0b\u6240\u793a\uff1a<\/p>\n\n\n\n
@OverridepublicvoidredeemUserCoupon(CouponTemplateRedeemReqDTO requestParam){\/\/ ......\/\/ \u901a\u8fc7\u7f16\u7a0b\u5f0f\u4e8b\u52a1\u6267\u884c\u4f18\u60e0\u5238\u5e93\u5b58\u81ea\u51cf\u4ee5\u53ca\u589e\u52a0\u7528\u6237\u4f18\u60e0\u5238\u9886\u53d6\u8bb0\u5f55long extractSecondField =StockDecrementReturnCombinedUtil.extractSecondField(stockDecrementLuaResult);\n transactionTemplate.executeWithoutResult(status ->{try{\/\/ ......\/\/ \u4fdd\u5b58\u4f18\u60e0\u5238\u7f13\u5b58\u96c6\u5408\u6709\u4e24\u4e2a\u9009\u9879\uff1adirect \u5728\u6d41\u7a0b\u91cc\u76f4\u63a5\u64cd\u4f5c\uff0cbinlog \u901a\u8fc7\u89e3\u6790\u6570\u636e\u5e93\u65e5\u5fd7\u540e\u64cd\u4f5cif(StrUtil.equals(userCouponListSaveCacheType,\"direct\")){\/\/ \u64cd\u4f5c\u7f13\u5b58\u3001\u64cd\u4f5c\u6d88\u606f\u961f\u5217\/\/ ......}}catch(Exception ex){\n status.setRollbackOnly();\/\/ \u4f18\u60e0\u5238\u5df2\u88ab\u9886\u53d6\u5b8c\u4e1a\u52a1\u5f02\u5e38if(ex instanceofServiceException){throw(ServiceException) ex;}if(ex instanceofDuplicateKeyException){\n log.error(\"\u7528\u6237\u91cd\u590d\u9886\u53d6\u4f18\u60e0\u5238\uff0c\u7528\u6237ID\uff1a{}\uff0c\u4f18\u60e0\u5238\u6a21\u677fID\uff1a{}\",UserContext.getUserId(), requestParam.getCouponTemplateId());thrownewServiceException(\"\u7528\u6237\u91cd\u590d\u9886\u53d6\u4f18\u60e0\u5238\");}thrownewServiceException(\"\u4f18\u60e0\u5238\u9886\u53d6\u5f02\u5e38\uff0c\u8bf7\u7a0d\u5019\u518d\u8bd5\");}});}<\/code><\/pre>\n\n\n\nRedis \u7f13\u5b58\u5e8f\u5217\u5316\u5668<\/h2>\n\n\n\n
\u56e0\u4e3a\u54b1\u4eec\u7684\u7528\u6237\u4fe1\u606f\u662f\u56fa\u5b9a\u5199\u5165\u7684\uff0c\u6240\u4ee5\uff0c\u5982\u679c\u7528\u6237\u9886\u53d6\u4e86\u4f18\u60e0\u5238\uff0c\u5927\u5bb6\u7684\u4f18\u60e0\u5238\u4fe1\u606f\u90fd\u662f\u5199\u5230\u4e00\u4e2a Redis\uff08\u5982\u679c\u7528\u4e86\u4e91 Redis \u7684\u8bdd\uff09\u7f13\u5b58\u7684\u3002\u8fd9\u6837\u7684\u8bdd\u5c31\u4e0d\u592a\u597d\u5206\u8fa8\u548c\u6d4b\u8bd5\uff0c\u4e3a\u6b64\u6211\u4eec\u901a\u8fc7\u81ea\u5b9a\u4e49 Redis \u7f13\u5b58\u7684\u5e8f\u5217\u5316\u5668\u505a\u4e2a\u6807\u8bc6\u3002<\/p>\n\n\n\n
\u53d8\u66f4\u4ee3\u7801\u5982\u4e0b\uff1a<\/p>\n\n\n\n![\"\"](\"https:\/\/oss.open8gu.com\/image-20240909195703640.png\" "\\"\\"\/")
<\/figure>\n\n\n\n\n\n\u903b\u8f91\u6bd4\u8f83\u7b80\u5355\uff0c\u901a\u8fc7\u81ea\u5b9a\u4e49\u4e00\u4e2a RedisKeySerializer<\/code> \u66ff\u6362\u9ed8\u8ba4\u7684 Key \u5e8f\u5217\u5316\u5668\u5c31\u597d\u3002<\/p>\n\n\n\n@RequiredArgsConstructor@EnableConfigurationProperties(RedisDistributedProperties.class)publicclassCacheConfigurationimplementsInitializingBean{\n\u200b\n privatefinalRedisDistributedProperties redisDistributedProperties;privatefinalStringRedisTemplate stringRedisTemplate;\n\u200b\n \/**\n * \u521b\u5efa Redis Key \u5e8f\u5217\u5316\u5668\uff0c\u53ef\u81ea\u5b9a\u4e49 Key Prefix\n *\/@BeanpublicRedisKeySerializerredisKeySerializer(){String prefix =Optional.ofNullable(redisDistributedProperties.getPrefix()).orElse(\"\");String prefixCharset = redisDistributedProperties.getPrefixCharset();returnnewRedisKeySerializer(prefix, prefixCharset);}\n\u200b\n @OverridepublicvoidafterPropertiesSet()throwsException{\n stringRedisTemplate.setKeySerializer(redisKeySerializer());}}<\/code><\/pre>\n\n\n\n\u7136\u540e\u6211\u4eec\u5728 VM \u53c2\u6570\u91cc\u6dfb\u52a0\u4e00\u4e2a\u65b0\u7684\u53c2\u6570\uff0c\u56e0\u4e3a\u6211\u53ea\u7528\u4e86\u516c\u6709\u4e91 RocketMQ\uff0c\u6240\u4ee5\u52a0\u4e0a\u540e\u4e00\u5171\u662f\u4e09\u4e2a\u53c2\u6570\u3002<\/p>\n\n\n\n![\"\"](\"https:\/\/oss.open8gu.com\/image-20240909200653218.png\" "\\"\\"\/")
<\/figure>\n\n\n\n\n\n\u4f46\u662f\u6709\u4e2a\u70b9\uff0c\u5e03\u9686\u8fc7\u6ee4\u5668\u7684\u521b\u5efa\u5e76\u4e0d\u53d7\u8fd9\u4e2a\u7ba1\u63a7\uff0c\u6240\u4ee5\u6211\u4eec\u8981\u624b\u52a8\u8ffd\u52a0\u3002\u9700\u8981\u4fee\u6539\u540e\u7ba1\u548c\u5f15\u64ce\u7684\u5e03\u9686\u8fc7\u6ee4\u5668\u521b\u5efa\u914d\u7f6e\u3002<\/p>\n\n\n\n
\u4ee3\u7801\u5982\u4e0b\uff1a<\/p>\n\n\n\n
@ConfigurationpublicclassRBloomFilterConfiguration{\n\u200b\n \/**\n * \u4f18\u60e0\u5238\u67e5\u8be2\u7f13\u5b58\u7a7f\u900f\u5e03\u9686\u8fc7\u6ee4\u5668\n *\/@BeanpublicRBloomFilter<String>couponTemplateQueryBloomFilter(RedissonClient redissonClient,@Value(\"${framework.cache.redis.prefix:}\")String cachePrefix){RBloomFilter<String> bloomFilter = redissonClient.getBloomFilter(cachePrefix +\"couponTemplateQueryBloomFilter\");\n bloomFilter.tryInit(640L,0.001);return bloomFilter;}}<\/code><\/pre>\n\n\n\n\u7136\u540e\u6211\u4eec\u91cd\u542f\u540e\u7ba1\u548c\u5f15\u64ce\u670d\u52a1\uff0c\u6267\u884c\u65b0\u589e\u548c\u9886\u53d6\u4f18\u60e0\u5238\u4e1a\u52a1\uff0c\u5c31\u53ef\u4ee5\u770b\u5230\u9ed8\u8ba4\u7684 Key \u524d\u9762\u4f1a\u8ffd\u52a0\u6211\u4eec\u81ea\u5b9a\u4e49\u7684 prefix\u3002<\/p>\n\n\n\n![\"\"](\"https:\/\/oss.open8gu.com\/image-20240909205027009.png\" "\\"\\"\/")
<\/figure>\n\n\n\n\n\n\u6267\u884c\u4f18\u60e0\u5238\u5151\u6362<\/h2>\n\n\n\n1. \u521b\u5efa\u4f18\u60e0\u5238\u6a21\u677f<\/h3>\n\n\n\n
\u521b\u5efa\u4f18\u60e0\u5238\u6a21\u677f\u63a5\u53e3\u5730\u5740\uff1a\u70b9\u51fb\u8df3\u8f6c<\/a><\/p>\n\n\n\n\u521b\u5efa\u4e00\u4e2a\u65b0\u7684\u4f18\u60e0\u5238\u6a21\u677f\uff0c\u7136\u540e\u7528\u6237\u9650\u9886\u6b21\u6570 limitPerPerson<\/code> \u8bbe\u7f6e\u4e3a 2 \u6b21\u3002<\/p>\n\n\n\n{\"name\":\"\u7528\u6237\u4e0b\u5355\u6ee110\u51cf3\u7279\u5927\u4f18\u60e0\",\"source\":0,\"target\":1,\"goods\":\"\",\"type\":0,\"validStartTime\":\"2024-07-08 12:00:00\",\"validEndTime\":\"2025-06-30 13:59:59\",\"stock\":4998,\"receiveRule\":\"{\\\"limitPerPerson\\\":2,\\\"usageInstructions\\\":\\\"3\\\"}\",\"consumeRule\":\"{\\\"termsOfUse\\\":10,\\\"maximumDiscountAmount\\\":3,\\\"explanationOfUnmetConditions\\\":\\\"3\\\",\\\"validityPeriod\\\":\\\"48\\\"}\"}<\/code><\/pre>\n\n\n\n2. \u5151\u6362\u4f18\u60e0\u5238<\/h3>\n\n\n\n
\u5151\u6362\u4f18\u60e0\u5238\u6a21\u677f\u63a5\u53e3\u5730\u5740\uff1a\u70b9\u51fb\u8df3\u8f6c<\/a><\/p>\n\n\n\n\u4ece\u6570\u636e\u5e93 one_coupon_rebuild_1<\/code> \u4e2d\u67e5\u8be2 t_coupon_template_15<\/code> \u6700\u65b0\u7684\u521b\u5efa\u4f18\u60e0\u5238\u6a21\u677f ID\uff0c\u7136\u540e\u8fdb\u5165 API \u5730\u5740\u5f00\u59cb\u8fdb\u884c\u5151\u6362\u3002<\/p>\n\n\n\n