Effect-TS函数式TypeScript实战类型安全的函数式编程范式

Effect-TS函数式TypeScript实战：类型安全的函数式编程范式🎯导读：如果你厌倦了到处写try-catch、处理undefined带来的运行时崩溃、以及在异步代码中丢失错误上下文，那么Effect-TS可能就是你一直在寻找的答案。Effect-TS是TypeScript生态中最强大的函数式编程框架，它将错误处理、依赖注入、并发控制、可观测性全部融入类型系统。本文从实际业务场景出发，带你掌握Effect-TS的核心概念和生产级用法。一、为什么需要Effect-TS？1.1 TypeScript类型系统的遗憾TypeScript的类型系统很强大，但在处理副作用时，类型就"投降"了：// ❌ 函数签名说返回User，但实际可能抛异常asyncfunctionfetchUser(id:string):PromiseUser{constres=awaitfetch(`/api/users/${id}`);if(!res.ok)thrownewError(`HTTP${res.status}`);// 类型系统不知道这里会抛异常returnres.json();// 返回值可能不是User类型}// 调用方不知道这个函数可能失败constuser=awaitfetchUser('123');console.log(user.name);// 💥 运行时可能崩溃1.2 try-catch的困境// ❌ 嵌套的try-catchasyncfunctionprocessOrder(orderId:string){try{constorder=awaitfetchOrder(orderId);try{constuser=awaitfetchUser(order.userId);try{constresult=awaitchargePayment(user,order.total);returnresult;}catch(paymentError){// 支付失败怎么处理？// 需要退款吗？需要通知用户吗？thrownewError(`Payment failed:${paymentError}`);}}catch(userError){thrownewError(`User fetch failed:${userError}`);}}catch(orderError){thrownewError(`Order fetch failed:${orderError}`);}}这段代码有几个问题：错误类型丢失（全部变成了Error）嵌套地狱无法在类型层面表达"可能失败"无法组合多个可能失败的操作1.3 Effect-TS的解决方案Effect-TS用类型编码副作用：import{Effect,pipe}from'effect';// ✅ 类型明确告诉调用者：可能成功(User)，可能失败(UserError)functionfetchUser(id:string):Effect.EffectUser,UserError{returnEffect.tryPromise({try:()=fetch(`/api/users/${id}`).then(r=r.json()),catch:(error)=newUserError({cause:error,userId:id}),});}// ✅ 组合操作，错误自动传播constprocessOrder=(orderId:string)=pipe(fetchOrder(orderId),Effect.flatMap((order)=fetchUser(order.userId)),Effect.flatMap((user)=chargePayment(user,order.total)),Effect.catchTag('UserError',(error)=Effect.succeed({status:'user_not_found',userId:error.userId})),);// 类型：Effect.EffectPaymentResult, OrderError | PaymentError二、核心概念：Effect类型2.1 Effect的三个类型参数// EffectSuccess, Error, Requirements// Success: 成功时的值类型// Error: 失败时的错误类型// Requirements: 依赖的服务类型// 最简单的Effect：成功constone:Effect.Effectnumber,never,never=Effect.succeed(1);// 失败consterr:Effect.Effectnever,string,never=Effect.fail('oops');// 需要依赖constgreet:Effect.Effectstring,never,Logger=Effect.gen(function*(){constlogger=yield*Logger;yield*logger.info('greeting');return'hello';});关键理解：never表示"不可能发生"——Effectnumber, never, never保证永远不会失败、不需要任何依赖Effect是惰性的——创建Effect不会执行任何操作，只有运行时才会执行2.2 创建Effectimport{Effect,pipe}from'effect';// 从同步值创建constpure:Effect.Effectnumber=Effect.succeed(42);// 从可能失败的同步代码创建constsafeDiv=(a:number,b:number)=b===0?Effect.fail(newError('Division by zero')):Effect.succeed(a/b);// 从Promise创建constfetchData=Effect.tryPromise({try:()=fetch('https://api.example.com/data').then(r=r.json()),catch:(error)=newFetchError({cause:error}),});// 从可能失败的同步代码constparseJSON=(input:string)=Effect.try({try:()=JSON.parse(input),catch:(error)=newParseError({cause:error}),});// 从回调风格代码constreadFile=(path:string)=Effect.asyncBuffer,IOError((resume)={fs.readFile(path,(err,data)={if(err)resume(Effect.fail(newIOError({cause:err})));elseresume(Effect.succeed(data));});});2.3 运行Effectimport{Effect,Runtime,Layer}from'effect'