文档首页/ 应用平台 AppStage/ 开发指南/ 使用Spring Cloud框架实现应用开发/ 开发指导/ 构建Spring Cloud工程

更新时间：2024-03-07 GMT+08:00

构建Spring Cloud工程

创建父工程

创建Maven工程。

图1 创建Maven工程

父pom添加依赖。

<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-dependencies</artifactId>
            <version>2.2.8.RELEASE</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>

创建子工程ServiceA

创建Maven工程。

图2 创建Maven工程
新建src目录。

图3 新建src目录

编写业务代码。

图4 业务代码文件

编写启动类

package com.huawei.demo.servicea;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

/**
 * 启动类
 *
 * @author XXX
 * @since 2023-12-05
 */
@SpringBootApplication
@EnableEurekaClient
public class ServiceASpringbootApplication {
    public static void main(String[] args) {
        SpringApplication.run(ServiceASpringbootApplication.class, args);
    }
}

编写Controller类

package com.huawei.demo.servicea.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import com.huawei.demo.servicea.pojo.UserInfo;
import com.huawei.demo.servicea.service.UserService;

/**
 * 用户对外接口
 *
 * @author XXX
 * @since 2023-12-06
 */
@RestController
@RequestMapping("/user")
public class UserController {
    @Autowired
    private UserService userService;

    @GetMapping("/{userId}")
    public UserInfo getUserByName(@PathVariable String userId) {
        return userService.getUserById(userId);
    }
}

编写Mapper类

package com.huawei.demo.servicea.mapper;

import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Select;

import com.huawei.demo.servicea.pojo.UserInfo;

/**
 * 用户查询
 *
 * @author XXX
 * @since 2023-12-06
 */
@Mapper
public interface UserMapper {
    @Select("select * from demo_user_info where user_id = #{userId}")
    UserInfo getUserById(String userId);
}

编写Pojo类

package com.huawei.demo.servicea.pojo;

import lombok.Data;

/**
 * user信息
 *
 * @author XXX
 * @since 2023-12-06
 */
@Data
public class UserInfo {
    private String userId;

    private String userName;

    private String phone;

    private String address;
}

编写Service类

package com.huawei.demo.servicea.service;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import com.huawei.demo.servicea.mapper.UserMapper;
import com.huawei.demo.servicea.pojo.UserInfo;

/**
 * userService
 *
 * @author XXX
 * @since 2023-12-06
 */
@Service
public class UserService {
    @Autowired
    private UserMapper userMapper;

    public UserInfo getUserById(String userId) {
        return userMapper.getUserById(userId);
    }
}

配置微服务

server:
  port: 8081
spring:
  application:
    name: demoServiceA
  datasource:
    url: jdbc:mysql://127.0.0.1:3306/spring_cloud_demo?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai
    username: root
    password: ***
    driver-class-name: com.mysql.jdbc.Driver

mybatis:
  configuration:
    map-underscore-to-camel-case: true
  type-aliases-package: com.huawei.dmo.servicea

创建子工程ServiceB

创建Maven工程。

图5 创建Maven工程
新建src目录。

图6 新建src目录

编写业务代码。

图7 业务代码文件

编写启动类

package com.huawei.demo.serviceb;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;

/**
 * 功能描述
 *
 * @author XXX
 * @since 2023-12-05
 */
@SpringBootApplication
@EnableEurekaClient
public class ServiceBSpringbootApplication {
    public static void main(String[] args) {
        SpringApplication.run(ServiceBSpringbootApplication.class, args);
    }

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

编写Controller类

package com.huawei.demo.serviceb.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import com.huawei.demo.serviceb.pojo.OrderInfo;
import com.huawei.demo.serviceb.service.OrderService;

/**
 * 用户对外接口
 *
 * @author XXX
 * @since 2023-12-06
 */
@RestController
@RequestMapping("/order")
public class OrderController {
    @Autowired
    private OrderService orderService;

    @GetMapping("/{orderId}")
    public OrderInfo findOrder(@PathVariable String orderId) {
        return orderService.findOrder(orderId);
    }
}

编写Domain类

package com.huawei.demo.serviceb.domain;

import lombok.Data;

/**
 * user信息
 *
 * @author XXX
 * @since 2023-12-06
 */
@Data
public class UserInfo {
    private String userId;

    private String userName;

    private String phone;

    private String address;
}

编写Mapper类

package com.huawei.demo.serviceb.mapper;

import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Select;

import com.huawei.demo.serviceb.pojo.OrderInfo;

/**
 * 用户查询
 *
 * @author XXX
 * @since 2023-12-06
 */
@Mapper
public interface OrderMapper {
    @Select("select * from demo_order_info where order_id = #{orderId}")
    OrderInfo getOrderById(String orderId);
}

编写Pojo类

package com.huawei.demo.serviceb.pojo;

import com.huawei.demo.serviceb.domain.UserInfo;

import lombok.Data;

/**
 * order信息
 *
 * @author XXX
 * @since 2023-12-06
 */
@Data
public class OrderInfo {
    private String orderId;

    private String orderName;

    private String price;

    private String userId;

    private UserInfo userInfo;
}

编写Service类

package com.huawei.demo.serviceb.service;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

import com.huawei.demo.serviceb.domain.UserInfo;
import com.huawei.demo.serviceb.mapper.OrderMapper;
import com.huawei.demo.serviceb.pojo.OrderInfo;

/**
 * 功能描述
 *
 * @author XXX
 * @since 2023-12-06
 */
@Service
public class OrderService {

    @Autowired
    private RestTemplate restTemplate;

    @Autowired
    private OrderMapper orderMapper;

    public OrderInfo findOrder(String orderId) {
        OrderInfo orderInfo=orderMapper.getOrderById(orderId);
        String url = "http://demoServiceA/user/" + orderInfo.getUserId();
        UserInfo userInfo = restTemplate.getForObject(url, UserInfo.class);
        orderInfo.setUserInfo(userInfo);
        return orderInfo;
    }
}

配置微服务

server:
  port: 8082
spring:
  application:
    name: demoServiceB
  datasource:
    url: jdbc:mysql://127.0.0.1:3306/spring_cloud_demo?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai
    username: root
    password: ***
    driver-class-name: com.mysql.jdbc.Driver

eureka:
  client:
    service-url:
      defaultZone: http://localhost:11011/eureka/

mybatis:
  configuration:
    map-underscore-to-camel-case: true
  type-aliases-package: com.huawei.dmo.servicea

创建Eureka注册中心

创建Eureka微服务。

添加依赖。

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

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>

新建启动类。

图8 新建启动类

启动类中增加注解@EnableEurekaServer，标明注册中心微服务。

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

在Eureka微服务中增加配置文件。

图9 增加配置文件

配置注册中心微服务端口等。

server:
  port: 11011
spring:
  application:
    name: eureka

eureka:
  client:
    register-with-eureka: false
    fetch-registry: false

其他微服务中增加注册中心配置。

eureka:
  client:
    service-url:
      defaultZone: http://localhost:11011/eureka/

依次启动Eureka、DemoServiceA、DemoServiceB，访问http://localhost:11011/，可以看到DemoServiceA、DemoServiceB的信息。

图10 查看微服务注册信息
调用接口：http://localhost:8082/order/1。

图11 调用接口

父主题： 开发指导

上一篇：开发指导

下一篇：接入STS（ACMS）

意见反馈

文档内容是否对您有帮助？

有帮助没帮助

提供反馈

提交成功！非常感谢您的反馈，我们会继续努力做到更好！您可在我的云声建议查看反馈及问题处理状态。

系统繁忙，请稍后重试

在使用文档中是否遇到以下问题

内容与产品页面不一致

内容不易理解

缺失示例代码

步骤不可操作

搜不到想要的内容

缺少最佳实践

意见反馈（选填）

0/500

请至少选择一项反馈信息并填写问题反馈

字符长度不能超过500

直接提交取消

如您有其它疑问，您也可以通过华为云社区问答频道来与我们联系探讨

智能客服提问云社区提问

构建Spring Cloud工程

创建父工程

创建子工程ServiceA

创建子工程ServiceB

创建Eureka注册中心

相关文档

意见反馈

文档内容是否对您有帮助？

7*24

备案

专业服务

退订

建议反馈

售前咨询热线