[
https://issues.apache.org/jira/browse/STORM-1270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15170272#comment-15170272
]
ASF GitHub Bot commented on STORM-1270:
---------------------------------------
Github user hustfxj commented on a diff in the pull request:
https://github.com/apache/storm/pull/1156#discussion_r54325240
--- Diff: storm-core/src/clj/org/apache/storm/daemon/drpc.clj ---
@@ -210,67 +63,19 @@
(wrap-reload '[org.apache.storm.daemon.drpc])
handle-request))
+
(defn launch-server!
([]
- (log-message "Starting drpc server for storm version '" STORM-VERSION
"'")
(let [conf (clojurify-structure (ConfigUtils/readStormConfig))
- worker-threads (int (conf DRPC-WORKER-THREADS))
- queue-size (int (conf DRPC-QUEUE-SIZE))
drpc-http-port (int (conf DRPC-HTTP-PORT))
- drpc-port (int (conf DRPC-PORT))
- drpc-service-handler (service-handler conf)
- ;; requests and returns need to be on separate thread pools,
since calls to
- ;; "execute" don't unblock until other thrift methods are
called. So if
- ;; 64 threads are calling execute, the server won't accept the
result
- ;; invocations that will unblock those threads
- handler-server (when (> drpc-port 0)
- (ThriftServer. conf
- (DistributedRPC$Processor.
drpc-service-handler)
- ThriftConnectionType/DRPC))
- invoke-server (ThriftServer. conf
- (DistributedRPCInvocations$Processor.
drpc-service-handler)
- ThriftConnectionType/DRPC_INVOCATIONS)
+ drpc-server (DrpcServer.)
http-creds-handler (AuthUtils/GetDrpcHttpCredentialsPlugin conf)]
- (Utils/addShutdownHookWithForceKillIn1Sec (fn []
- (if handler-server (.stop
handler-server))
- (.stop invoke-server)))
- (log-message "Starting Distributed RPC servers...")
- (future (.serve invoke-server))
(when (> drpc-http-port 0)
- (let [app (-> (webapp drpc-service-handler http-creds-handler)
- requests-middleware)
- filter-class (conf DRPC-HTTP-FILTER)
- filter-params (conf DRPC-HTTP-FILTER-PARAMS)
- filters-confs [(FilterConfiguration. filter-class
filter-params)]
- https-port (int (or (conf DRPC-HTTPS-PORT) 0))
- https-ks-path (conf DRPC-HTTPS-KEYSTORE-PATH)
- https-ks-password (conf DRPC-HTTPS-KEYSTORE-PASSWORD)
- https-ks-type (conf DRPC-HTTPS-KEYSTORE-TYPE)
- https-key-password (conf DRPC-HTTPS-KEY-PASSWORD)
- https-ts-path (conf DRPC-HTTPS-TRUSTSTORE-PATH)
- https-ts-password (conf DRPC-HTTPS-TRUSTSTORE-PASSWORD)
- https-ts-type (conf DRPC-HTTPS-TRUSTSTORE-TYPE)
- https-want-client-auth (conf DRPC-HTTPS-WANT-CLIENT-AUTH)
- https-need-client-auth (conf DRPC-HTTPS-NEED-CLIENT-AUTH)]
-
- (UIHelpers/stormRunJetty
- (int drpc-http-port)
- (reify IConfigurator (execute [this server]
- (UIHelpers/configSsl server
- https-port
- https-ks-path
- https-ks-password
- https-ks-type
- https-key-password
- https-ts-path
- https-ts-password
- https-ts-type
- https-need-client-auth
- https-want-client-auth)
- (UIHelpers/configFilter server
(ring.util.servlet/servlet app) filters-confs))))))
- (start-metrics-reporters conf)
- (when handler-server
- (.serve handler-server)))))
+ (let [app (-> (webapp drpc-server http-creds-handler)
--- End diff --
ok
> port backtype.storm.daemon.drpc to java
> ---------------------------------------
>
> Key: STORM-1270
> URL: https://issues.apache.org/jira/browse/STORM-1270
> Project: Apache Storm
> Issue Type: New Feature
> Components: storm-core
> Reporter: Robert Joseph Evans
> Assignee: John Fang
> Labels: java-migration, jstorm-merger
>
> DRPC server with HTTP and thrift support
> https://github.com/apache/storm/blob/jstorm-import/jstorm-core/src/main/java/com/alibaba/jstorm/drpc/Drpc.java
> (But missing HTTP support)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
