基于docker部署的微服務架構（二）： 服務提供者和調用者

前言

前一篇 基于docker部署的微服務架構（一）：服務注冊中心 已經成功創(chuàng)建了一個服務注冊中心，現在我們創(chuàng)建一個簡單的微服務，讓這個服務在服務注冊中心注冊。然后再創(chuàng)建一個調用者，調用此前創(chuàng)建的微服務。

創(chuàng)建微服務

新建一個maven工程，修改pom.xml引入 spring cloud 依賴:

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.4.2.RELEASE</version>
</parent>

<dependencies>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-eureka</artifactId>
    </dependency>
</dependencies>

<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>Camden.SR2</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>

在 resources 目錄中創(chuàng)建 application.yml 配置文件，在配置文件內容:

spring:
  application:
    name: @project.artifactId@

server:
  port: 8100

eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8000/eureka/

這里eureka的注冊地址為上一篇中設置的defaultZone。
在 java 目錄中創(chuàng)建一個包 demo ，在包中創(chuàng)建啟動入口 AddServiceApplication.java

@EnableDiscoveryClient
@SpringBootApplication
public class AddServiceApplication {
    public static void main(String[] args) {
        SpringApplication.run(AddServiceApplication.class, args);
    }
}

在demo包下新建一個子包controller，在controller子包下創(chuàng)建一個controller對外提供接口。

@RestController
public class AddController {
    @RequestMapping(value = "/add", method = RequestMethod.GET)
    public Map<String, Object> add(Integer a, Integer b) {
        System.out.println("端口為8100的實例被調用");
        Map<String, Object> returnMap = new HashMap<>();
        returnMap.put("code", 200);
        returnMap.put("msg", "操作成功");
        returnMap.put("result", a + b);
        return returnMap;
    }
}

在服務注冊中心已經運行的情況下，運行 AddServiceApplication.java 中的 main 方法，啟動微服務。
訪問服務注冊中心頁面 http://localhost:8000， 可以看到已經成功注冊了 ADD-SERVICE-DEMO 服務。

服務注冊中心
服務注冊中心

啟動第二個實例，修改端口為 8101 ，修改 AddController.java 中的輸出信息為

System.out.println("端口為8101的實例被調用");

再次運行 AddServiceApplication.java 中的 main 方法。
訪問服務注冊中心頁面 http://localhost:8000， 可以看到已經成功注冊了兩個 ADD-SERVICE-DEMO 服務，端口分別為 8100 和 8101。

服務注冊中心2
服務注冊中心2

demo源碼 spring-cloud-1.0/add-service-demo

ribbon方式調用服務

新建一個maven工程，修改pom.xml引入 spring cloud 依賴:

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.4.2.RELEASE</version>
</parent>

<dependencies>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-ribbon</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-eureka</artifactId>
    </dependency>
</dependencies>

<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>Camden.SR2</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>

在 resources 目錄中創(chuàng)建 application.yml 配置文件，在配置文件內容:

spring:
  application:
    name: @project.artifactId@

server:
  port: 8200

eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8000/eureka/

在 java 目錄中創(chuàng)建一個包 demo ，在包中創(chuàng)建啟動入口 RibbonClientApplication.java

@EnableDiscoveryClient
@SpringBootApplication
public class RibbonClientApplication {

    public static void main(String[] args) {
        SpringApplication.run(RibbonClientApplication.class, args);
    }

    @Bean
    @LoadBalanced
    RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

這里配置了一個可以從服務注冊中心讀取服務列表，并且實現了負載均衡的 restTemplate。

在demo包下新建一個子包controller，在controller子包下創(chuàng)建一個controller對外提供接口。

@RestController
public class RibbonController {

    @Autowired
    RestTemplate restTemplate;

    @RequestMapping(value = "/add", method = RequestMethod.GET)
    public String add(Integer a, Integer b) {
        return restTemplate.getForEntity("http://ADD-SERVICE-DEMO/add?a="+a+"&b=" + b, String.class).getBody();
    }
    
}

可以看到這里的請求url用了服務注冊中心對應的 Application。

運行 RibbonClientApplication.java 中的 main 方法，啟動項目。
在瀏覽器中訪問 http://localhost:8200/add?a=1&b=2 ，得到返回結果：

{
    msg: "操作成功",
    result: 3,
    code: 200
}

多次訪問，查看 AddServiceApplication 的控制臺，可以看到兩個 ADD-SERVICE-DEMO 被負載均衡的調用。
demo源碼 spring-cloud-1.0/ribbon-client-demo

feign方式調用服務

新建一個maven工程，修改pom.xml引入 spring cloud 依賴:

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.4.2.RELEASE</version>
</parent>

<dependencies>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-feign</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-eureka</artifactId>
    </dependency>
</dependencies>

<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>Camden.SR2</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>

在 resources 目錄中創(chuàng)建 application.yml 配置文件，在配置文件內容:

spring:
  application:
    name: @project.artifactId@

server:
  port: 8300

eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8000/eureka/

在 java 目錄中創(chuàng)建一個包 demo ，在包中創(chuàng)建啟動入口 FeignClientApplication.java

@EnableDiscoveryClient
@SpringBootApplication
@EnableFeignClients
public class FeignClientApplication {

    public static void main(String[] args) {
        SpringApplication.run(FeignClientApplication.class, args);
    }

}

在demo包下新建一個子包service，在service子包下創(chuàng)建一個接口 AddService.java 調用之前創(chuàng)建的微服務 ADD-SERVICE-DEMO。

@FeignClient("ADD-SERVICE-DEMO")
public interface AddService {
    @RequestMapping(method = RequestMethod.GET, value = "/add")
    String add(@RequestParam(value = "a") Integer a, @RequestParam(value = "b") Integer b);
}

這里 @FeignClient 注解中的參數為服務注冊中心對應的 Application。

在demo包下再新建一個子包controller，在controller子包下創(chuàng)建一個 FeignController.java 對外提供接口。

@RestController
public class FeignController {

    @Autowired
    private AddService addService;

    @RequestMapping(value = "/add", method = RequestMethod.GET)
    public String add(Integer a, Integer b) {
        return addService.add(a, b);
    }

}

FeignController 里注入了剛才創(chuàng)建的 AddService 接口。

運行 FeignClientApplication.java 中的 main 方法，啟動項目。
在瀏覽器中訪問 http://localhost:8300/add?a=1&b=2 ，得到返回結果：

{
    msg: "操作成功",
    result: 3,
    code: 200
}

多次訪問，查看 AddServiceApplication 的控制臺，可以看到兩個 ADD-SERVICE-DEMO 被負載均衡的調用。
demo源碼 spring-cloud-1.0/feign-client-demo

使用docker-maven-plugin打包并生成docker鏡像

以 add-service-demo 為例，
復制 application.yml，重命名為 application-docker.yml，修改 defaultZone為：

eureka:
  client:
    serviceUrl:
      defaultZone: http://service-registry:8000/eureka/

這里修改了 defaultZone 的訪問url，如何修改取決于部署docker容器時的 --link 參數， --link 可以讓兩個容器之間互相通信。

修改 application.yml 中的 spring 節(jié)點為：

spring:
  application:
    name: @project.artifactId@
  profiles:
    active: @activatedProperties@

這里增加了 profiles 的配置，在maven打包時選擇不同的profile，加載不同的配置文件。

在pom.xml文件中增加：

<properties>
    <java.version>1.8</java.version> <!-- 指定java版本 -->
    <!-- 鏡像前綴，推送鏡像到遠程庫時需要，這里配置了一個阿里云的私有庫 -->
    <docker.image.prefix>
        registry.cn-hangzhou.aliyuncs.com/ztecs
    </docker.image.prefix>
    <!-- docker鏡像的tag -->
    <docker.tag>demo</docker.tag>

    <!-- 激活的profile -->
    <activatedProperties></activatedProperties>
</properties>

<profiles>
    <!-- docker環(huán)境 -->
    <profile>
        <id>docker</id>

        <properties>
            <activatedProperties>docker</activatedProperties>
            <docker.tag>docker-demo-${project.version}</docker.tag>
        </properties>
    </profile>
</profiles>

<build>
    <defaultGoal>install</defaultGoal>
    <finalName>${project.artifactId}</finalName>

    <resources>
        <resource>
            <directory>src/main/resources</directory>
            <filtering>true</filtering>
        </resource>
    </resources>

    <plugins>
        <!-- 配置spring boot maven插件，把項目打包成可運行的jar包 -->
        <plugin>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-maven-plugin</artifactId>
            <configuration>
                <executable>true</executable>
            </configuration>
        </plugin>

        <!-- 打包時跳過單元測試 -->
        <plugin>
            <groupId>org.apache.maven.plugins</groupId>
            <artifactId>maven-surefire-plugin</artifactId>
            <configuration>
                <skipTests>true</skipTests>
            </configuration>
        </plugin>

        <!-- 配置docker maven插件，綁定install生命周期，在運行maven install時生成docker鏡像 -->
        <plugin>
            <groupId>com.spotify</groupId>
            <artifactId>docker-maven-plugin</artifactId>
            <version>0.4.13</version>
            <executions>
                <execution>
                    <phase>install</phase>
                    <goals>
                        <goal>build</goal>
                        <goal>tag</goal>
                    </goals>
                </execution>
            </executions>
            <configuration>
                <!-- 修改這里的docker節(jié)點ip，需要打開docker節(jié)點的遠程管理端口2375，
                具體如何配置可以參照之前的docker安裝和配置的文章 -->
                <dockerHost>http://docker節(jié)點ip:2375</dockerHost>
                <imageName>${docker.image.prefix}/${project.build.finalName}</imageName>
                <baseImage>java</baseImage>
                <!-- 這里的entryPoint定義了容器啟動時的運行命令，容器啟動時運行
                java -jar 包名 , -Djava.security.egd這個配置解決tomcat8啟動時，
因為需要收集環(huán)境噪聲來生成安全隨機數導致啟動過慢的問題-->
                <entryPoint>
                    ["java", "-Djava.security.egd=file:/dev/./urandom", "-jar", "/${project.build.finalName}.jar"]
                </entryPoint>
                <resources>
                    <resource>
                        <targetPath>/</targetPath>
                        <directory>${project.build.directory}</directory>
                        <include>${project.build.finalName}.jar</include>
                    </resource>
                </resources>
                <image>${docker.image.prefix}/${project.build.finalName}</image>
                <newName>${docker.image.prefix}/${project.build.finalName}:${docker.tag}</newName>
                <forceTags>true</forceTags>
                <!-- 如果需要在生成鏡像時推送到遠程庫，pushImage設為true -->
                <pushImage>false</pushImage>
            </configuration>
        </plugin>
    </plugins>
</build>

選擇 docker profile，運行 mvn install -P docker ，打包項目并生成docker鏡像，注意docker-maven-plugin中的 <entryPoint> 標簽里的內容不能換行，否則在生成docker鏡像的時候會報錯。
運行成功后，登錄docker節(jié)點，運行 docker images 應該可以看到剛才打包生成的鏡像了。

啟動docker容器并注冊服務

在前一篇中，已經創(chuàng)建了一個 service-registry-demo 的docker鏡像，這里先把這個鏡像運行起來。

docker run -d --name service-registry-demo --publish 8000:8000 \
 --volume /etc/localtime:/etc/localtime \
 registry.cn-hangzhou.aliyuncs.com/ztecs/service-registry-demo:docker-demo-1.0

對這條命令做個簡單說明， -d 指定當前容器運行在后臺， --name 指定容器名稱， --publish 指定端口映射到宿主機， --volume 這個掛載是為了解決容器內的時區(qū)和宿主機不一致的問題，讓容器使用宿主機設置的時區(qū)，最后指定使用的docker鏡像，鏡像名稱和標簽需要根據自己的情況做修改。
運行這條命令之后，service-registry-demo 的容器就啟動了。訪問 http://宿主機IP:8000，打開注冊中心的頁面。
下邊啟動 add-service-demo 容器，

docker run -d --name add-service-demo --link service-registry-demo:service-registry --publish 8100:8100 \
 --volume /etc/localtime:/etc/localtime \
 registry.cn-hangzhou.aliyuncs.com/ztecs/add-service-demo:docker-demo-1.0

這條命令和上一條差不多，只是增加了一個 --link 參數，--link 指定容器間的連接，命令格式 --link 容器名:別名，這里連接了之前創(chuàng)建的名為 service-registry-demo 的容器，這里的別名和 application-docker.yml 文件中配置的 defaultZone 一致。其實就是通過別名找到了對應的容器IP，進到容器里查看 hosts 文件就明白了，其實就是加了條hosts映射。
add-service-demo 容器啟動成功之后，刷新配置中心的頁面，發(fā)現已經注冊到配置中心了。

最后編輯于 ：
?著作權歸作者所有,轉載或內容合作請聯系作者
【社區(qū)內容提示】社區(qū)部分內容疑似由AI輔助生成，瀏覽時請結合常識與多方信息審慎甄別。
平臺聲明：文章內容（如有圖片或視頻亦包括在內）由作者上傳并發(fā)布，文章內容僅代表作者本人觀點，簡書系信息發(fā)布平臺，僅提供信息存儲服務。

相關閱讀更多精彩內容

友情鏈接更多精彩內容