/*@jsxRuntime automatic @jsxImportSource react*/
const {Fragment: _Fragment, jsx: _jsx, jsxs: _jsxs} = arguments[0];
function _createMdxContent(props) {
  const _components = Object.assign({
    p: "p",
    a: "a",
    h2: "h2",
    em: "em",
    strong: "strong",
    code: "code",
    blockquote: "blockquote"
  }, props.components), {Alert, Link, Gist} = _components;
  if (!Alert) _missingMdxReference("Alert", true);
  if (!Gist) _missingMdxReference("Gist", true);
  if (!Link) _missingMdxReference("Link", true);
  return _jsxs(_Fragment, {
    children: [_jsx(Alert, {
      info: true,
      children: _jsxs(_components.p, {
        children: ["This is a re-​publication of the fol­low­ing ", _jsx(_components.a, {
          href: "https://www.rowellbelen.com/dynamic-routing-in-serverless-microservice-with-vert-x-event-bus/",
          children: "blog post"
        })]
      })
    }), "\n", _jsxs(_components.h2, {
      id: "serverless-framework",
      children: [_jsx(_components.a, {
        "aria-hidden": true,
        tabIndex: "-1",
        className: "heading-anchor",
        href: "#serverless-framework"
      }), "Serverless framework"]
    }), "\n", _jsxs(_components.p, {
      children: ["The ", _jsx(_components.a, {
        href: "https://serverless.com",
        children: "Server­less Frame­work"
      }), " has be­come the ", _jsx(_components.em, {
        children: "De Facto"
      }), " toolkit for build­ing and de­ploy­ing Server­less func­tions or ap­pli­ca­tions. Its com­mu­nity has done a great job ad­vanc­ing the tools around Server­less ar­chi­tec­ture."]
    }), "\n", _jsxs(_components.p, {
      children: ["How­ever, in the Server­less com­mu­nity there is de­bate among de­vel­op­ers on whether a sin­gle ", _jsx(_components.strong, {
        children: "AWS Lambda"
      }), " func­tion should only be re­spon­si­ble for a sin­gle API end­point. My an­swer, based on my real-​world pro­duc­tion ex­pe­ri­ence, is ", _jsx(_components.strong, {
        children: "NO"
      }), "."]
    }), "\n", _jsxs(_components.p, {
      children: ["Imag­ine if you are build­ing a set of APIs with ", _jsx(_components.strong, {
        children: "10"
      }), " end­points and you need to de­ploy the APIs to ", _jsx(_components.strong, {
        children: "DEV"
      }), ", ", _jsx(_components.strong, {
        children: "STAGE"
      }), " and ", _jsx(_components.strong, {
        children: "PROD"
      }), " en­vi­ron­ments. Now you are look­ing at ", _jsx(_components.strong, {
        children: "30"
      }), " dif­fer­ent func­tions to ver­sion, de­ploy and man­age - not to men­tion the ", _jsx(_components.em, {
        children: "Copy & Paste"
      }), " code and con­fig­u­ra­tion that will re­sult from this type of set-​up. ", _jsx(_components.strong, {
        children: "NO THANKS!!!"
      })]
    }), "\n", _jsxs(_components.p, {
      children: ["I be­lieve a more prag­matic ap­proach is ", _jsx(_components.strong, {
        children: "1 Lambda Func­tion"
      }), " == ", _jsx(_components.strong, {
        children: "1 Mi­croser­vice"
      }), "."]
    }), "\n", _jsxs(_components.p, {
      children: ["For ex­am­ple, if you were build­ing a ", _jsx(_components.strong, {
        children: "User Mi­croser­vice"
      }), " with basic ", _jsx(_components.strong, {
        children: "CRUD"
      }), " func­tion­al­ity, you should im­ple­ment ", _jsx(_components.code, {
        children: "CREATE"
      }), ", ", _jsx(_components.code, {
        children: "READ"
      }), ", ", _jsx(_components.code, {
        children: "UPDATE"
      }), " and ", _jsx(_components.code, {
        children: "DELETE"
      }), " in a ", _jsx(_components.strong, {
        children: "sin­gle"
      }), " Lambda func­tion. In the code, you should re­solve the de­sired ac­tion by in­spect­ing the re­quest or the con­text."]
    }), "\n", _jsxs(_components.h2, {
      id: "vertx-to-the-rescue",
      children: [_jsx(_components.a, {
        "aria-hidden": true,
        tabIndex: "-1",
        className: "heading-anchor",
        href: "#vertx-to-the-rescue"
      }), "Vert.x to the rescue"]
    }), "\n", _jsxs(_components.p, {
      children: ["There are many ben­e­fits to using ", _jsx(_components.strong, {
        children: "Vert.x"
      }), " in any ap­pli­ca­tion. With ", _jsx(_components.strong, {
        children: "Vert.x"
      }), ", you get a rock-​solid and light­weight toolkit for build­ing ", _jsx(_components.strong, {
        children: "re­ac­tive"
      }), ", ", _jsx(_components.strong, {
        children: "highly per­for­mant"
      }), ", ", _jsx(_components.strong, {
        children: "event-​driven"
      }), " and ", _jsx(_components.strong, {
        children: "non-​blocking"
      }), " ap­pli­ca­tions. The toolkit even pro­vides asyn­chro­nous ", _jsx(_components.em, {
        children: "APIs"
      }), " for ac­cess­ing tra­di­tional block­ing dri­vers such as ", _jsx(_components.strong, {
        children: _jsx(Link, {
          href: "/docs/vertx-jdbc-client/groovy/",
          passHref: true,
          children: _jsx(_components.a, {
            href: "",
            children: "JDBC"
          })
        })
      }), "."]
    }), "\n", _jsxs(_components.p, {
      children: ["How­ever, for this ex­am­ple, we will mainly focus on the ", _jsx(Link, {
        href: "/docs/vertx-core/groovy/#event_bus",
        passHref: true,
        children: _jsx(_components.a, {
          href: "",
          children: "Event Bus"
        })
      }), ". The event bus al­lows dif­fer­ent parts of your ap­pli­ca­tion to com­mu­ni­cate with each other via event mes­sages. It sup­ports ", _jsx(_components.em, {
        children: "pub­lish/sub­scribe"
      }), ", ", _jsx(_components.em, {
        children: "point to point"
      }), ", and ", _jsx(_components.em, {
        children: "request-​response mes­sag­ing"
      }), "."]
    }), "\n", _jsxs(_components.p, {
      children: ["For the ", _jsx(_components.strong, {
        children: "User Mi­croser­vice"
      }), " ex­am­ple above, we could treat the com­bi­na­tion of the ", _jsx(_components.code, {
        children: "HTTP METHOD"
      }), " and ", _jsx(_components.code, {
        children: "RESOURCE PATH"
      }), " as a unique event chan­nel, and reg­is­ter the sub­scribers/han­dlers to re­spond ap­pro­pri­ately."]
    }), "\n", _jsx(_components.p, {
      children: "Let’s dive right in."
    }), "\n", _jsxs(_components.h2, {
      id: "goal",
      children: [_jsx(_components.a, {
        "aria-hidden": true,
        tabIndex: "-1",
        className: "heading-anchor",
        href: "#goal"
      }), "Goal"]
    }), "\n", _jsxs(_components.p, {
      children: ["Cre­ate a ", _jsx(_components.em, {
        children: "re­ac­tive"
      }), ", ", _jsx(_components.em, {
        children: "message-​driven"
      }), ", ", _jsx(_components.em, {
        children: "asyn­chro­nous"
      }), " ", _jsx(_components.strong, {
        children: "User Mi­croser­vice"
      }), " with ", _jsx(_components.code, {
        children: "GET"
      }), ", ", _jsx(_components.code, {
        children: "POST"
      }), ", ", _jsx(_components.code, {
        children: "DELETE"
      }), ", ", _jsx(_components.code, {
        children: "PUT"
      }), " CRUD op­er­a­tions in a ", _jsx(_components.em, {
        children: "sin­gle"
      }), " ", _jsx(_components.strong, {
        children: _jsx(_components.a, {
          href: "aws.amazon.com/lambda",
          children: "AWS Lambda Func­tion"
        })
      }), " using the ", _jsx(_components.a, {
        href: "https://serverless.com",
        children: "Server­less Frame­work"
      })]
    }), "\n", _jsxs(_components.p, {
      children: [_jsx(_components.code, {
        children: "Serverless stack definition"
      }), ":"]
    }), "\n", _jsx(Gist, {
      url: "https://gist.github.com/bytekast/48daa2ca479156c98d2735cca181ef30"
    }), "\n", _jsxs(_components.h2, {
      id: "solution",
      children: [_jsx(_components.a, {
        "aria-hidden": true,
        tabIndex: "-1",
        className: "heading-anchor",
        href: "#solution"
      }), "Solution"]
    }), "\n", _jsxs(_components.p, {
      children: ["Use ", _jsx(Link, {
        href: "/",
        passHref: true,
        children: _jsx(_components.a, {
          href: "",
          children: "Vert.x"
        })
      }), "’s ", _jsx(Link, {
        href: "/docs/vertx-core/groovy/#event_bus",
        passHref: true,
        children: _jsx(_components.a, {
          href: "",
          children: "Event Bus"
        })
      }), " to han­dle ", _jsx(_components.strong, {
        children: "dy­namic rout­ing"
      }), " to ", _jsx(_components.strong, {
        children: "event han­dlers"
      }), " based on ", _jsx(_components.em, {
        children: "HTTP method"
      }), " and ", _jsx(_components.em, {
        children: "re­source path"
      }), " from the API input."]
    }), "\n", _jsxs(_components.p, {
      children: [_jsx(_components.code, {
        children: "Lambda Handler"
      }), ":"]
    }), "\n", _jsx(Gist, {
      url: "https://gist.github.com/bytekast/d5a544f8cdcd327a12010100b2ba2d66"
    }), "\n", _jsxs(_components.h2, {
      id: "code-review",
      children: [_jsx(_components.a, {
        "aria-hidden": true,
        tabIndex: "-1",
        className: "heading-anchor",
        href: "#code-review"
      }), "Code review"]
    }), "\n", _jsxs(_components.p, {
      children: ["Lines ", _jsx(_components.code, {
        children: "14-19"
      }), " ini­tial­izes the ", _jsx(_components.strong, {
        children: "Vert.x"
      }), " in­stance. AWS Lambda will hold on to this in­stance for the life of the con­tainer/", _jsx(_components.strong, {
        children: "JVM"
      }), ". It is reused in sub­se­quent re­quests."]
    }), "\n", _jsxs(_components.p, {
      children: ["Line ", _jsx(_components.code, {
        children: "17"
      }), " reg­is­ters the ", _jsx(_components.strong, {
        children: "User Ser­vice"
      }), " ", _jsx(_components.em, {
        children: "han­dlers"
      })]
    }), "\n", _jsxs(_components.p, {
      children: ["Line ", _jsx(_components.code, {
        children: "22"
      }), " de­fines the ", _jsx(_components.strong, {
        children: "main han­dler"
      }), " method that is called when the ", _jsx(_components.strong, {
        children: "Lambda func­tion"
      }), " is in­voked."]
    }), "\n", _jsxs(_components.p, {
      children: ["Line ", _jsx(_components.code, {
        children: "27"
      }), " sends the Lambda func­tion input to the (dy­namic) ", _jsx(_components.strong, {
        children: "ad­dress"
      }), " where han­dlers are wait­ing to re­spond."]
    }), "\n", _jsxs(_components.p, {
      children: ["Lines ", _jsx(_components.code, {
        children: "44-66"
      }), " de­fines the spe­cific ", _jsx(_components.em, {
        children: "han­dlers"
      }), " and binds them to the ap­pro­pri­ate ", _jsx(_components.em, {
        children: "chan­nels"
      }), " (http method + re­source path)"]
    }), "\n", _jsxs(_components.h2, {
      id: "summary",
      children: [_jsx(_components.a, {
        "aria-hidden": true,
        tabIndex: "-1",
        className: "heading-anchor",
        href: "#summary"
      }), "Summary"]
    }), "\n", _jsxs(_components.p, {
      children: ["As you can see, ", _jsx(Link, {
        href: "/",
        passHref: true,
        children: _jsx(_components.a, {
          href: "",
          children: "Vert.x"
        })
      }), "’s ", _jsx(Link, {
        href: "/docs/vertx-core/groovy/#event_bus",
        passHref: true,
        children: _jsx(_components.a, {
          href: "",
          children: "Event Bus"
        })
      }), " makes it very easy to dy­nam­i­cally sup­port mul­ti­ple routes in a sin­gle ", _jsx(_components.strong, {
        children: "Server­less"
      }), " func­tion. This re­duces the num­ber of func­tions you have to man­age, de­ploy and main­tain in ", _jsx(_components.strong, {
        children: "AWS"
      }), ". In ad­di­tion, you gain ac­cess to asyn­chro­nous, non-​blocking APIs that come stan­dard with ", _jsx(_components.strong, {
        children: "Vert.x"
      }), "."]
    }), "\n", _jsxs(_components.blockquote, {
      children: ["\n", _jsx(_components.p, {
        children: "Server­less + Vert.x = BLISS"
      }), "\n"]
    })]
  });
}
function MDXContent(props = {}) {
  const {wrapper: MDXLayout} = props.components || ({});
  return MDXLayout ? _jsx(MDXLayout, Object.assign({}, props, {
    children: _jsx(_createMdxContent, props)
  })) : _createMdxContent(props);
}
return {
  default: MDXContent
};
function _missingMdxReference(id, component) {
  throw new Error("Expected " + (component ? "component" : "object") + " `" + id + "` to be defined: you likely forgot to import, pass, or provide it.");
}


Blog

Dynamic Routing in Serverless Microservice with Vert.x Event Bus

Next post

Building a real-time web app with Angular/Ngrx and Vert.x

Previous post

Scala is here

Blog

Dynamic Routing in Serverless Microservice with Vert.x Event Bus

Next post

Building a real-time web app with Angular/Ngrx and Vert.x

Previous post

Scala is here

Related posts

Things to keep in mind concerning CSRF attacks

Real-time bidding with Websockets and Vert.x

Some Rest with Vert.x