ihaolin / antares Goto Github PK

我之前做过调度这块，哈哈，恰好写的依赖模块

你好,请问怎样添加客户端,?
以便于在任务配置列表中,可以对某个任务指定客户端执行

antares对机器配置有要求吗?tower启动不了,日志不全

您好，我是电子工业出版社博文视点的编辑，请问您有兴趣出版分布式方面的图书吗：）

目前支持shell和agent，不知道支不支持web

if (instance != null && finished){ jobSupport.checkJobInstanceFinish(shardFinishDto); }

检查是否job instance完成的时候并没有触发下游啊

在windows下，能够正常使用，最近将环境移了Linux-Debian上，如果全部使用127.0.0.1可以启动，但是如果换成本机ip，则会错，报错如下：
java.net.BindException: Cannot assign requested address: bind
at sun.nio.ch.Net.bind0(Native Method)
at sun.nio.ch.Net.bind(Net.java:433)
at sun.nio.ch.Net.bind(Net.java:425)
at sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:223)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:74)
at org.apache.tomcat.util.net.NioEndpoint.bind(NioEndpoint.java:210)
at org.apache.tomcat.util.net.AbstractEndpoint.start(AbstractEndpoint.java:990)
at org.apache.coyote.AbstractProtocol.start(AbstractProtocol.java:635)
at org.apache.catalina.connector.Connector.startInternal(Connector.java:1022)
at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:150)
at org.apache.catalina.core.StandardService.addConnector(StandardService.java:225)
at org.springframework.boot.context.embedded.tomcat.TomcatEmbeddedServletContainer.addPreviouslyRemovedConnectors(TomcatEmbeddedServletContainer.java:250)
at org.springframework.boot.context.embedded.tomcat.TomcatEmbeddedServletContainer.start(TomcatEmbeddedServletContainer.java:193)
at org.springframework.boot.context.embedded.EmbeddedWebApplicationContext.startEmbeddedServletContainer(EmbeddedWebApplicationContext.java:297)
at org.springframework.boot.context.embedded.EmbeddedWebApplicationContext.finishRefresh(EmbeddedWebApplicationContext.java:145)
at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:546)
at org.springframework.boot.context.embedded.EmbeddedWebApplicationContext.refresh(EmbeddedWebApplicationContext.java:122)
at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:693)
at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:360)
at org.springframework.boot.SpringApplication.run(SpringApplication.java:303)
at org.springframework.boot.SpringApplication.run(SpringApplication.java:1118)
at org.springframework.boot.SpringApplication.run(SpringApplication.java:1107)
at me.hao0.antares.server.Bootstrap.main(Bootstrap.java:23)
2017-10-11 14:27:27.541 [main] ERROR - Failed to start connector [Connector[HTTP/1.1-22122]]
org.apache.catalina.LifecycleException: Failed to start component [Connector[HTTP/1.1-22122]]
at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:167)
at org.apache.catalina.core.StandardService.addConnector(StandardService.java:225)
at org.springframework.boot.context.embedded.tomcat.TomcatEmbeddedServletContainer.addPreviouslyRemovedConnectors(TomcatEmbeddedServletContainer.java:250)
at org.springframework.boot.context.embedded.tomcat.TomcatEmbeddedServletContainer.start(TomcatEmbeddedServletContainer.java:193)
at org.springframework.boot.context.embedded.EmbeddedWebApplicationContext.startEmbeddedServletContainer(EmbeddedWebApplicationContext.java:297)
at org.springframework.boot.context.embedded.EmbeddedWebApplicationContext.finishRefresh(EmbeddedWebApplicationContext.java:145)
at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:546)
at org.springframework.boot.context.embedded.EmbeddedWebApplicationContext.refresh(EmbeddedWebApplicationContext.java:122)
at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:693)
at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:360)
at org.springframework.boot.SpringApplication.run(SpringApplication.java:303)
at org.springframework.boot.SpringApplication.run(SpringApplication.java:1118)
at org.springframework.boot.SpringApplication.run(SpringApplication.java:1107)
at me.hao0.antares.server.Bootstrap.main(Bootstrap.java:23)
Caused by: org.apache.catalina.LifecycleException: service.getName(): "Tomcat"; Protocol handler start failed
at org.apache.catalina.connector.Connector.startInternal(Connector.java:1029)
at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:150)
... 13 common frames omitted
Caused by: java.net.BindException: Cannot assign requested address: bind
at sun.nio.ch.Net.bind0(Native Method)
at sun.nio.ch.Net.bind(Net.java:433)
at sun.nio.ch.Net.bind(Net.java:425)
at sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:223)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:74)
at org.apache.tomcat.util.net.NioEndpoint.bind(NioEndpoint.java:210)
at org.apache.tomcat.util.net.AbstractEndpoint.start(AbstractEndpoint.java:990)
at org.apache.coyote.AbstractProtocol.start(AbstractProtocol.java:635)
at org.apache.catalina.connector.Connector.startInternal(Connector.java:1022)
... 14 common frames omitted
2017-10-11 14:27:27.550 [main] INFO - Pausing ProtocolHandler ["http-nio-47.94.225.72-22122"]
2017-10-11 14:27:27.550 [main] INFO - Stopping service [Tomcat]
2017-10-11 14:27:27.559 [main] INFO - The stop() method was called on component [StandardServer[-1]] after stop() had already been called. The second call will be ignored.
2017-10-11 14:27:27.559 [main] INFO - Stopping ProtocolHandler ["http-nio-47.94.225.72-22122"]
2017-10-11 14:27:27.559 [main] INFO - Destroying ProtocolHandler ["http-nio-47.94.225.72-22122"]
2017-10-11 14:27:27.561 [main] INFO -

Error starting ApplicationContext. To display the auto-configuration report re-run your application with 'debug' enabled.
2017-10-11 14:27:27.566 [main] ERROR -

APPLICATION FAILED TO START

Description:

The Tomcat connector configured to listen on port 22122 failed to start. The port may already be in use or the connector may be misconfigured.

服务器失效转移：当服务器集群中某个节点宕机时，其正在调度的任务将转移到其他节点去调度；

是否可以理解为：所有任务是平均分配到server中的，一旦其中一个server宕机了，其他server会接管宕机的server的任务，如果这个宕机的server恢复了，其他server又会把任务还给这个server？
如果是这样的话，这个分布式算法太牛逼了，求教怎么做到的

JobPool下的createQuartzJob方法

if (jobDetail.getConfig().getMisfire()) {
    // ignore all misfired
    scheduleBuilder.withMisfireHandlingInstructionDoNothing();
} else {
    scheduleBuilder.withMisfireHandlingInstructionFireAndProceed();
}

判断逻辑是不是反了? misfire为true时才设置为FireAndProceed, 否则为DoNothing ?

请问有考虑提供spring boot 的starter吗？

如题， 前端是用的Vue还是Ractk呢， 想学习一下呢~~

支不支持其它语言?

配置修改，redis配置成redis cluster

1. 调度服务就会报 has a running instance ，任务就不会再执行
2. Antares系统报警 elapsedTime 会无限累加 每次都会告警
3. 停止服务再启动服务，调度已经停止，客户端依旧会执行任务

不指定服务ip，zk上注册ip为-1 建议能修改成获取当前服务器ip。
如果必须显性指定ip 相当不利于容器化 例如像k8s这样内部分配虚拟ip 必须指定会造成扩展困难

job写好后放在哪里，是要重新编译程序吗

一个job如果需要指定在某一个客户端执行现在是怎么处理的呢？
比如调用shell，shell脚本是放在某一台主机上的。

新建的应用和任务老自动被删除。