摘要:在这里,这个提供了一个风格的接口访问。准备刚刚我们已经成功地在中运行了我们的微服务。对外暴露的端口需要跟服务的端口是一致的。运行是发布一个容器的端口到运行的主机上。
tags: Microservice Restful Docker
Author: Andy Ai
Weibo: NinetyH
GitHub: https://github.com/aiyanbo/do...
实现构思
使用 Maven 进行项目构建
使用 Jersey 实现一个 RESTful 风格的微服务
在 Docker 里面执行 mvn package 对项目打包
在 Docker 容器里运行这个微服务
实现一个 RESTful 风格的微服务如果你对 RESTful 风格的 API 设计有疑惑,可以参考我的文章 RESTful Best Practices。
场景 & 需求在 Maven 仓库里面有许多的组件,我们现在暂且称之为 Stack。在我们模拟的系统里面有下面2个需求:
列出仓库里的所有 Stack
根据 Stack 的 ID 找到某一个组件,如果没有找到则返回 Not Found
现在,我们就根据这个需求一起踏入 Jersey 打造微服务的奇幻之旅。
Step0. 准备使用 mvn 命令创建一个简单工程
mvn archetype:generate -DgroupId=org.jmotor -DartifactId=docker-restful-demo -DinteractiveMode=false
在 pom.xml 加入 Jersey 等依赖
Step1. 构建 ModelUTF-8 UTF-8 4.12 2.18 3.1.0 junit junit ${junit.version} test org.glassfish.jersey.containers jersey-container-grizzly2-http ${jersey.version} org.glassfish.jersey.media jersey-media-json-jackson ${jersey.version}
Stack 包含了以下几个属性: id, groupId, artifactId, version。同时,Stack 类里面包含了一个 Builder 用来比较方便地创建一个 Stack 对象。这些都可以使用 IDE 自动生成,无需手动编写。
package org.jmotor.model; /** * Component: * Description: * Date: 2015/6/18 * * @author Andy Ai */ public class Stack { private Integer id; private String groupId; private String artifactId; private String version; ...getter and setter... public static class Builder { private Integer id; private String groupId; private String artifactId; private String version; public Builder id(Integer id) { this.id = id; return this; } ... public Stack build() { Stack stack = new Stack(); stack.setId(id); ... return stack; } public static Builder newBuilder() { return new Builder(); } } }Step2 创建一个 Restlet
刚刚我们已经把 Model 做好了,现在我们就开始使用 Jersey 实现一个 Service,在 JAX-RS 中这样的一个服务称为 Resource。在这里,这个 Service(Resource) 提供了一个 RESTful 风格的接口访问。所以我们称之为 restlet。restlet 在 JAX-RS 或 Jersey 中并没有这个概念,这是我们附加上去的用法。
import javax.ws.rs.Path; @Path("/v1/stacks") public class StacksRestlet {}
我们需要使用 javax.ws.rs.Path 这个注解来申明 Restlet 的根路径是什么。在上面的代码中, Restlet 的跟路径是 /v1/stacks。
Step3. 实现服务接口在 Jersey 里实现一个服务接口非常简单,你只需要创建一个 public 的方法就可以了。
接口1:
@GET @Produces("application/json") public Liststacks() { return Arrays.asList( Stack.Builder.newBuilder().id(1).groupId("javax.servlet").artifactId("javax.servlet-api").version("3.1.0").build(), Stack.Builder.newBuilder().id(2).groupId("com.google.guava").artifactId("guava").version("18.0").build() ); }
我们使用 javax.ws.rs.GET 这个注解来申明接口接受的是 HTTP 请求的 GET 方法。javax.ws.rs.Produces("application/json") 用来表示我们这个接口返回的是 application/json 类型的数据。
接口2:
@GET @Path("{id}") @Produces("application/json") public Stack filterByArtifactId(@NotNull @PathParam("id") Integer id) { switch (id) { case 1: return Stack.Builder.newBuilder().id(1).groupId("javax.servlet").artifactId("javax.servlet-api").version("3.1.0").build(); case 2: return Stack.Builder.newBuilder().id(2).groupId("com.google.guava").artifactId("guava").version("18.0").build(); default: throw new WebApplicationException("Stack not found, id: " + id, 404); } }
在上面的示例中:
@Path("{id}") 表示 id 是一个 url 上的动态参数,因为 id 是变化的,所以我们要做成一个 url 变量。然后在方法里面使用 @PathParam("id") 来获得这个参数。JAX-RS 可以有许多类型的参数,例如:QueryParam 用来获取 url 问号? 后面的查询参数。你可以在 javax.ws.rs 这个包中找到其他的参数!
使用 WebApplicationException 抛一个任何状态的异常,例如: 404 或 500。
Step4. 运行微服务这里,我们使用 Jersey 的内置的 Grizzly 容器运行。
final URI uri = UriBuilder.fromUri("http://localhost/").port(9998).build(); final ResourceConfig config = new ResourceConfig(); config.packages("org.jmotor.restlet"); final HttpServer server = GrizzlyHttpServerFactory.createHttpServer(uri, config); Runtime.getRuntime().addShutdownHook(new Thread() { @Override public void run() { server.shutdown(); } }); try { server.start(); } catch (IOException e) { e.printStackTrace(); System.exit(1); }Step5. 测试
获取 Stacks 列表
$ curl http://localhost:9998/v1/stacks [{"id":1,"groupId":"javax.servlet","artifactId":"javax.servlet-api","version":"3.1.0"},{"id":2,"groupId":"com.google.gua va","artifactId":"guava","version":"18.0"}]
根据 ID 获取 Stack
$ curl http://localhost:9998/v1/stacks/1 {"id":1,"groupId":"javax.servlet","artifactId":"javax.servlet-api","version":"3.1.0"}
找不到的 Stack
$ curl -I http://localhost:9998/v1/stacks/5 HTTP/1.1 404 Not Found Content-Length: 0 Date: Tue, 23 Jun 2015 06:04:19 GMT在 Docker 中运行
首先,我们需要安装一个 Docker 环境,你可以从 Docker Docs 上找到如何安装它。
安装完成后,我们需要把我们的微服务打包成一个 Docker Image。下面,我们就使用 Dockerfile 来构建我们的 Docker Image。
Step0. 准备刚刚我们已经成功地在 IDE 中运行了我们的微服务。但是如果需要让它能独立运行,我们需要把我们的工程通过 mvn 做成一个可以运行的包。但是因为我们在 Docker 中运行,所以我们只需要把相关的依赖复制到一个特地的地方就可以了。在下面的代码中,我们把依赖放到了 ${project.build.directory}/lib 下。
在 pom.xml 加入下面的代码:
Step1. Dockerfileorg.apache.maven.plugins maven-dependency-plugin copy-dependencies package copy-dependencies provided ${project.build.directory}/lib org.apache.maven.plugins maven-compiler-plugin 1.7
FROM jamesdbloom/docker-java8-maven MAINTAINER Andy Ai "yanbo.ai@gmail.com" WORKDIR /code ADD pom.xml /code/pom.xml ADD src /code/src ADD settings.xml /root/.m2/settings.xml RUN ["mvn", "package"] CMD ["java", "-cp", "target/lib/*:target/docker-restful-demo-1.0-SNAPSHOT.jar", "org.jmotor.StackMicroServices"] EXPOSE 9998
Tips
ADD settings.xml /root/.m2/settings.xml,这是加入了本地的 maven settings。在这个文件里面你可能会使用到一些特定的配置,例如:maven 仓库的代理镜像。代理镜像可以加快你的 Docker Build。
EXPOSE 9998 Docker 对外暴露的端口需要跟服务的端口是一致的。
Step2. Build Imagecd docker-restful-demo docker build -t docker-restful-demo .
上面代码中,-t 是在 Docker Build 的时候指定 Image Tag。
Step3. 运行 Imagedocker run -d -p 9998:9998 docker-restful-demo
Step4. Docker 容器测试Tips
-p 是发布一个 Docker 容器的端口到 Docker 运行的主机上。
检查 Docker 容器是否在运行
$ docker ps CONTAINER ID IMAGE COMMAND CREATED STATUS PORTS NAMES bdda2408484a docker-restful-demo:latest "java -cp target/lib 31 seconds ago Up 29 seconds 0.0.0.0:9 998->9998/tcp fervent_swartz
检查 Docker 容器内的服务是否已经启动:
登录到 Docker 容器:
docker exec -i -t bdda2408484a bash
查看服务端口信息
$ ss -a Netid State Recv-Q Send-Q Local Address:Port Peer Address:Port nl UNCONN 0 0 rtnl:kernel * nl UNCONN 4352 0 tcpdiag:ss/92 * nl UNCONN 768 0 tcpdiag:kernel * nl UNCONN 0 0 6:kernel * nl UNCONN 0 0 10:kernel * nl UNCONN 0 0 12:kernel * nl UNCONN 0 0 15:kernel * nl UNCONN 0 0 16:kernel * u_str ESTAB 0 0 * 9590 * 0 tcp LISTEN 0 128 ::ffff:127.0.0.1:9998 :::*
测试接口
$ curl -i http://localhost:9998/v1/stacks HTTP/1.1 200 OK Content-Type: application/json Date: Tue, 23 Jun 2015 07:51:15 GMT Content-Length: 163 [{"id":1,"groupId":"javax.servlet","artifactId":"javax.servlet-api","version":"3.1.0"},{"id":2,"groupId":"com.google.gua va","artifactId":"guava","version":"18.0"}]
退出 Docker 容器
exitStep5. 远程调用测试
如果你使用的是 boot2docker, 需要拿到 boot2docker 虚拟机的IP
$ boot2docker ip 192.168.59.103
调用远程接口
$ curl http://192.168.59.103:9998/v1/stacks curl: (7) Failed to connect to 192.168.59.103 port 9998: Connection refused
如果遇到上面的错误,我们可以通过2种方式去解决它:
方法1: 将程序绑定全零IP的端口
检查 Docker 容器绑定的端口:
$ docker port bdda2408484a 9998/tcp -> 0.0.0.0:9998
我们看到的是 9998 这个端口绑定在 0.0.0.0 上,这时需要把 Jersey 容器的 URI 改成 0.0.0.0 就可以,像这样:
final URI uri = UriBuilder.fromUri("http://localhost/").port(9998).build(); ---> final URI uri = UriBuilder.fromUri("http://0.0.0.0/").port(9998).build();
方法2: 将程序绑定到非回路的IP端口上
查看 Docker 容器 IP 地址的方法:
boot2docker ssh docker inspect --format "{{.NetworkSettings.IPAddress}}" $container_id
使用 Java 接口获取本机的非回路IP地址:
final URI uri = UriBuilder.fromUri("http://localhost/").port(9998).build(); ---> InetAddress inetAddress = localInet4Address(); String host = "0.0.0.0"; if (inetAddress != null) { host = inetAddress.getHostAddress(); } final URI uri = UriBuilder.fromUri("http://" + host + "/").port(9998).build(); private static InetAddress localInet4Address() throws SocketException { EnumerationnetworkInterfaces = NetworkInterface.getNetworkInterfaces(); while (networkInterfaces.hasMoreElements()) { NetworkInterface networkInterface = networkInterfaces.nextElement(); Enumeration inetAddresses = networkInterface.getInetAddresses(); while (inetAddresses.hasMoreElements()) { InetAddress inetAddress = inetAddresses.nextElement(); if (!inetAddress.isLoopbackAddress() && inetAddress instanceof Inet4Address) { return inetAddress; } } } return null; }
使用上面的任何一种方法,服务都能正常调用:
$ curl -i http://192.168.59.103:9998/v1/stacks HTTP/1.1 200 OK Content-Type: application/json Date: Tue, 23 Jun 2015 07:53:24 GMT Content-Length: 163 [{"id":1,"groupId":"javax.servlet","artifactId":"javax.servlet-api","version":"3.1.0"},{"id":2,"groupId":"com.google.gua va","artifactId":"guava","version":"18.0"}]加速器
在撰写此文的时候,我使用的是 DaoColud 的镜像在做加速。 具体步骤请查看 DaoColud Mirror 文档。
如果你在 Windows 上使用 Boot2Docker, 可以按照下列步骤设置你的 Docker 镜像仓库:
boot2docker ssh sudo su echo "EXTRA_ARGS="--registry-mirror=http://98bc3dca.m.daocloud.io"" >> /var/lib/boot2docker/profile exit boot2docker restart
参考资料
https://dashboard.daocloud.io...
http://martinfowler.com/artic...
https://jersey.java.net/docum...
https://blog.giantswarm.io/ge...
未经同意不可转载, 转载需保留原文链接与作者署名。
文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。
转载请注明本文地址:https://www.ucloud.cn/yun/26422.html
摘要:运行在上的微服务服务发现与注册在上一节中,我们学习了如何在上构建一个风格的微服务。接下来,我们将学习如何把运行在上的微服务暴露在服务中心上,以便客户端的调用。资源服务在关闭时需要将服务实例在服务中心进行注销操作。响应用户的终止。 运行在 Docker 上的微服务 - 服务发现与注册 tags: Docker Microservice RESTful etcd Author: And...
摘要:微服务架构模式使得每个微服务独立部署,且每个服务独立扩展,开发者不再需要协调其它服务部署对本服务的影响。微服务架构模式使得持续化部署成为可能。所以使用微服务不是必须的,而是在适当的实际,架构适应应用场景的一种改变。 近段时间离职,跟同事们讲解我之前所做的微服务相关产品,对于同事们提出的问题,做了如下整理出来,加上自己的理解,分享出来跟大家一起探讨下: 问题预览 我为什么要换微服务?能...
摘要:此刻的后手指依旧飞速地敲打键盘,丝毫没有要停不下来意思。阅读本期技术周刊,你不光能弄明白什么是,使用的意义何在,还将被传授秘籍,以达的境界。周刊筛选的每篇内容,是作者的独到见解,踩坑总结和经验分享。 showImg(https://segmentfault.com/img/bVC5qJ?w=900&h=385); 啪嗒啪嗒,啪嗒啪嗒,听到后排动感十足的清脆键盘响,我就能猜到公司程序员定...
摘要:纳尼隔壁少林派表示自家金刚技压群雄在座各位都是。。。纳尼你觉得写太繁琐了你不喜欢我们还有或者等等一大堆工具呢。纳尼没有你还是觉得无法接受好吧那么笔者推荐类似这类更友好的工具你可以导入导出其他格式也可以使用其来撰写。 说起微服务, 想必现在的技术圈内人士个个都能谈笑风云, 娓娓道来。的确, 技术变革日新月异, 各种工具框架雨后春笋般涌现, 现在我们可以轻巧便捷地根据自己的业务需求, 构建...
摘要:是一个相对比较新的微服务框架,年才推出的版本虽然时间最短但是相比等框架提供的全套的分布式系统解决方案。提供线程池不同的服务走不同的线程池,实现了不同服务调用的隔离,避免了服务器雪崩的问题。通过互相注册的方式来进行消息同步和保证高可用。 Spring Cloud 是一个相对比较新的微服务框架,...
阅读 3469·2021-11-18 10:07
阅读 1540·2021-11-04 16:08
阅读 1481·2021-11-02 14:43
阅读 1067·2021-10-09 09:59
阅读 815·2021-09-08 10:43
阅读 1019·2021-09-07 09:59
阅读 933·2019-12-27 11:56
阅读 925·2019-08-30 15:56