1.使用 maven 生成项目
mvn archetype:generate -DgroupId=com.packt.samples -DartifactId=kafka_server -Dversion=1.0.0 -DinteractiveMode=false -DarchetypeCatalog=internal
2.编辑pom 文件
<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/maven-v4_0_0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.packt.samples</groupId>
<artifactId>kafka_server</artifactId>
<packaging>jar</packaging>
<version>1.0.0</version>
<name>kafka_server</name>
<url>http://maven.apache.org</url>
<dependencies>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>3.8.1</version>
<scope>test</scope>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-assembly-plugin</artifactId>
<version>2.4</version>
<configuration>
<descriptorRefs>
<descriptorRef>jar-with-dependencies</descriptorRef>
</descriptorRefs>
<archive>
<manifest>
<addClasspath>true</addClasspath>
<mainClass>com.packt.samples.App</mainClass>
</manifest>
</archive>
</configuration>
<executions>
<execution>
<id>assemble-all</id>
<phase>package</phase>
<goals>
<goal>single</goal>
</goals>
</execution>
</executions>
</plugin>
</plugins>
</build>
</project>
3.编辑代码
[root@localhost kafka_server]# cat src/main/java/com/packt/samples/App.java
package com.packt.samples;
public class App
{
public static void main( String[] args )
{
final KafkaServerStartable kafka_server = new KafkaServerStartable();
Runtime.getRuntime().addShutdownHook(new Thread("kafka-shutdown-hook") {
@Override
public void run() {
kafka_server.shutdown();
}
});
kafka_server.startup();
kafka_server.awaitShutdown();
}
}
[root@localhost kafka_server]# cat src/main/java/com/packt/samples/KafkaServerStartable.java
package com.packt.samples;
public class KafkaServerStartable {
private KafkaServer server;
public KafkaServerStartable() {
server = new KafkaServer();
}
public void startup() {
server.startup();
}
public void awaitShutdown() {
server.awaitShutdown();
}
public void shutdown() {
try {
server.shutdown();
} catch(Exception e) {
System.out.println(e);
System.exit(1);
}
}
}
[root@localhost kafka_server]# cat src/main/java/com/packt/samples/KafkaServer.java
package com.packt.samples;
import java.util.concurrent.CountDownLatch;
public class KafkaServer {
public CountDownLatch shutdownLatch;
public KafkaServer() {
}
public void startup() {
shutdownLatch = new CountDownLatch(1);
}
public void awaitShutdown() {
try {
shutdownLatch.await();
} catch(InterruptedException e) {
System.err.println(e);
}
}
public void shutdown() {
shutdownLatch.countDown();
}
}
4.编译
mvn clean package -DskipTests
5.测试
java -jar target/kafka_server-1.0.0-jar-with-dependencies.jar
