AWS SNS HTTPS网站推送通知：token接收与订阅确认咨询

首先明确：浏览器端点绝对不对！ #

SNS的HTTPS订阅要求端点是公网可访问的HTTPS服务器地址——因为SNS需要主动向这个端点发送POST请求（不管是订阅确认还是后续的通知消息）。浏览器是客户端，没有固定的公网可访问地址，也没法直接接收SNS的POST请求，所以你得先搭建一个后端服务，提供一个HTTPS接口作为订阅端点。

处理订阅确认POST请求的处理器示例 #

当你调用subscribe API（把Protocol设为https，Endpoint填你的后端HTTPS接口地址，比如https://your-domain.com/sns-webhook）后，SNS会立刻给这个端点发一个POST请求，类型是SubscriptionConfirmation，里面包含SubscribeURL、Token和TopicArn等关键信息。你需要处理这个请求来完成订阅确认，下面给两个常用后端语言的示例：

Node.js + Express 实现 #

const express = require('express');
const axios = require('axios');
const app = express();

// 解析POST请求的内容
app.use(express.json());
app.use(express.urlencoded({ extended: true }));

app.post('/sns-webhook', async (req, res) => {
  const snsMsg = req.body;

  // 处理订阅确认请求
  if (snsMsg.Type === 'SubscriptionConfirmation') {
    console.log('收到订阅确认请求，确认链接:', snsMsg.SubscribeURL);
    
    // 方法1：直接GET请求SubscribeURL完成确认（最直观的方式）
    try {
      await axios.get(snsMsg.SubscribeURL);
      console.log('订阅确认成功！');
      res.status(200).send('确认完成');
    } catch (err) {
      console.error('确认失败:', err);
      res.status(500).send('确认出错');
    }

    // 方法2：返回XML响应替代GET请求（也能完成确认）
    // const xmlResp = `<SubscribeConfirmationResponse><Success>true</Success></SubscribeConfirmationResponse>`;
    // res.set('Content-Type', 'text/xml');
    // res.status(200).send(xmlResp);
  } 
  // 处理后续的通知消息
  else if (snsMsg.Type === 'Notification') {
    console.log('收到推送通知:', snsMsg.Message);
    res.status(200).send('消息已接收');
  } 
  // 处理取消订阅的确认请求
  else if (snsMsg.Type === 'UnsubscribeConfirmation') {
    console.log('收到取消订阅请求');
    res.status(200).send('取消确认');
  }
});

// 启动HTTPS服务器（需要SSL证书，比如用Let's Encrypt免费证书）
const https = require('https');
const fs = require('fs');
const sslOptions = {
  key: fs.readFileSync('/path/to/your-private-key.pem'),
  cert: fs.readFileSync('/path/to/your-certificate.pem')
};

https.createServer(sslOptions, app).listen(443, () => {
  console.log('SNS Webhook服务已启动在443端口');
});

Python + Flask 实现 #

from flask import Flask, request, Response
import requests

app = Flask(__name__)

@app.route('/sns-webhook', methods=['POST'])
def sns_webhook_handler():
    # SNS可能用表单或JSON发送请求，所以两种都兼容
    sns_msg = request.form if request.form else request.json

    if sns_msg.get('Type') == 'SubscriptionConfirmation':
        subscribe_url = sns_msg.get('SubscribeURL')
        print(f'收到订阅确认，确认链接: {subscribe_url}')
        
        # 方法1：GET请求确认链接完成订阅
        try:
            resp = requests.get(subscribe_url)
            resp.raise_for_status()
            print('订阅确认成功！')
            return '确认完成', 200
        except Exception as e:
            print(f'确认失败: {str(e)}')
            return '确认出错', 500
        
        # 方法2：返回XML响应完成确认
        # xml_resp = '<SubscribeConfirmationResponse><Success>true</Success></SubscribeConfirmationResponse>'
        # return Response(xml_resp, mimetype='text/xml'), 200
    
    elif sns_msg.get('Type') == 'Notification':
        print(f'收到推送消息: {sns_msg.get("Message")}')
        return '消息已接收', 200
    
    elif sns_msg.get('Type') == 'UnsubscribeConfirmation':
        print('收到取消订阅请求')
        return '取消确认', 200
    
    return '未知消息类型', 400

if __name__ == '__main__':
    # 生产环境请用Gunicorn等专业服务器搭配SSL证书，不要用自带的开发服务器
    app.run(host='0.0.0.0', port=443, ssl_context=('/path/to/your-cert.pem', '/path/to/your-key.pem'))

额外注意事项 #

1. 必须用HTTPS：SNS不支持HTTP端点，所以你的后端必须配置SSL证书（可以用Let's Encrypt免费申请）。
2. 公网可访问：你的服务器要有公网IP，并且443端口（或自定义HTTPS端口）对外开放，确保SNS能访问到。
3. 验证请求合法性：生产环境一定要验证SNS请求的签名，防止伪造请求。可以用AWS SDK自带的签名验证工具，比如Node.js的aws-sdk.SNS.verifySignature，Python的boto3相关工具。
4. 获取订阅ARN：当你完成订阅确认后，SNS会返回SubscriptionArn，这就是你需要的“订阅标识”，后续可以用它来取消订阅、设置消息过滤等。

内容的提问来源于stack exchange，提问作者Shawn Yap