下面的图表展示了轮询和Webhook之间的比较。
假设我们经营一个电子商务网站。客户通过API网关将订单发送到订单服务，该服务再进行支付交易。支付服务随后与外部支付服务提供商（PSP）通信以完成交易。
处理与外部PSP的通信有两种方式：
1.短轮询在向PSP发送支付请求后，支付服务会不断询问PSP支付状态。经过几轮后，PSP最终返回状态。短轮询有两个缺点：1.不断轮询状态会占用支付服务的资源。2.外部服务直接与支付服务通信，存在安全漏洞。2.Webhook我们可以向外部服务注册一个Webhook。这意味着：当请求有更新时，请调用指定的URL来通知我。当PSP完成处理后，它将调用HTTP请求来更新支付状态。这种方式改变了编程范式，支付服务不再需要浪费资源轮询支付状态。
如果PSP没有回调怎么办？我们可以设置一个每小时检查支付状态的定时任务。
Webhook通常被称为反向API或推送API，因为服务器向客户端发送HTTP请求。在使用Webhook时，我们需要注意以下三个方面：
1.我们需要为外部服务设计一个适当的API，以供其调用。2.出于安全原因，我们需要在API网关中设置适当的规则。3.我们需要在外部服务中注册正确的URL。
当然！以下是一个示例代码，演示了如何使用Python和Flask创建一个处理支付状态更新的Webhook服务器：
import jsonfrom flask import Flask, request, abortapp = Flask(__name__)@app.route(\\\'/webhook/payment\\\', methods=[\\\'POST\\\'])def payment_webhook():data = request.get_json()if not data:abort(400, \\\'Invalid request payload.\\\')# 验证请求来源if not verify_request_origin(request):abort(401, \\\'Unauthorized request.\\\')# 处理支付状态更新payment_id = data[\\\'payment_id\\\']status = data[\\\'status\\\']update_payment_status(payment_id, status)return json.dumps({\\\'message\\\': \\\'Payment webhook received\\\'}), 200, {\\\'Content-Type\\\': \\\'application/json\\\'}def verify_request_origin(request):# 进行请求来源验证的逻辑# 如果请求不是来自预期的外部服务，返回False# 示例中简单地验证请求的来源IP是否在允许的IP列表中allowed_ips = [\\\'123.456.789.0\\\', \\\'987.654.321.0\\\']request_ip = request.remote_addrif request_ip not in allowed_ips:return Falsereturn Truedef update_payment_status(payment_id, status):# 执行更新支付状态的逻辑# 根据payment_id和status更新数据库或调用其他服务等# ...if __name__ == \\\'__main__\\\':app.run(host=\\\'0.0.0.0\\\', port=8000)
在上述示例中，我们首先定义了一个/webhook/payment端点，用于接收支付状态更新的Webhook请求。
原创文章，作者：小技术君，如若转载，请注明出处：https://www.sudun.com/ask/33852.html
