获取数据的代码编写

.mvn/wrapper/MavenWrapperDownloader.java

@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 import java.net.*;
 import java.io.*;
 import java.nio.channels.*;
@@ -25,7 +26,7 @@ public class MavenWrapperDownloader {
      * Default URL to download the maven-wrapper.jar from, if no 'downloadUrl' is provided.
      */
     private static final String DEFAULT_DOWNLOAD_URL = "https://repo.maven.apache.org/maven2/io/takari/maven-wrapper/"
-        + WRAPPER_VERSION + "/maven-wrapper-" + WRAPPER_VERSION + ".jar";
+            + WRAPPER_VERSION + "/maven-wrapper-" + WRAPPER_VERSION + ".jar";
 
     /**
      * Path to the maven-wrapper.properties file, which might contain a downloadUrl property to
@@ -54,7 +55,7 @@ public class MavenWrapperDownloader {
         // wrapperUrl parameter.
         File mavenWrapperPropertyFile = new File(baseDirectory, MAVEN_WRAPPER_PROPERTIES_PATH);
         String url = DEFAULT_DOWNLOAD_URL;
-        if(mavenWrapperPropertyFile.exists()) {
+        if (mavenWrapperPropertyFile.exists()) {
             FileInputStream mavenWrapperPropertyFileInputStream = null;
             try {
                 mavenWrapperPropertyFileInputStream = new FileInputStream(mavenWrapperPropertyFile);
@@ -65,7 +66,7 @@ public class MavenWrapperDownloader {
                 System.out.println("- ERROR loading '" + MAVEN_WRAPPER_PROPERTIES_PATH + "'");
             } finally {
                 try {
-                    if(mavenWrapperPropertyFileInputStream != null) {
+                    if (mavenWrapperPropertyFileInputStream != null) {
                         mavenWrapperPropertyFileInputStream.close();
                     }
                 } catch (IOException e) {
@@ -76,8 +77,8 @@ public class MavenWrapperDownloader {
         System.out.println("- Downloading from: " + url);
 
         File outputFile = new File(baseDirectory.getAbsolutePath(), MAVEN_WRAPPER_JAR_PATH);
-        if(!outputFile.getParentFile().exists()) {
-            if(!outputFile.getParentFile().mkdirs()) {
+        if (!outputFile.getParentFile().exists()) {
+            if (!outputFile.getParentFile().mkdirs()) {
                 System.out.println(
                         "- ERROR creating output directory '" + outputFile.getParentFile().getAbsolutePath() + "'");
             }

pom.xml

@@ -1,7 +1,7 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <project xmlns="http://maven.apache.org/POM/4.0.0"
-		 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-		 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <modelVersion>4.0.0</modelVersion>
     <parent>
         <groupId>org.springframework.boot</groupId>
@@ -50,10 +50,10 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-jdbc</artifactId>
         </dependency>
-       <!-- <dependency>
-            <groupId>com.zaxxer</groupId>
-            <artifactId>HikariCP</artifactId>
-        </dependency>-->
+        <!-- <dependency>
+             <groupId>com.zaxxer</groupId>
+             <artifactId>HikariCP</artifactId>
+         </dependency>-->
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-activemq</artifactId>
@@ -64,6 +64,10 @@
         </dependency>
         <dependency>
             <groupId>org.apache.camel.springboot</groupId>
+            <artifactId>camel-rest-starter</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.camel.springboot</groupId>
             <artifactId>camel-spring-boot-starter</artifactId>
         </dependency>
         <dependency>
@@ -84,6 +88,10 @@
         </dependency>
         <dependency>
             <groupId>org.apache.camel.springboot</groupId>
+            <artifactId>camel-rest-starter</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.camel.springboot</groupId>
             <artifactId>camel-file-starter</artifactId>
         </dependency>
         <dependency>
@@ -96,6 +104,28 @@
             <optional>true</optional>
         </dependency>
         <dependency>
+            <groupId>org.apache.camel</groupId>
+            <artifactId>camel-http</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-core</artifactId>
+            <version>2.12.3</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.camel</groupId>
+            <artifactId>camel-jackson</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.camel</groupId>
+            <artifactId>camel-jetty</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.camel</groupId>
+            <artifactId>camel-servlet</artifactId>
+        </dependency>
+        <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-test</artifactId>
             <scope>test</scope>
@@ -111,6 +141,11 @@
             <artifactId>spring-integration-test</artifactId>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+            <version>1.2.69</version>
+        </dependency>
     </dependencies>
 
 

settings.xml

@@ -46,297 +46,297 @@ under the License.
 <settings xmlns="http://maven.apache.org/SETTINGS/1.0.0"
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
           xsi:schemaLocation="http://maven.apache.org/SETTINGS/1.0.0 http://maven.apache.org/xsd/settings-1.0.0.xsd">
-  <!-- localRepository
-   | The path to the local repository maven will use to store artifacts.
-   |
-   | Default: ${user.home}/.m2/repository
-  <localRepository>/path/to/local/repo</localRepository>
-  -->
-  <localRepository>D:/repository</localRepository>
-
-  <!-- interactiveMode
-   | This will determine whether maven prompts you when it needs input. If set to false,
-   | maven will use a sensible default value, perhaps based on some other setting, for
-   | the parameter in question.
-   |
-   | Default: true
-  <interactiveMode>true</interactiveMode>
-  -->
-
-  <!-- offline
-   | Determines whether maven should attempt to connect to the network when executing a build.
-   | This will have an effect on artifact downloads, artifact deployment, and others.
-   |
-   | Default: false
-  <offline>false</offline>
-  -->
-
-  <!-- pluginGroups
-   | This is a list of additional group identifiers that will be searched when resolving plugins by their prefix, i.e.
-   | when invoking a command line like "mvn prefix:goal". Maven will automatically add the group identifiers
-   | "org.apache.maven.plugins" and "org.codehaus.mojo" if these are not already contained in the list.
-   |-->
-  <pluginGroups>
-    <!-- pluginGroup
-     | Specifies a further group identifier to use for plugin lookup.
-    <pluginGroup>com.your.plugins</pluginGroup>
+    <!-- localRepository
+     | The path to the local repository maven will use to store artifacts.
+     |
+     | Default: ${user.home}/.m2/repository
+    <localRepository>/path/to/local/repo</localRepository>
     -->
-  </pluginGroups>
+    <localRepository>D:/repository</localRepository>
 
-  <!-- proxies
-   | This is a list of proxies which can be used on this machine to connect to the network.
-   | Unless otherwise specified (by system property or command-line switch), the first proxy
-   | specification in this list marked as active will be used.
-   |-->
-  <proxies>
-    <!-- proxy
-     | Specification for one proxy, to be used in connecting to the network.
+    <!-- interactiveMode
+     | This will determine whether maven prompts you when it needs input. If set to false,
+     | maven will use a sensible default value, perhaps based on some other setting, for
+     | the parameter in question.
      |
-    <proxy>
-      <id>optional</id>
-      <active>true</active>
-      <protocol>http</protocol>
-      <username>proxyuser</username>
-      <password>proxypass</password>
-      <host>proxy.host.net</host>
-      <port>80</port>
-      <nonProxyHosts>local.net|some.host.com</nonProxyHosts>
-    </proxy>
+     | Default: true
+    <interactiveMode>true</interactiveMode>
     -->
-  </proxies>
 
-  <!-- servers
-   | This is a list of authentication profiles, keyed by the server-id used within the system.
-   | Authentication profiles can be used whenever maven must make a connection to a remote server.
-   |-->
-  <servers>
-    <!-- server
-     | Specifies the authentication information to use when connecting to a particular server, identified by
-     | a unique name within the system (referred to by the 'id' attribute below).
-     |
-     | NOTE: You should either specify username/password OR privateKey/passphrase, since these pairings are
-     |       used together.
+    <!-- offline
+     | Determines whether maven should attempt to connect to the network when executing a build.
+     | This will have an effect on artifact downloads, artifact deployment, and others.
      |
-    <server>
-      <id>deploymentRepo</id>
-      <username>repouser</username>
-      <password>repopwd</password>
-    </server>
+     | Default: false
+    <offline>false</offline>
     -->
 
-    <!-- Another sample, using keys to authenticate.
-    <server>
-      <id>siteServer</id>
-      <privateKey>/path/to/private/key</privateKey>
-      <passphrase>optional; leave empty if not used.</passphrase>
-    </server>
-    -->
-	<server>   
-		<id>releases</id>   
-		<username>admin</username>   
-		<password>123456</password>   
-	</server>
-	<server>   
-		<id>snapshots</id>   
-		<username>admin</username>   
-		<password>123456</password>   
-	</server>
-  </servers>
+    <!-- pluginGroups
+     | This is a list of additional group identifiers that will be searched when resolving plugins by their prefix, i.e.
+     | when invoking a command line like "mvn prefix:goal". Maven will automatically add the group identifiers
+     | "org.apache.maven.plugins" and "org.codehaus.mojo" if these are not already contained in the list.
+     |-->
+    <pluginGroups>
+        <!-- pluginGroup
+         | Specifies a further group identifier to use for plugin lookup.
+        <pluginGroup>com.your.plugins</pluginGroup>
+        -->
+    </pluginGroups>
 
-  <!-- mirrors
-   | This is a list of mirrors to be used in downloading artifacts from remote repositories.
-   |
-   | It works like this: a POM may declare a repository to use in resolving certain artifacts.
-   | However, this repository may have problems with heavy traffic at times, so people have mirrored
-   | it to several places.
-   |
-   | That repository definition will have a unique id, so we can create a mirror reference for that
-   | repository, to be used as an alternate download site. The mirror site will be the preferred
-   | server for that repository.
-   |-->
-  <mirrors>
-    <!-- mirror
-     | Specifies a repository mirror site to use instead of a given repository. The repository that
-     | this mirror serves has an ID that matches the mirrorOf element of this mirror. IDs are used
-     | for inheritance and direct lookup purposes, and must be unique across the set of mirrors.
-     |
-    <mirror>
-      <id>mirrorId</id>
-      <mirrorOf>repositoryId</mirrorOf>
-      <name>Human Readable Name for this Mirror.</name>
-      <url>http://my.repository.com/repo/path</url>
-    </mirror>
-	
-	 <mirror>
-	  <id>aliyunmaven</id>
-	  <mirrorOf>*</mirrorOf>
-	  <name>阿里云公共仓库</name>
-	  <url>https://maven.aliyun.com/repository/public</url>
-	</mirror>
-	
-     -->
-	<mirror>
-		<id>nexus</id>
-		<name>maven-public</name>
-		<url>http://117.34.118.57:28081/repository/maven-public/</url>
-		<mirrorOf>*</mirrorOf>
-	</mirror>
-	
-  </mirrors>
+    <!-- proxies
+     | This is a list of proxies which can be used on this machine to connect to the network.
+     | Unless otherwise specified (by system property or command-line switch), the first proxy
+     | specification in this list marked as active will be used.
+     |-->
+    <proxies>
+        <!-- proxy
+         | Specification for one proxy, to be used in connecting to the network.
+         |
+        <proxy>
+          <id>optional</id>
+          <active>true</active>
+          <protocol>http</protocol>
+          <username>proxyuser</username>
+          <password>proxypass</password>
+          <host>proxy.host.net</host>
+          <port>80</port>
+          <nonProxyHosts>local.net|some.host.com</nonProxyHosts>
+        </proxy>
+        -->
+    </proxies>
+
+    <!-- servers
+     | This is a list of authentication profiles, keyed by the server-id used within the system.
+     | Authentication profiles can be used whenever maven must make a connection to a remote server.
+     |-->
+    <servers>
+        <!-- server
+         | Specifies the authentication information to use when connecting to a particular server, identified by
+         | a unique name within the system (referred to by the 'id' attribute below).
+         |
+         | NOTE: You should either specify username/password OR privateKey/passphrase, since these pairings are
+         |       used together.
+         |
+        <server>
+          <id>deploymentRepo</id>
+          <username>repouser</username>
+          <password>repopwd</password>
+        </server>
+        -->
+
+        <!-- Another sample, using keys to authenticate.
+        <server>
+          <id>siteServer</id>
+          <privateKey>/path/to/private/key</privateKey>
+          <passphrase>optional; leave empty if not used.</passphrase>
+        </server>
+        -->
+        <server>
+            <id>releases</id>
+            <username>admin</username>
+            <password>123456</password>
+        </server>
+        <server>
+            <id>snapshots</id>
+            <username>admin</username>
+            <password>123456</password>
+        </server>
+    </servers>
 
-  <!-- profiles
-   | This is a list of profiles which can be activated in a variety of ways, and which can modify
-   | the build process. Profiles provided in the settings.xml are intended to provide local machine-
-   | specific paths and repository locations which allow the build to work in the local environment.
-   |
-   | For example, if you have an integration testing plugin - like cactus - that needs to know where
-   | your Tomcat instance is installed, you can provide a variable here such that the variable is
-   | dereferenced during the build process to configure the cactus plugin.
-   |
-   | As noted above, profiles can be activated in a variety of ways. One way - the activeProfiles
-   | section of this document (settings.xml) - will be discussed later. Another way essentially
-   | relies on the detection of a system property, either matching a particular value for the property,
-   | or merely testing its existence. Profiles can also be activated by JDK version prefix, where a
-   | value of '1.4' might activate a profile when the build is executed on a JDK version of '1.4.2_07'.
-   | Finally, the list of active profiles can be specified directly from the command line.
-   |
-   | NOTE: For profiles defined in the settings.xml, you are restricted to specifying only artifact
-   |       repositories, plugin repositories, and free-form properties to be used as configuration
-   |       variables for plugins in the POM.
-   |
-   |-->
-  <profiles>
-    <!-- profile
-     | Specifies a set of introductions to the build process, to be activated using one or more of the
-     | mechanisms described above. For inheritance purposes, and to activate profiles via <activatedProfiles/>
-     | or the command line, profiles have to have an ID that is unique.
+    <!-- mirrors
+     | This is a list of mirrors to be used in downloading artifacts from remote repositories.
      |
-     | An encouraged best practice for profile identification is to use a consistent naming convention
-     | for profiles, such as 'env-dev', 'env-test', 'env-production', 'user-jdcasey', 'user-brett', etc.
-     | This will make it more intuitive to understand what the set of introduced profiles is attempting
-     | to accomplish, particularly when you only have a list of profile id's for debug.
+     | It works like this: a POM may declare a repository to use in resolving certain artifacts.
+     | However, this repository may have problems with heavy traffic at times, so people have mirrored
+     | it to several places.
      |
-     | This profile example uses the JDK version to trigger activation, and provides a JDK-specific repo.
-    <profile>
-      <id>jdk-1.4</id>
+     | That repository definition will have a unique id, so we can create a mirror reference for that
+     | repository, to be used as an alternate download site. The mirror site will be the preferred
+     | server for that repository.
+     |-->
+    <mirrors>
+        <!-- mirror
+         | Specifies a repository mirror site to use instead of a given repository. The repository that
+         | this mirror serves has an ID that matches the mirrorOf element of this mirror. IDs are used
+         | for inheritance and direct lookup purposes, and must be unique across the set of mirrors.
+         |
+        <mirror>
+          <id>mirrorId</id>
+          <mirrorOf>repositoryId</mirrorOf>
+          <name>Human Readable Name for this Mirror.</name>
+          <url>http://my.repository.com/repo/path</url>
+        </mirror>
 
-      <activation>
-        <jdk>1.4</jdk>
-      </activation>
+         <mirror>
+          <id>aliyunmaven</id>
+          <mirrorOf>*</mirrorOf>
+          <name>阿里云公共仓库</name>
+          <url>https://maven.aliyun.com/repository/public</url>
+        </mirror>
 
-      <repositories>
-        <repository>
-          <id>jdk14</id>
-          <name>Repository for JDK 1.4 builds</name>
-          <url>http://www.myhost.com/maven/jdk14</url>
-          <layout>default</layout>
-          <snapshotPolicy>always</snapshotPolicy>
-        </repository>
-      </repositories>
-    </profile>
-    -->
-<profile>
-      <activation>
-          <!-- 默认激活此 profile -->
-          <activeByDefault>true</activeByDefault>
-      </activation>
-      <repositories>
-        <repository>
-          <id>nexus</id>
-          <name>Nexus Repository</name>
-          <url>http://117.34.118.57:28081/repository/maven-public/</url>
-          <releases>
-            <enabled>true</enabled>
-          </releases>
-        </repository>
-      
-        <repository>
-          <id>central</id>
-          <name>Nexus Central Repository</name>
-          <url>http://117.34.118.57:28081/repository/maven-central/</url>
-          <releases>
-            <enabled>true</enabled>
-          </releases>
-          <snapshots>
-            <enabled>false</enabled>
-          </snapshots>
-        </repository>
-        
-        <repository>
-          <id>release</id>
-          <name>Nexus Release Repository</name>
-          <url>http://117.34.118.57:28081/repository/maven-releases/</url>
-          <releases>
-            <enabled>true</enabled>
-          </releases>
-          <snapshots>
-            <enabled>false</enabled>
-          </snapshots>
-        </repository>
-        
-        <repository>
-          <id>snapshots</id>
-          <name>Nexus Snapshots Repository</name>
-          <url>http://117.34.118.57:28081/repository/maven-snapshots/</url>
-          <releases>
-            <enabled>true</enabled>
-          </releases>
-          <snapshots>
-            <enabled>true</enabled>
-          </snapshots>
-        </repository>
-      </repositories>
-      
-      <pluginRepositories>
-        <pluginRepository>
-          <id>plugins</id>
-          <name>Nexus Plugin Repositories</name>
-          <url>http://117.34.118.57:28081/repository/maven-public/</url>
-        </pluginRepository>
-      </pluginRepositories>
-    </profile>
-    <!--
-     | Here is another profile, activated by the system property 'target-env' with a value of 'dev',
-     | which provides a specific path to the Tomcat instance. To use this, your plugin configuration
-     | might hypothetically look like:
+         -->
+        <mirror>
+            <id>nexus</id>
+            <name>maven-public</name>
+            <url>http://117.34.118.57:28081/repository/maven-public/</url>
+            <mirrorOf>*</mirrorOf>
+        </mirror>
+
+    </mirrors>
+
+    <!-- profiles
+     | This is a list of profiles which can be activated in a variety of ways, and which can modify
+     | the build process. Profiles provided in the settings.xml are intended to provide local machine-
+     | specific paths and repository locations which allow the build to work in the local environment.
      |
-     | ...
-     | <plugin>
-     |   <groupId>org.myco.myplugins</groupId>
-     |   <artifactId>myplugin</artifactId>
+     | For example, if you have an integration testing plugin - like cactus - that needs to know where
+     | your Tomcat instance is installed, you can provide a variable here such that the variable is
+     | dereferenced during the build process to configure the cactus plugin.
      |
-     |   <configuration>
-     |     <tomcatLocation>${tomcatPath}</tomcatLocation>
-     |   </configuration>
-     | </plugin>
-     | ...
+     | As noted above, profiles can be activated in a variety of ways. One way - the activeProfiles
+     | section of this document (settings.xml) - will be discussed later. Another way essentially
+     | relies on the detection of a system property, either matching a particular value for the property,
+     | or merely testing its existence. Profiles can also be activated by JDK version prefix, where a
+     | value of '1.4' might activate a profile when the build is executed on a JDK version of '1.4.2_07'.
+     | Finally, the list of active profiles can be specified directly from the command line.
      |
-     | NOTE: If you just wanted to inject this configuration whenever someone set 'target-env' to
-     |       anything, you could just leave off the <value/> inside the activation-property.
+     | NOTE: For profiles defined in the settings.xml, you are restricted to specifying only artifact
+     |       repositories, plugin repositories, and free-form properties to be used as configuration
+     |       variables for plugins in the POM.
      |
-    <profile>
-      <id>env-dev</id>
+     |-->
+    <profiles>
+        <!-- profile
+         | Specifies a set of introductions to the build process, to be activated using one or more of the
+         | mechanisms described above. For inheritance purposes, and to activate profiles via <activatedProfiles/>
+         | or the command line, profiles have to have an ID that is unique.
+         |
+         | An encouraged best practice for profile identification is to use a consistent naming convention
+         | for profiles, such as 'env-dev', 'env-test', 'env-production', 'user-jdcasey', 'user-brett', etc.
+         | This will make it more intuitive to understand what the set of introduced profiles is attempting
+         | to accomplish, particularly when you only have a list of profile id's for debug.
+         |
+         | This profile example uses the JDK version to trigger activation, and provides a JDK-specific repo.
+        <profile>
+          <id>jdk-1.4</id>
 
-      <activation>
-        <property>
-          <name>target-env</name>
-          <value>dev</value>
-        </property>
-      </activation>
+          <activation>
+            <jdk>1.4</jdk>
+          </activation>
 
-      <properties>
-        <tomcatPath>/path/to/tomcat/instance</tomcatPath>
-      </properties>
-    </profile>
-    -->
-  </profiles>
+          <repositories>
+            <repository>
+              <id>jdk14</id>
+              <name>Repository for JDK 1.4 builds</name>
+              <url>http://www.myhost.com/maven/jdk14</url>
+              <layout>default</layout>
+              <snapshotPolicy>always</snapshotPolicy>
+            </repository>
+          </repositories>
+        </profile>
+        -->
+        <profile>
+            <activation>
+                <!-- 默认激活此 profile -->
+                <activeByDefault>true</activeByDefault>
+            </activation>
+            <repositories>
+                <repository>
+                    <id>nexus</id>
+                    <name>Nexus Repository</name>
+                    <url>http://117.34.118.57:28081/repository/maven-public/</url>
+                    <releases>
+                        <enabled>true</enabled>
+                    </releases>
+                </repository>
+
+                <repository>
+                    <id>central</id>
+                    <name>Nexus Central Repository</name>
+                    <url>http://117.34.118.57:28081/repository/maven-central/</url>
+                    <releases>
+                        <enabled>true</enabled>
+                    </releases>
+                    <snapshots>
+                        <enabled>false</enabled>
+                    </snapshots>
+                </repository>
+
+                <repository>
+                    <id>release</id>
+                    <name>Nexus Release Repository</name>
+                    <url>http://117.34.118.57:28081/repository/maven-releases/</url>
+                    <releases>
+                        <enabled>true</enabled>
+                    </releases>
+                    <snapshots>
+                        <enabled>false</enabled>
+                    </snapshots>
+                </repository>
+
+                <repository>
+                    <id>snapshots</id>
+                    <name>Nexus Snapshots Repository</name>
+                    <url>http://117.34.118.57:28081/repository/maven-snapshots/</url>
+                    <releases>
+                        <enabled>true</enabled>
+                    </releases>
+                    <snapshots>
+                        <enabled>true</enabled>
+                    </snapshots>
+                </repository>
+            </repositories>
 
-  <!-- activeProfiles
-   | List of profiles that are active for all builds.
-   |
-  <activeProfiles>
-    <activeProfile>alwaysActiveProfile</activeProfile>
-    <activeProfile>anotherAlwaysActiveProfile</activeProfile>
-  </activeProfiles>
-  -->
+            <pluginRepositories>
+                <pluginRepository>
+                    <id>plugins</id>
+                    <name>Nexus Plugin Repositories</name>
+                    <url>http://117.34.118.57:28081/repository/maven-public/</url>
+                </pluginRepository>
+            </pluginRepositories>
+        </profile>
+        <!--
+         | Here is another profile, activated by the system property 'target-env' with a value of 'dev',
+         | which provides a specific path to the Tomcat instance. To use this, your plugin configuration
+         | might hypothetically look like:
+         |
+         | ...
+         | <plugin>
+         |   <groupId>org.myco.myplugins</groupId>
+         |   <artifactId>myplugin</artifactId>
+         |
+         |   <configuration>
+         |     <tomcatLocation>${tomcatPath}</tomcatLocation>
+         |   </configuration>
+         | </plugin>
+         | ...
+         |
+         | NOTE: If you just wanted to inject this configuration whenever someone set 'target-env' to
+         |       anything, you could just leave off the <value/> inside the activation-property.
+         |
+        <profile>
+          <id>env-dev</id>
+
+          <activation>
+            <property>
+              <name>target-env</name>
+              <value>dev</value>
+            </property>
+          </activation>
+
+          <properties>
+            <tomcatPath>/path/to/tomcat/instance</tomcatPath>
+          </properties>
+        </profile>
+        -->
+    </profiles>
+
+    <!-- activeProfiles
+     | List of profiles that are active for all builds.
+     |
+    <activeProfiles>
+      <activeProfile>alwaysActiveProfile</activeProfile>
+      <activeProfile>anotherAlwaysActiveProfile</activeProfile>
+    </activeProfiles>
+    -->
 </settings>

src/main/java/com/gct/tools/etlcamelhuge/EtlCamelHugeApplication.java

@@ -1,8 +1,11 @@
 package com.gct.tools.etlcamelhuge;
 
+import org.apache.camel.component.servlet.CamelHttpTransportServlet;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.web.servlet.ServletRegistrationBean;
+import org.springframework.context.annotation.Bean;
 
 @SpringBootApplication
 public class EtlCamelHugeApplication {

src/main/java/com/gct/tools/etlcamelhuge/camelconfig/CamelContextAwareConfiguration.java

@@ -33,7 +33,7 @@ public class CamelContextAwareConfiguration implements CamelContextAware, Applic
         this.camelContext = cc;
         camelContext.setNameStrategy(new DefaultCamelContextNameStrategy("lloyd-camel-etl"));
         final Map<String, RouteBuilder> beans = applicationContext.getBeansOfType(RouteBuilder.class);
-        log.info("[I say:] total {} defined route builders ",beans.size());
+        log.info("[I say:] total {} defined route builders ", beans.size());
         for (RouteBuilder value : beans.values()) camelContext.addRoutes(value);
     }
 

src/main/java/com/gct/tools/etlcamelhuge/camelconfig/MyDataSourceConfiguration.java

@@ -16,17 +16,23 @@ import javax.sql.DataSource;
  * @since 2021/4/21 下午1:42
  */
 @Configuration
-public class MyDataSourceConfiguration  {
+public class MyDataSourceConfiguration {
 
     @Bean(name = "centralbase")
     @ConfigurationProperties(prefix = "spring.datasource.ds1")
-    public DataSource dataSource1( ){
+    public DataSource dataSource1() {
         return DataSourceBuilder.create().build();
     }
 
     @Bean(name = "diagnosis")
     @ConfigurationProperties(prefix = "spring.datasource.ds2")
-    public DataSource dataSource2( ){
+    public DataSource dataSource2() {
+        return DataSourceBuilder.create().build();
+    }
+
+    @Bean(name = "oracle")
+    @ConfigurationProperties(prefix = "spring.datasource.ds3")
+    public DataSource dataSource3() {
         return DataSourceBuilder.create().build();
     }
 }

src/main/java/com/gct/tools/etlcamelhuge/routeconfig/CamelFileConfiguration.java

@@ -62,44 +62,44 @@ public class CamelFileConfiguration {
             public void configure() throws Exception {
 //				from("jms-queue:queue:my-queue")
                 from("file:{{user.home}}/Desktop/cameltest/in")
-                    .routeId("file-to-file")
+                        .routeId("file-to-file")
                         .transform()
-                            .body(GenericFile.class, this::apply)
+                        .body(GenericFile.class, this::apply)
                         .log("this is my test -camel")
                         .setHeader("CamelFileName", () -> UUID.randomUUID().toString())
                         .tracing()
                         .process()
-                            .exchange(exchange -> {
-                                new Date().toInstant();
-                                LocalDateTime start = LocalDateTime.now();
-                                final Message in = exchange.getIn();
-                                String body = in.getBody(String.class);
-                                log.info("body is {}", body);
-                                Thread t = new Thread(() -> {
-                                    while (true) {
-                                        try {
-                                            Thread.sleep(1000);
-                                        } catch (InterruptedException e) {
-                                            e.printStackTrace();
-                                        }
-                                        log.warn("thread completed");
-                                        break;
+                        .exchange(exchange -> {
+                            new Date().toInstant();
+                            LocalDateTime start = LocalDateTime.now();
+                            final Message in = exchange.getIn();
+                            String body = in.getBody(String.class);
+                            log.info("body is {}", body);
+                            Thread t = new Thread(() -> {
+                                while (true) {
+                                    try {
+                                        Thread.sleep(1000);
+                                    } catch (InterruptedException e) {
+                                        e.printStackTrace();
                                     }
-                                });
-                                t.start();
+                                    log.warn("thread completed");
+                                    break;
+                                }
+                            });
+                            t.start();
 
-                                try {
-                                    t.join();
+                            try {
+                                t.join();
 
-                                } catch (InterruptedException e) {
-                                    e.printStackTrace();
-                                }
+                            } catch (InterruptedException e) {
+                                e.printStackTrace();
+                            }
 
-                                final LocalDateTime end = LocalDateTime.now();
-                                final long l = Duration.between(start, end).toDays();
-                                log.warn("run with time : {}", l);
-                            })
-                .to("file:{{user.home}}/Desktop/cameltest/out");
+                            final LocalDateTime end = LocalDateTime.now();
+                            final long l = Duration.between(start, end).toDays();
+                            log.warn("run with time : {}", l);
+                        })
+                        .to("file:{{user.home}}/Desktop/cameltest/out");
             }
         };
     }

src/main/java/com/gct/tools/etlcamelhuge/routeconfig/CamelJMSConfiguration.java

@@ -21,15 +21,15 @@ import java.io.InputStreamReader;
  */
 @Slf4j
 //@Configuration
-public class CamelJMSConfiguration  {
+public class CamelJMSConfiguration {
     @Bean
     RouteBuilder routeBuilderJms() {
         return new RouteBuilder() {
             @Override
             public void configure() throws Exception {
                 from("file:{{user.home}}/Desktop/cameltest/out")
-                    .routeId("file-to-jms")
-                    .transform()
+                        .routeId("file-to-jms")
+                        .transform()
                         .body(GenericFile.class, gf -> {
                             final BufferedReader in;
                             try {
@@ -45,24 +45,24 @@ public class CamelJMSConfiguration  {
                                 throw new RuntimeException("read fault!");
                             }
                         })
-                    .process()
+                        .process()
                         .exchange(exchange -> {
                             final Message in = exchange.getIn();
                             String body = in.getBody(String.class);
                             log.info("exchange is :" + body);
                         })
-                .to("jms:queue:testfiles").tracing();
+                        .to("jms:queue:testfiles").tracing();
 
                 from("jms:queue:testfiles")
-                    .routeId("jms-to-file")
-                    .transform()
+                        .routeId("jms-to-file")
+                        .transform()
                         .body(String.class, s -> s + "amazing\n")
-                    .process()
+                        .process()
                         .exchange(exchange -> {
                             final Message in = exchange.getIn();
                             log.info("from jms exchange is :" + in.getBody(String.class));
                         })
-                .to("file:{{user.home}}/Desktop/cameltest/jmsout").tracing();
+                        .to("file:{{user.home}}/Desktop/cameltest/jmsout").tracing();
             }
         };
     }

src/main/resources/application.yml

@@ -1,4 +1,3 @@
-
 camel:
   springboot:
     main-run-controller: true
@@ -8,7 +7,7 @@ spring:
     ds1:
       ## Hikari连接池的设置 Hikari 时间单位都是毫秒
       type: com.zaxxer.hikari.HikariDataSource
-      jdbc-url: jdbc:postgresql://101.200.219.190:54321/database
+      jdbc-url: jdbc:postgresql://10.72.143.2:54321/database
       username: root
       password: 123456
       driver-class-name: org.postgresql.Driver
@@ -30,7 +29,7 @@ spring:
     ds2:
       ## Hikari连接池的设置 Hikari 时间单位都是毫秒
       type: com.zaxxer.hikari.HikariDataSource
-      jdbc-url: jdbc:postgresql://101.200.219.190:54321/diagnosis
+      jdbc-url: jdbc:postgresql://10.72.143.2:54321/diagnosis
       username: root
       password: 123456
       driver-class-name: org.postgresql.Driver
@@ -49,6 +48,28 @@ spring:
         max-lifetime: 1800000
         ## 数据库连接超时时间,默认30秒，即30000
         connection-timeout: 30000
+    ds3:
+      ## Hikari连接池的设置 Hikari 时间单位都是毫秒
+      type: com.zaxxer.hikari.HikariDataSource
+      jdbc-url: jdbc:oracle:thin:@10.72.181.234:1521:orcl
+      username: dhzdly
+      password: gctgct#831511
+      driver-class-name: oracle.jdbc.driver.OracleDriver
+      hikari:
+        ## 连接池名字
+        pool-name: SystemHikariCP
+        ## 最小空闲连接数量
+        minimum-idle: 5
+        ## 空闲连接存活最大时间，默认600000（10分钟）
+        idle-timeout: 60000
+        ## 连接池最大连接数，默认是10
+        maximum-pool-size: 15
+        ## 此属性控制从池返回的连接的默认自动提交行为,默认值：true
+        auto-commit: true
+        ## 此属性控制池中连接的最长生命周期，值0表示无限生命周期，默认1800000即30分钟
+        max-lifetime: 1800000
+        ## 数据库连接超时时间,默认30秒，即30000
+        connection-timeout: 30000
 
 management:
   info:
@@ -60,11 +81,11 @@ management:
       enabled: true
     camelroutecontroller:
       enabled: true
-#Actuator for camel was not supported at camel version > 3.4
+  #Actuator for camel was not supported at camel version > 3.4
   endpoints:
     web:
       exposure:
-        include:  health, info,camelroutes , camelroutecontroller
+        include: health, info,camelroutes , camelroutecontroller
       cors:
         allow-credentials: off
 server:

src/test/java/com/gct/tools/etlcamelhuge/EtlCamelHugeApplicationTests.java

@@ -1,21 +1,45 @@
 package com.gct.tools.etlcamelhuge;
 
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.gct.tools.etlcamelhuge.entity.Response;
+import com.gct.tools.etlcamelhuge.routeconfig.CamelJDBCConfiguration;
+import io.micrometer.core.instrument.util.IOUtils;
 import lombok.Data;
+import org.apache.camel.AggregationStrategy;
+import org.apache.camel.CamelContext;
+import org.apache.camel.Exchange;
+import org.apache.camel.Processor;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.http.common.HttpMessage;
+import org.apache.camel.impl.DefaultCamelContext;
+import org.apache.camel.model.ModelCamelContext;
 import org.junit.jupiter.api.Test;
 import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.context.annotation.Bean;
 import org.springframework.test.context.junit4.SpringRunner;
 
+import java.io.IOException;
+import java.io.InputStream;
 import java.lang.reflect.Array;
 import java.lang.reflect.InvocationTargetException;
+import java.text.SimpleDateFormat;
 import java.util.ArrayList;
 import java.util.Arrays;
+import java.util.Date;
 import java.util.List;
 
+import static org.junit.Assert.assertEquals;
+
 @RunWith(SpringRunner.class)
 @SpringBootTest
 class EtlCamelHugeApplicationTests {
 
+    @Autowired
+    RouteBuilder routeBuilder;
+
     @Test
     public void contextLoads() {
     }
@@ -81,18 +105,19 @@ class EtlCamelHugeApplicationTests {
     }
 
     @Data
-    class te{
+    class te {
         private double m;
 
-//        @Cons
+        //        @Cons
         public te(double m) {
             this.m = m;
         }
     }
+
     @Test
     public void test3() {
 
-        te s=new te(0.9);
+        te s = new te(0.9);
         System.out.println(s);
         System.out.println(s.getClass());
         try {
@@ -113,7 +138,7 @@ class EtlCamelHugeApplicationTests {
             e.printStackTrace();
         }
 
-        ArrayList<Double> a1=new ArrayList<Double>();
+        ArrayList<Double> a1 = new ArrayList<Double>();
 
         a1.add(0.9);
         a1.add(0.8);
@@ -125,13 +150,13 @@ class EtlCamelHugeApplicationTests {
 
     }
 
-    private <T> T[][] transfer(List<List<T>> source,Class<T> tClass){
+    private <T> T[][] transfer(List<List<T>> source, Class<T> tClass) {
 
-        List<T[]> l1=new ArrayList<>();
+        List<T[]> l1 = new ArrayList<>();
         for (List<T> ts : source) {
-            T[] t=(T[]) Array.newInstance(tClass,ts.size());
+            T[] t = (T[]) Array.newInstance(tClass, ts.size());
             for (int i = 0; i < ts.size(); i++) {
-                t[i]=ts.get(i);
+                t[i] = ts.get(i);
             }
 
             l1.add(t);
@@ -141,5 +166,46 @@ class EtlCamelHugeApplicationTests {
 
     }
 
+    @Test
+    public void test10() {
+        JSONArray jsonArray = new JSONArray();
+        JSONObject search = new JSONObject();
+        JSONObject body = new JSONObject();
+        body.put("userno", "zdcycgtlyxt"); // 分配的系统用户账号
+        body.put("password", "Zdcycgtlyxt");
+        body.put("pageNo", 1); // 页码，从1开始
+        body.put("pageSize", 10);
+        search.put("field","父ID");
+        search.put("rule","=");
+        search.put("val","kvAfwAVEzv");
+        jsonArray.add(search);
+        body.put("search",jsonArray);
+        System.out.println(body);
+    }
+
+    public static void main(String args[]) throws Exception {
+        CamelContext context = new DefaultCamelContext();
+        //new ClassPathXmlApplicationContext("jetty/camel.xml");
+        context.addRoutes(new RouteBuilder() {
+            @Override
+            public void configure() {
+                JSONObject body = new JSONObject();
+                body.put("userno", "zdcycgtlyxt"); // 分配的系统用户账号
+                body.put("password", "Zdcycgtlyxt");
+                from("timer:mytimer?repeatCount=1")
+                        .setBody(simple(body.toJSONString()))
+                        .removeHeaders("CamelHttp*")
+                        .to("http://11.71.3.110:30010/dibs/0/service/token")
+                        .log("${body}:");
+            }
+        });
+        context.start();
+        boolean loop = true;
+        while (loop) {
+            Thread.sleep(25000);
+        }
+        context.stop();
+    }
+
 
 }