springboot整合kafka和storm项目更新，增加项目打包，和解决在storm环境运行的bug

springboot-kafka-storm/src/main/java/com/pancm/Application.java

@@ -26,7 +26,6 @@ public static void main(String[] args) {
 		ConfigurableApplicationContext context = SpringApplication.run(Application.class, args);
 		GetSpringBean springBean=new GetSpringBean();
 		springBean.setApplicationContext(context);
-
 	}
 
 }

springboot-kafka-storm/src/main/java/com/pancm/SpringBootApp.java

@@ -0,0 +1,26 @@
+package com.pancm;
+
+
+import com.pancm.util.GetSpringBean;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.ConfigurableApplicationContext;
+
+/**
+ * @author pancm
+ * @Title: springBoot-study
+ * @Description:
+ * @Version:1.0.0
+ * @Since:jdk1.8
+ * @date 2019/8/22
+ */
+@SpringBootApplication
+public class SpringBootApp {
+
+    public static void run(String args) {
+        // 启动嵌入式的 Tomcat 并初始化 Spring 环境及其各 Spring 组件
+        ConfigurableApplicationContext context = SpringApplication.run(Application.class, args);
+        GetSpringBean springBean=new GetSpringBean();
+        springBean.setApplicationContext(context);
+    }
+}

springboot-kafka-storm/src/main/java/com/pancm/storm/bolt/InsertBolt.java

@@ -40,7 +40,7 @@ public class InsertBolt extends BaseRichBolt{
 		private static final Logger logger = LoggerFactory.getLogger(InsertBolt.class);
 
 
-	   private UserService userService;
+	    private UserService userService;
 
 
 		@SuppressWarnings("rawtypes")

springboot-kafka-storm/src/main/java/com/pancm/storm/spout/KafkaInsertDataSpout.java

@@ -51,7 +51,7 @@ public class KafkaInsertDataSpout extends BaseRichSpout{
 	private ConsumerRecords<String, String> msgList;
 
 
-	public static ApplicationConfiguration app;
+	private ApplicationConfiguration app;
 
 
 

springboot-kafka-storm/src/main/java/com/pancm/util/GetSpringBean.java

@@ -1,5 +1,6 @@
 package com.pancm.util;
 
+import com.pancm.SpringBootApp;
 import org.springframework.beans.BeansException;
 import org.springframework.context.ApplicationContext;
 import org.springframework.context.ApplicationContextAware;
@@ -23,7 +24,9 @@ public static Object getBean(String name) {
 	}
 
 	public static <T> T getBean(Class<T> c) {
-
+		if(context==null){
+			SpringBootApp.run("pancm");
+		}
 		return context.getBean(c);
 	}