storm集群环境执行springboot项目的方法

JeniTurtle commented 5 years ago

storm jar org.springframework.boot.loader.JarLauncher topologyName

这里把main class的路径包名换成springboot的。

l06066hb commented 5 years ago

请问下这种方式打包提交集群遇到过找不到spout和bolt的情况么

BerserkGuts commented 5 years ago

打包会报扩展实现的spout类不存在，ClassNotFoundException

JeniTurtle commented 5 years ago

@BerserkGuts 你是用maven构建的吗

这是我构建插件的配置

org.apache.maven.plugins maven-compiler-plugin ${java.version} ${java.version} UTF-8 org.apache.maven.plugins maven-jar-plugin com.jouryu.Application false /usr/hdp/2.6.4.0-91/storm/extlib/ false maven-assembly-plugin false src/main/assembly/depolyment.xml dist package single

BerserkGuts commented 5 years ago

@TomorrowCat 能给下assembly的具体配置嘛？多谢了！

JeniTurtle commented 5 years ago

@BerserkGuts `dist

zip

<includeBaseDirectory>true</includeBaseDirectory>
<fileSets>
    <fileSet>
        <directory>${project.build.directory}/lib</directory>
        <outputDirectory>lib</outputDirectory>
        <includes>
            <include>**/**</include>
        </includes>
    </fileSet>
    <fileSet>
        <directory>${project.build.directory}</directory>
        <outputDirectory>.</outputDirectory>
        <includes>
            <include>*.jar</include>
        </includes>
        <excludes>
            <exclude>*-sources.jar</exclude>
        </excludes>
    </fileSet>
    <fileSet>
        <directory>${project.build.directory}/classes</directory>
        <outputDirectory>bin</outputDirectory>
        <includes>
            <include>*.sh</include>
        </includes>
        <fileMode>0744</fileMode>
        <lineEnding>unix</lineEnding>
    </fileSet>
    <fileSet>
    <directory>${project.build.directory}/classes</directory>
        <outputDirectory>bin</outputDirectory>
        <includes>
            <include>cron/**</include>
        </includes>
        <fileMode>0744</fileMode>
        <lineEnding>unix</lineEnding>
    </fileSet>

    <fileSet>
        <directory>${project.basedir}/conf</directory>
        <outputDirectory>conf</outputDirectory>
        <includes>
            <include>**/**</include>
        </includes>
    </fileSet>

    <fileSet>
        <directory>${project.build.directory}/classes</directory>
        <outputDirectory>conf</outputDirectory>
        <includes>
            <include>*.properties</include>
            <include>*.xml</include>
            <include>*.der</include>
        </includes>
        <lineEnding>unix</lineEnding>
    </fileSet>

    <fileSet>
        <directory>${project.basedir}/config</directory>
        <outputDirectory>config</outputDirectory>
        <includes>
            <include>**/**</include>
        </includes>
    </fileSet>

    <fileSet>
        <directory>${project.build.directory}/classes</directory>
        <outputDirectory>config</outputDirectory>
        <includes>
            <include>*.properties</include>
            <include>*.xml</include>
            <include>*.der</include>
        </includes>
        <lineEnding>unix</lineEnding>
    </fileSet>

</fileSets>`

xuwujing / springBoot-study

storm集群环境执行springboot项目的方法 #8