Быстрые и масштабируемые веб-приложения Clojure Ring с Comsat

Как уже знают многие клоюристы, минималистичная лаконичность и ясность Клоюра могут принести пользу производительности и обслуживания для повседневных задач разработки, а также эстетическое блаженство и даже радость для нашей работы; Благодаря  Pulsar  вы также можете наслаждаться высокой производительностью волокон и улучшенной абстракцией параллелизма в традиционных приложениях Clojure.  Недавно был выпущен Comsat 0.3.0, который также предоставляет возможности волокон для веб-разработки Ring: давайте кратко рассмотрим, что возможно.

Кольцо, в ближайшее время

В то время как  рассекает API сервлетов  мы уже имели освежающий взгляд на  кольцо  от моделирования и API точки зрения дизайна. Кольцо давно стало основой выбора для большинства веб-приложений и фреймворков Clojure.

На самом низком уровне веб-приложение Ring — это просто  обработчик , то есть функция, преобразующая карту, представляющую запрос HTTP, в карту, представляющую ответ HTTP.

Поскольку необходимость выполнения предварительной и последующей обработки запросов является очень распространенной, Ring предлагает использовать  промежуточное программное обеспечение , то есть функции высшего порядка, превращающие обработчик в новый обработчик с дополнительной логикой. Ring уже предоставляет некоторые промежуточные программы, например, для обслуживания файлов и ресурсов classpath или для обогащения карты запросов информацией из нескольких частей. Конечно, промежуточное программное обеспечение может быть  связано  в определенном порядке посредством обычной функциональной композиции, потому что то, что мы получаем, применяя промежуточное программное обеспечение к обработчику, является другим обработчиком, к которому затем может быть применено еще несколько промежуточных программ.

Наконец, Ring предоставляет на основе Jetty HTTP-  адаптер  для обработчиков. Помимо Ring есть несколько других адаптеров, но обычно любой из них будет функцией, получающей обработчик в качестве основного входа и карту дополнительных опций (например, для прослушивающих интерфейсов и портов, размеров пула потоков и т. Д.), Которые будут запускать бесконечное обслуживание HTTP. петля.

Основы: вставка волоконно-оптического адаптера Comsat

Оптоволоконный адаптер Comsat Ring основан на Jetty 9 и опирается на поддержку Servlet Async (доступно с Servlet 3.0). Для каждого запроса он порождает новое волокно и немедленно возвращается, так что дорогие серверные потоки освобождаются как можно скорее; волокно выполнит обработчик и передаст ответ позже, когда обработка и построение ответа будут завершены.

Волокна Comsat Ring порождается через Pulsar, поэтому обработчик и все вокруг применяются промежуточное программной она должна быть  суспендируемыми : это можно сделать легко с помощью либо пульсар  sfn /  defsfn макросов или  suspendable! функции. В качестве вежливости адаптер сделает это за вас в последнем обработчике, который передается.

Давайте перенесем следующее простое веб-приложение «Hello World» Ring на адаптер блокировки волокна:

(ns myapp
  (:use ring.adapter.jetty))

(defn- hello-world [request]
  (Thread/sleep 100)
  {:status  200
   :headers {"Content-Type" "text/plain"}
   :body    "Hello World"})

(defn run [] (run-jetty hello-world {:port 8080}))`

(defproject myapp "0.1.0-SNAPSHOT"
            :description "Comsat Ring Hello World example."
            :min-lein-version "2.4.3"

            :dependencies
            [[org.clojure/clojure "1.6.0"]

             [co.paralleluniverse/comsat-ring-jetty9 "0.3.0"]]

            :main myapp.core/run

            :java-agents [[co.paralleluniverse/quasar-core "0.6.2"]])

(ns myapp.core
  (:use co.paralleluniverse.fiber.ring.jetty9)
  (:require [co.paralleluniverse.pulsar.core :refer [sfn defsfn suspendable!]])
  (:import (co.paralleluniverse.fibers Fiber)))

(defsfn hello-world [request]
  (Fiber/sleep 1000)
  {:status  200
   :headers {"Content-Type" "text/plain"}
   :body    "Hello World"})

(defn run [] (run-jetty hello-world {:port 8080}))

(ns myapp.core
  (:use co.paralleluniverse.fiber.ring.jetty9
        ring.middleware.file)
  (:require [co.paralleluniverse.pulsar.core :refer [sfn defsfn suspendable!]])
  (:import (co.paralleluniverse.fibers Fiber)))

(defn- fiber-sleep-middleware [h] #(do (Fiber/sleep 1000) ((suspendable! h) %)))

(defsfn hello-world [request]
  {:status  200
   :headers {"Content-Type" "text/plain"}
   :body "Hello World"})

(defn run [] (run-jetty
               (-> hello-world
                   fiber-sleep-middleware
                   (wrap-file "public")
                   fiber-sleep-middleware)
               {:port 8080}))

<!DOCTYPE html>
<html lang="en">
  <head>
    <meta charset="utf-8"/>
  </head>
  <body>
    <h1>Static test page!</h1>
  </body>
</html>

(ns ring-sample.core
    (:use co.paralleluniverse.fiber.ring.jetty9)
    (:require
      [co.paralleluniverse.pulsar.core :refer [sfn defsfn suspendable!]]
      [ring.middleware.json :as midjson]
      [ring.middleware.resource :as midres]
      [net.cgrand.moustache :as moustache]
      [ring.util.response :as ringres])
    (:import (co.paralleluniverse.fibers Fiber)))

(def ^:private app-routes
  (moustache/app
    [] (sfn [_] (Fiber/sleep 100) (ringres/resource-response "index.html" {:root "public"}))
    ["widgets"] (sfn [_] (Fiber/sleep 100) (ringres/response [{:name "Widget 1"} {:name "Widget 2"}]))))

(def app
  (-> app-routes
      suspendable!
      (midres/wrap-resource "/public")
      suspendable!
      (midjson/wrap-json-body)
      suspendable!
      (midjson/wrap-json-response)))

(defn run [] (run-jetty app {:port 8080}))