Lemon Squeezy API完全指南在Next.js billing app中实现订阅CRUD操作【免费下载链接】nextjs-billingNext.js billing app with Lemon Squeezy项目地址: https://gitcode.com/gh_mirrors/ne/nextjs-billing在当今的SaaS软件即服务时代构建一个可靠的订阅计费系统是每个开发者面临的挑战。幸运的是借助Lemon Squeezy API和Next.js框架我们可以快速搭建一个功能完整的计费系统。本文将为你详细介绍如何在Next.js billing应用中实现订阅的创建、读取、更新和删除CRUD操作让你轻松管理用户订阅生命周期。为什么选择Lemon Squeezy与Next.js组合Lemon Squeezy作为一款现代化的支付处理平台提供了简洁的API接口和丰富的订阅管理功能。结合Next.js 14的App Router架构我们可以构建出高性能、SEO友好的订阅计费应用。这个组合特别适合初创公司和独立开发者因为它降低了支付集成的复杂度让你能专注于核心业务逻辑。项目架构概览我们的Next.js billing应用采用了分层架构设计确保代码的清晰性和可维护性前端层使用React组件展示订阅计划和用户订阅状态API层处理Lemon Squeezy API调用和Webhook接收数据层通过Drizzle ORM管理PostgreSQL数据库配置层集中管理Lemon Squeezy认证和环境变量环境配置与初始化开始之前我们需要配置Lemon Squeezy环境变量。在项目根目录的.env文件中添加以下关键配置LEMONSQUEEZY_API_KEY你的API密钥 LEMONSQUEEZY_STORE_ID你的商店ID LEMONSQUEEZY_WEBHOOK_SECRET你的Webhook密钥 WEBHOOK_URL你的Webhook接收地址 POSTGRES_URL你的数据库连接字符串在src/config/lemonsqueezy.ts中我们配置了Lemon Squeezy SDK的初始化函数export function configureLemonSqueezy() { lemonSqueezySetup({ apiKey: process.env.LEMONSQUEEZY_API_KEY, onError: (error) { console.error(error); throw new Error(Lemon Squeezy API error: ${error.message}); }, }); }数据库模型设计订阅系统的核心是数据模型。在src/db/schema.ts中我们定义了以下关键表结构订阅计划表plans存储Lemon Squeezy中的产品变体信息包括价格、计费周期、试用期等。用户订阅表subscriptions跟踪用户的订阅状态包含订阅ID、订单ID、状态、续费日期等关键字段。Webhook事件表webhookEvents记录所有从Lemon Squeezy接收的Webhook事件确保事件处理的可靠性。实现订阅CRUD操作1. 创建订阅Create创建订阅的核心是生成结账链接。在src/app/actions.ts中getCheckoutURL函数负责这一过程export async function getCheckoutURL(variantId: number, embed false) { configureLemonSqueezy(); const checkout await createCheckout( process.env.LEMONSQUEEZY_STORE_ID!, variantId, { checkoutOptions: { embed, media: false, logo: !embed }, checkoutData: { email: session.user.email ?? undefined, custom: { user_id: session.user.id }, }, productOptions: { enabledVariants: [variantId], redirectUrl: ${process.env.NEXT_PUBLIC_APP_URL}/dashboard/billing/, receiptButtonText: Go to Dashboard, receiptThankYouNote: Thank you for signing up!, }, }, ); return checkout.data?.data.attributes.url; }这个函数会生成一个独特的结账URL用户点击后可以完成订阅购买流程。2. 读取订阅Read获取用户订阅信息是计费面板的核心功能。getUserSubscriptions函数从数据库中查询当前用户的所有订阅export async function getUserSubscriptions() { const session await auth(); if (!session?.user) { return []; } return await db .select() .from(subscriptions) .where(eq(subscriptions.userId, session.user.id)); }在src/components/dashboard/billing/subscription/subscriptions.tsx组件中订阅信息被优雅地展示给用户包括状态、价格、续费日期等关键信息。3. 更新订阅Update订阅更新主要包括两个操作暂停订阅和更改订阅计划。暂停订阅pauseUserSubscription函数允许用户临时暂停订阅export async function pauseUserSubscription(id: string) { configureLemonSqueezy(); const pausedSub await updateSubscription(id, { pause: { mode: void }, }); // 更新数据库中的订阅状态 await db .update(subscriptions) .set({ isPaused: true, status: pausedSub.data.data.attributes.status, statusFormatted: pausedSub.data.data.attributes.status_formatted, }) .where(eq(subscriptions.lemonSqueezyId, id)); }更改订阅计划changePlan函数处理用户升级或降级订阅计划的需求export async function changePlan(currentPlanId: number, newPlanId: number) { // 获取当前订阅和新计划信息 // 调用Lemon Squeezy API更新订阅 // 同步更新本地数据库 }4. 删除订阅Delete取消订阅是订阅生命周期的重要环节。cancelSub函数处理订阅取消逻辑export async function cancelSub(id: string) { configureLemonSqueezy(); const cancelledSub await cancelSubscription(id); if (cancelledSub.error) { throw new Error(cancelledSub.error.message); } // 更新数据库中的订阅状态 await db .update(subscriptions) .set({ status: cancelledSub.data.data.attributes.status, statusFormatted: cancelledSub.data.data.attributes.status_formatted, endsAt: cancelledSub.data.data.attributes.ends_at, }) .where(eq(subscriptions.lemonSqueezyId, id)); revalidatePath(/); return cancelledSub; }Webhook事件处理Webhook是Lemon Squeezy与你的应用实时同步的关键机制。在src/app/api/webhook/route.ts中我们实现了安全的Webhook接收端点安全性验证// 验证请求签名 const hmac Buffer.from( crypto.createHmac(sha256, secret).update(rawBody).digest(hex), hex, ); if (!crypto.timingSafeEqual(hmac, signature)) { return new Response(Invalid signature, { status: 400 }); }事件处理processWebhookEvent函数处理不同类型的订阅事件if (webhookEvent.eventName.startsWith(subscription_)) { // 处理订阅创建、更新等事件 const updateData: NewSubscription { lemonSqueezyId: eventBody.data.id, orderId: attributes.order_id as number, name: attributes.user_name as string, email: attributes.user_email as string, status: attributes.status as string, // ... 其他字段 }; // 创建或更新数据库记录 await db.insert(subscriptions).values(updateData).onConflictDoUpdate({ target: subscriptions.lemonSqueezyId, set: updateData, }); }订阅计划同步保持本地计划数据与Lemon Squeezy同步至关重要。syncPlans函数从Lemon Squeezy API获取所有产品变体并更新本地数据库export async function syncPlans() { configureLemonSqueezy(); // 获取Lemon Squeezy中的所有产品 const products await getAllProducts({ filter: { storeId: process.env.LEMONSQUEEZY_STORE_ID }, include: [variants], }); // 遍历产品并同步变体信息 for (const product of products.data?.data ?? []) { const variants product.relationships.variants.data; for (const variant of variants) { const variantData await getVariant(variant.id); // 将变体信息保存到数据库 await _addVariant({ productId: product.id, productName: product.attributes.name, variantId: variantData.data.data.id, name: variantData.data.data.attributes.name, // ... 其他字段 }); } } }最佳实践与优化建议1. 错误处理与日志记录始终在关键操作中添加适当的错误处理和日志记录特别是在API调用和数据库操作中。2. 数据一致性使用数据库事务确保数据的一致性特别是在处理Webhook事件时。3. 性能优化实现订阅数据的缓存机制使用增量同步减少API调用优化数据库查询索引4. 安全性考虑验证所有用户输入实施速率限制防止滥用定期轮换API密钥部署与生产环境准备1. 环境配置确保生产环境正确配置所有必要的环境变量特别是生产环境的Lemon Squeezy API密钥正确的Webhook URL和密钥生产数据库连接字符串2. Webhook设置在生产环境的Lemon Squeezy商店中配置Webhook至少订阅以下事件subscription_createdsubscription_updatedsubscription_payment_success3. 监控与告警设置监控系统跟踪Webhook接收成功率订阅同步状态API调用错误率总结通过本文的指导你已经掌握了在Next.js应用中集成Lemon Squeezy API实现完整订阅CRUD操作的核心技术。从环境配置到数据库设计从订阅管理到Webhook处理每个环节都经过精心设计和实现。这个Next.js billing应用模板为你提供了一个坚实的起点你可以基于此构建更复杂的计费逻辑如使用量计费usage-based billing多货币支持优惠券和折扣系统发票和收据管理记住良好的订阅管理不仅仅是技术实现更是用户体验的重要组成部分。通过清晰的订阅状态展示、便捷的操作界面和可靠的事件处理你可以为用户提供优质的计费体验。现在你已经具备了构建专业级SaaS订阅系统的能力。开始使用这个模板将你的创意转化为可持续的商业模式吧【免费下载链接】nextjs-billingNext.js billing app with Lemon Squeezy项目地址: https://gitcode.com/gh_mirrors/ne/nextjs-billing创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考