提交 90f65846 authored 作者: xueli.xue's avatar xueli.xue

Initialization

上级 f60cce5b
...@@ -58,10 +58,16 @@ public class RemoteHttpJobBean extends QuartzJobBean { ...@@ -58,10 +58,16 @@ public class RemoteHttpJobBean extends QuartzJobBean {
params.put(HandlerRepository.TRIGGER_LOG_ID, String.valueOf(jobLog.getId())); params.put(HandlerRepository.TRIGGER_LOG_ID, String.valueOf(jobLog.getId()));
params.put(HandlerRepository.HANDLER_NAME, jobDataMap.get(HandlerRepository.HANDLER_NAME)); params.put(HandlerRepository.HANDLER_NAME, jobDataMap.get(HandlerRepository.HANDLER_NAME));
params.put(HandlerRepository.HANDLER_PARAMS, jobDataMap.get(HandlerRepository.HANDLER_PARAMS)); params.put(HandlerRepository.HANDLER_PARAMS, jobDataMap.get(HandlerRepository.HANDLER_PARAMS));
String[] postResp = HttpUtil.post(jobDataMap.get(HandlerRepository.HANDLER_ADDRESS), params); // handler address, netty or servlet
String handler_address = jobDataMap.get(HandlerRepository.HANDLER_ADDRESS);
if (!handler_address.startsWith("http")){
handler_address = "http://" + handler_address + "/";
}
String[] postResp = HttpUtil.post(handler_address, params);
logger.info(">>>>>>>>>>> xxl-job trigger http response, jobLog.id:{}, jobLog:{}", jobLog.getId(), jobLog); logger.info(">>>>>>>>>>> xxl-job trigger http response, jobLog.id:{}, jobLog:{}", jobLog.getId(), jobLog);
// parse trigger response // parse trigger response
String responseMsg = postResp[0]; String responseMsg = postResp[0];
String exceptionMsg = postResp[1]; String exceptionMsg = postResp[1];
......
trigger_log_url=http://localhost:8080/xxl-job-admin/joblog/save trigger_log_url=http://localhost:8080/joblog/save
\ No newline at end of file \ No newline at end of file
...@@ -11,4 +11,8 @@ ...@@ -11,4 +11,8 @@
<context:component-scan base-package="com.xxl.job.service" /> <context:component-scan base-package="com.xxl.job.service" />
<bean id="xxlJobJettyServer" class="com.xxl.job.client.netcom.jetty.XxlJobJettyServer" init-method="start">
<property name="port" value="9999" />
</bean>
</beans> </beans>
\ No newline at end of file
...@@ -23,7 +23,7 @@ ...@@ -23,7 +23,7 @@
<!-- Xxl Job Servlet --> <!-- Xxl Job Servlet -->
<servlet> <servlet>
<servlet-name>XxlJobServlet</servlet-name> <servlet-name>XxlJobServlet</servlet-name>
<servlet-class>com.xxl.job.client.netcom.http.XxlJobServlet</servlet-class> <servlet-class>com.xxl.job.client.netcom.servlet.XxlJobServlet</servlet-class>
<load-on-startup>1</load-on-startup> <load-on-startup>1</load-on-startup>
</servlet> </servlet>
<servlet-mapping> <servlet-mapping>
......
...@@ -24,6 +24,13 @@ ...@@ -24,6 +24,13 @@
<version>2.1</version> <version>2.1</version>
<scope>provided</scope> <scope>provided</scope>
</dependency> </dependency>
<!-- jetty -->
<dependency>
<groupId>org.eclipse.jetty</groupId>
<artifactId>jetty-server</artifactId>
<version>7.6.9.v20130131</version>
</dependency>
<!-- slf4j --> <!-- slf4j -->
<dependency> <dependency>
...@@ -45,7 +52,7 @@ ...@@ -45,7 +52,7 @@
<artifactId>httpclient</artifactId> <artifactId>httpclient</artifactId>
<version>4.3.6</version> <version>4.3.6</version>
</dependency> </dependency>
</dependencies> </dependencies>
<build> <build>
......
package com.xxl.job.client.netcom.http; package com.xxl.job.client.netcom.servlet;
import java.io.IOException; import java.io.IOException;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;
import javax.servlet.ServletException; import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpServletResponse;
import com.xxl.job.client.handler.HandlerRepository; import com.xxl.job.client.handler.HandlerRepository;
/** /**
* remote job client on http * remote job client on http
* @author xuxueli 2015-12-19 18:36:47 * @author xuxueli 2015-12-19 18:36:47
*/ */
public class XxlJobServlet extends HttpServlet { public class XxlJobServlet extends HttpServlet {
private static final long serialVersionUID = 1L; private static final long serialVersionUID = 1L;
/** /**
* Default constructor. * Default constructor.
*/ */
public XxlJobServlet() { public XxlJobServlet() {
// TODO Auto-generated constructor stub // TODO Auto-generated constructor stub
} }
/** /**
* @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse response) * @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse response)
*/ */
protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
request.setCharacterEncoding("UTF-8"); request.setCharacterEncoding("UTF-8");
response.setCharacterEncoding("UTF-8"); response.setCharacterEncoding("UTF-8");
Map<String, String> _param = new HashMap<String, String>(); Map<String, String> _param = new HashMap<String, String>();
if (request.getParameterMap()!=null && request.getParameterMap().size()>0) { if (request.getParameterMap()!=null && request.getParameterMap().size()>0) {
for (Object paramKey : request.getParameterMap().keySet()) { for (Object paramKey : request.getParameterMap().keySet()) {
if (paramKey!=null) { if (paramKey!=null) {
String paramKeyStr = paramKey.toString(); String paramKeyStr = paramKey.toString();
_param.put(paramKeyStr, request.getParameter(paramKeyStr)); _param.put(paramKeyStr, request.getParameter(paramKeyStr));
} }
} }
} }
String resp = HandlerRepository.pushHandleQueue(_param); String resp = HandlerRepository.pushHandleQueue(_param);
response.getWriter().append(resp); response.getWriter().append(resp);
return; return;
} }
/** /**
* @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse response) * @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse response)
*/ */
protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
// TODO Auto-generated method stub // TODO Auto-generated method stub
doGet(request, response); doGet(request, response);
} }
} }
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论