[Java] Storm框架整合springboot的方法

@override
public void open(map map, topologycontext topologycontext, spoutoutputcollector spoutoutputcollector) {
 //启动springboot应用
 springstormapplication.run();
 
 this.map = map;
 this.topologycontext = topologycontext;
 this.spoutoutputcollector = spoutoutputcollector;
}

@override
public void prepare(map map, topologycontext topologycontext, outputcollector outputcollector) {
 //启动springboot应用
 springstormapplication.run();
 
 this.map = map;
 this.topologycontext = topologycontext;
 this.outputcollector = outputcollector;
}
·springstormapplication启动类
@springbootapplication
@componentscan(value = "com.xxx.storm")
public class springstormapplication {
 /**
  * 非工程启动入口，所以不用main方法
  * @param args
  */
 public static void run(string ...args) {
  springapplication app = new springapplication(springstormapplication.class);
  //我们并不需要web servlet功能，所以设置为webapplicationtype.none
  app.setwebapplicationtype(webapplicationtype.none);
  //忽略掉banner输出
  app.setbannermode(banner.mode.off);
  //忽略spring启动信息日志
  app.setlogstartupinfo(false);
  app.run(args);
 }
}

@springbootapplication
@componentscan(value = "com.xxx.web")
public class platformapplication {
 public static void main(string[] args) {
  springapplication.run(platformapplication.class, args);
 }
}

@component
public class beanutils implements applicationcontextaware {
 private static applicationcontext applicationcontext = null;
 @override
 public void setapplicationcontext(applicationcontext applicationcontext) throws beansexception {
  if (beanutils.applicationcontext == null) {
   beanutils.applicationcontext = applicationcontext;
  }
 }
 public static applicationcontext getapplicationcontext() {
  return applicationcontext;
 }
 public static object getbean(string name) {
  return getapplicationcontext().getbean(name);
 }
 public static <t> t getbean(class<t> clazz) {
  return getapplicationcontext().getbean(clazz);
 }
 public static <t> t getbean(string name, class<t> clazz) {
  return getapplicationcontext().getbean(name, clazz);
 }
}

@override
public void execute(tuple tuple) {
 filterservice filterservice = (filterservice) beanutils.getbean("filterservice");
 filterservice.deleteall();
}

@service("filterservice")
public class filterservice {
 @autowired
 userrepository userrepository;
 
 public void deleteall() {
  userrepository.deleteall();
 }
}

slf4j: class path contains multiple slf4j bindings.
slf4j: found binding in [jar:file:/applications/intellij%20idea.app/contents/bin/~/.m2/repository/org/apache/logging/log4j/log4j-slf4j-impl/2.11.1/log4j-slf4j-impl-2.11.1.jar!/org/slf4j/impl/staticloggerbinder.class]
slf4j: found binding in [jar:file:/applications/intellij%20idea.app/contents/bin/~/.m2/repository/ch/qos/logback/logback-classic/1.2.3/logback-classic-1.2.3.jar!/org/slf4j/impl/staticloggerbinder.class]
slf4j: see http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
slf4j: actual binding is of type [org.apache.logging.slf4j.log4jloggerfactory]

<dependency>
 <groupid>org.springframework.boot</groupid>
 <artifactid>spring-boot-starter</artifactid>
 <exclusions>
  <exclusion>
   <groupid>org.apache.logging.log4j</groupid>
   <artifactid>log4j-to-slf4j2</artifactid>
  </exclusion>
  <exclusion>
   <groupid>ch.qos.logback</groupid>
   <artifactid>logback-classic2</artifactid>
  </exclusion>
 </exclusions>
</dependency>