请求事务(TransactionScope)

目录结构

主目录transactions

  1.     —— main.go

代码示例

main.go

  1. package main
  3. import (
  4.     "github.com/kataras/iris"
  5.     "github.com/kataras/iris/context"
  6. )
  8. func main() {
  9.     app := iris.New()
  10.     //子域可以与所有可用的路由器一起使用，就像其他功能一样。
  11.     app.Get("/", func(ctx context.Context) {
  12.         ctx.BeginTransaction(func(t *context.Transaction) {
  13.             // 选择步骤：如果为true，那么下一个转录将不会被执行，如果为fails则向反
  14.             // t.SetScope（context.RequestTransactionScope）
  15.             //可选步骤：
  16.             //在此处创建新的自定义错误类型，以跟踪状态代码和错误消息
  17.             err := context.NewTransactionErrResult()
  18.             //如果我们想要回滚这个函数clojure中的任何错误，我们应该使用t.Context。
  19.             t.Context().Text("Blablabla this should not be sent to the client because we will fill the err with a message and status")
  20.             //在这里虚拟化一个虚假的错误，为了测试这个例子
  21.             fail := true
  22.             if fail {
  23.                 err.StatusCode = iris.StatusInternalServerError
  24.                 //注意：如果为空原因则会触发默认或自定义http错误（如ctx.FireStatusCode）
  25.                 err.Reason = "Error: Virtual failure!!"
  26.                 //选择步骤：
  27.                 //但是如果我们想要在事务失败时将错误消息回发给客户端，这很有用
  28.                 //如果原因为空，那么交易成功完成，
  29.                 //否则我们回滚整个返回的响应体，
  30.                 //header和Cookie，状态代码以及此事务中的所有内容
  31.                 t.Complete(err)
  32.             }
  33.         })
  34.         ctx.BeginTransaction(func(t *context.Transaction) {
  35.             t.Context().HTML("<h1>This will sent at all cases because it lives on different transaction and it doesn't fails</h1>")
  36.             // *如果我们没有任何'throw error'逻辑，则不需要scope.Complete（）
  37.         })
  38.         // OPTIONALLY，取决于用法：
  39.         //无论如何，在上下文的事务中发生的情景都会发送给客户端
  40.         ctx.HTML("<h1>Let's add a second html message to the response, " +
  41.             "if the transaction was failed and it was request scoped then this message would " +
  42.             "not been shown. But it has a transient scope(default) so, it is visible as expected!</h1>")
  43.     })
  44.     app.Run(iris.Addr(":8080"))
  45. }

提示

  • 尝试修改一下fail变量值，当与到错误，则会不显示BeginTransaction里面的内容，也就是说回滚了