springcloud微服务之间相互调用实战

深碍√TFBOYSˉ_ 2023-06-10 13:21 167阅读 0赞

任务一实现：
使用脚手架生成deepexi-spring-cloud(服务消费者)、deepeximessage-spring-cloud(服务提供者)
registerCenter(注册中心，这个没用脚手架生成)

一 服务消费者，实现用户管理的CRUD，然后在添加用户时调用deepeximessage-spring-cloud发送一条欢迎信息。脚手架好像没有发现有生成快速生成xml、mapper、entity的方法，
所以使用mybatis generator根据数据库表快速生成相应文件,需要根据实际情况修改内容.

  1. 表结构：create table user(
  2. uid  int primary key auto_increment,
  3. uname varchar(200) comment '姓名',
  4. pwd varchar(50)  comment '密码',
  5. addr varchar(100) comment '详细地址'
  6. )

1 com.deepexi.domain.entity包下的User实体类：

  1. package com.deepexi.domain.entity;
  2. import lombok.Data;
  3. @Data
  4. public class User {
  5.     private Integer uid;
  6.     private String uname;
  7.     private String pwd;
  8.     private String addr;
  9. }

2 com.deepexi.mapper包下的mapper接口：

  1. package com.deepexi.mapper;
  3. import com.deepexi.domain.entity.User;
  4. import com.deepexi.domain.query.UserQuery;
  5. import org.apache.ibatis.annotations.Mapper;
  6. import org.apache.ibatis.annotations.Param;
  8. import java.util.List;
  9. @Mapper
  10. public interface UserMapper {
  11.     /**
  12.      * @description :通过id删除用户
  13.      * @param uid :
  14.      * @return :int
  15.      */
  16.     int deleteByPrimaryKey(@Param(value="uid") String uid);
  18.     /**
  19.      * @description :插入用户
  20.      * @param user :
  21.      * @return :int
  22.      */
  23.     int insert(User user);
  25.     /**
  26.      * @description :条件查询
  27.      * @param userQuery :
  28.      * @return :java.util.List<com.deepexi.domain.entity.User>
  29.      */
  30.     List<User> selectByUser(UserQuery userQuery);
  32.     /**
  33.      * @description :修改用户
  34.      * @param user :
  35.      * @return :int
  36.      */
  37.     int update(User user);
  39. }

3.下面是com.deepexi.service业务层接口UserService(对于里面的UserQuery类是用于查询的实体类对象，继承PaginationRequest，添加分页参数)

  1. package com.deepexi.service;
  3. import com.deepexi.domain.entity.User;
  4. import com.deepexi.domain.query.UserQuery;
  5. import java.util.List;
  7. public interface UserService {
  8.     int deleteByPrimaryKey(String uid);
  9.     int insert(User user);
  10.     List<User> selectUser(UserQuery userQuery);
  11.     int update(User user);
  12. }

4 com.deepexi.domain.query下的UserQuery实体类：

  1. package com.deepexi.domain.query;
  2. import lombok.Data;
  4. @Data
  5. public class UserQuery extends PaginationRequest {
  6.     private String uname;
  7.     private String pwd;
  8.     private String addr;
  9. }

5 接着是com.deepexi.service.impl业务层接口UserService的实现类UserServiceImpl：

  1. package com.deepexi.service.impl;
  3. import com.deepexi.domain.entity.User;
  4. import com.deepexi.domain.query.UserQuery;
  5. import com.deepexi.mapper.UserMapper;
  6. import com.deepexi.service.UserService;
  7. import org.springframework.beans.factory.annotation.Autowired;
  8. import org.springframework.stereotype.Service;
  9. import java.util.List;
  11. @Service
  12. public class UserServiceImpl implements UserService {
  14.     @Autowired(required = false)
  15.     private UserMapper userMapper;
  16.     @Override
  17.     public int deleteByPrimaryKey(String uid) {
  18.         return userMapper.deleteByPrimaryKey(uid);
  19.     }
  21.     @Override
  22.     public int insert(User user) {
  23.         return userMapper.insert(user);
  24.     }
  26.     @Override
  27.     public List<User> selectUser(UserQuery userQuery) {
  28.         return userMapper.selectByUser(userQuery);
  29.     }
  31.     @Override
  32.     public int update(User user) {
  33.         return userMapper.update(user);
  34.     }
  35. }

6下面是控制层代码com.deepexi.controller下的UserController:(类中使用了ResultVo返回请求内容，内容使用StatusEnum填充)：

  1. package com.deepexi.controller;
  3. import com.alibaba.fastjson.JSONObject;
  4. import com.deepexi.domain.entity.User;
  5. import com.deepexi.domain.query.UserQuery;
  6. import com.deepexi.domain.vo.ResultVo;
  7. import com.deepexi.enums.StatusEnum;
  8. import com.deepexi.remote.MessageRemote;
  9. import com.deepexi.service.UserService;
  10. import io.swagger.annotations.Api;
  11. import io.swagger.annotations.ApiOperation;
  12. import org.slf4j.Logger;
  13. import org.slf4j.LoggerFactory;
  14. import org.springframework.beans.factory.annotation.Autowired;
  15. import org.springframework.http.ResponseEntity;
  16. import org.springframework.web.bind.annotation.*;
  18. import java.util.List;
  20. @RestController
  21. @Api(value= "用户管理")
  22. public class UserController {
  23.     private final Logger log= LoggerFactory.getLogger(UserController.class);
  24.     @Autowired
  25.     private UserService userService;
  26.     @Autowired
  27.     MessageRemote messageRemote;
  29.     @PostMapping(value= "/login")
  30.     @ApiOperation(value= "用户登录",notes= "条件查询是否存在用户")
  31.     public ResponseEntity login(@RequestBody UserQuery userQuery){
  32.         List<User>  list= null;
  33.         try {
  34.             log.info("request to login: {}",JSONObject.toJSON(userQuery));
  35.             userQuery.setIndex(userQuery.getOffset());
  36.             userQuery.setSize(userQuery.getLimit());
  37.             list = userService.selectUser(userQuery);
  38.         } catch (Exception e) {
  39.             log.info("用户查询失败");
  40.             return ResponseEntity.ok().body(ResultVo.getInstance(StatusEnum.FAIL));
  41.         }
  42.         return ResponseEntity.ok().body(list);
  43.     }
  45.     @PostMapping(value= "/updateUser")
  46.     @ApiOperation(value= "修改用户",notes ="修改用户信息，包括修改密码")
  47.     public ResponseEntity  updateUser(@RequestBody  User user){
  48.         try {
  49.             log.info("request to update user info:{}", JSONObject.toJSON(user));
  50.             userService.update(user);
  51.         } catch (Exception e) {
  52.             log.info("修改用户信息错误");
  53.             return ResponseEntity.ok().body(ResultVo.getInstance(StatusEnum.UPDATEFAIL));
  54.         }
  55.         return ResponseEntity.ok().body(ResultVo.getInstance(StatusEnum.SUCCESS));
  56.     }
  58.     @PostMapping(value="/addUser")
  59.     @ApiOperation(value="添加用户",notes = "添加用户信息")
  60.     public ResponseEntity addUser(@RequestBody User user){
  61.         //调用远程服务，返回欢迎信息
  62.         String msg=messageRemote.registerInfo();
  63.         try {
  64.             log.info("request to add user info: {}", JSONObject.toJSON(user));
  65.             userService.insert(user);
  66.         } catch (Exception e) {
  67.             log.info("添加用户失败");
  68.             return ResponseEntity.ok().body(ResultVo.getInstance(StatusEnum.ADDFAIL));
  69.         }
  70.         return ResponseEntity.ok().body(msg);
  71.     }
  73.     @PostMapping(value="/deleteUser")
  74.     @ApiOperation(value="删除用户",notes = "根据uid删除用户")
  75.     public  ResponseEntity deleteUser(@RequestParam("uid") String uid){
  76.         try {
  77.             log.info("request to delete user info:{}", uid);
  78.             userService.deleteByPrimaryKey(uid);
  79.         } catch (Exception e) {
  80.             log.info("删除用户失败");
  81.             return ResponseEntity.ok().body(ResultVo.getInstance(StatusEnum.DALETEFAIL));
  82.         }
  83.         return ResponseEntity.ok().body(ResultVo.getInstance(StatusEnum.SUCCESS));
  84.     }
  86. }

7 ResultVo代码如下:用于控制层返回对象

  1. package com.deepexi.domain.vo;
  3. import com.deepexi.enums.StatusEnum;
  4. import lombok.Data;
  6. @Data
  7. public class ResultVo{
  8.     private String code;
  10.     private String msg;
  12.     public static ResultVo getInstance(StatusEnum statusEnum){
  13.         ResultVo resultVo=new ResultVo();
  14.         resultVo.setCode(statusEnum.getCode());
  15.         resultVo.setMsg(statusEnum.getMsg());
  16.         return resultVo;
  17.     }
  18. }

8 StatusEnum代码如下：定义返回状态内容

  1. package com.deepexi.enums;
  4. public enum StatusEnum {
  5.     SUCCESS("200","请求成功"),
  6.     FAIL("400","请求失败"),
  7.     UPDATEFAIL("400","修改失败"),
  8.     DALETEFAIL("400","删除失败"),
  9.     ADDFAIL("400","添加失败");
  10.     private String code;
  11.     private String msg;
  13.     StatusEnum(String code, String msg) {
  14.         this.code = code;
  15.         this.msg = msg;
  16.     }
  18.     public String getCode() {
  19.         return code;
  20.     }
  22.     public void setCode(String code) {
  23.         this.code = code;
  24.     }
  26.     public String getMsg() {
  27.         return msg;
  28.     }
  30.     public void setMsg(String msg) {
  31.         this.msg = msg;
  32.     }
  33. }

9 远程服务调用：在com.deepexi.remote下创建MessageRemote：

  1. package com.deepexi.remote;
  3. import org.springframework.cloud.openfeign.FeignClient;
  4. import org.springframework.web.bind.annotation.RequestMapping;
  5. import org.springframework.web.bind.annotation.RequestMethod;
  7. @FeignClient(name="deepeximessage-spring-cloud")
  8. public interface MessageRemote {
  9.     @RequestMapping(value="/alertInfo",method = RequestMethod.POST)
  10.      String registerInfo();
  11. }

10 启动类：添加@EnableDiscoveryClient服务注册，@EnableFeignClients开启feign调用：

  1. package com.deepexi;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
  6. import org.springframework.cloud.openfeign.EnableFeignClients;
  8. @SpringBootApplication
  9. @EnableDiscoveryClient
  10. @EnableFeignClients
  11. public class StartupApplication {
  12.     public static void main(String[] args) {
  13.         SpringApplication.run(StartupApplication.class, args);
  14.     }
  15. }

11 配置文件： 指定应用名称，注册中心地址

  1. spring:
  2.   application:
  3.     name: deepexi-spring-cloud
  4.   profiles:
  5.     active: local
  6.   datasource:
  7.     driver-class-name: com.mysql.jdbc.Driver
  8.     druid:
  9.       web-stat-filter:
  10.         enabled: true
  11.       stat-view-servlet:
  12.         enabled: true
  13.         login-username: root
  14.         login-password: root
  15.   thymeleaf:
  16.     cache: false
  17.   redis:
  18.     timeout: 1000
  19. swagger:
  20.   base-package: com.deepexi.controller
  21.   info:
  22.     title: deepexi-spring-cloud
  23. server:
  24.   error:
  25.     include-stacktrace: always
  26.     include-exception: true
  27. logging:
  28.   file: 'logs/${spring.application.name}.log'
  29. management:
  30.   server:
  31.     port: 8081
  32. eureka:
  33.   client:
  34.     service-url:
  35.       defaultZone: http://127.0.0.1:8761/eureka/
  36. mybatis:
  37.   mapper-locations: 'classpath:mapper/*.xml'
  38. feign:
  39.   hystrix:
  40.     enabled: true
  41. shiro:
  42.   web:
  43.     mode: stateless
  44.     filter-chain-definition:
  45.       authc:
  46.         - /v1/**
  47.       anon:
  48.         - /**
  52. spring:
  53.   datasource:
  54.     driver-class-name: com.mysql.jdbc.Driver
  55.     username: root
  56.     password: root
  57.     url: jdbc:mysql://localhost:3306/test?serverTimezone=UTC
  58. logging:
  59.   level:
  60.     com.deepexi.mapper: debug
  61. server:
  62.   port: 8060

12 映射文件resoures/mapper下的UserMapper.xml:

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  3. <mapper namespace="com.deepexi.mapper.UserMapper">
  4.   <resultMap id="BaseResultMap" type="com.deepexi.domain.entity.User">
  5.     <id column="uid" jdbcType="INTEGER" property="uid" />
  6.     <result column="uname" jdbcType="VARCHAR" property="uname" />
  7.     <result column="pwd" jdbcType="VARCHAR" property="pwd" />
  8.     <result column="addr" jdbcType="VARCHAR" property="addr" />
  9.   </resultMap>
  10.   <sql id="Base_Column_List">
  11.     uid, uname, pwd, addr
  12.   </sql>
  13.   <!-- 分页条件的拼接  -->
  14.   <sql id="pageSql">
  15.     <if test="index != null and size != null">
  16.       limit ${index},${size}
  17.     </if>
  18.   </sql>
  20.   <select id="selectByUser" parameterType="com.deepexi.domain.entity.User" resultMap="BaseResultMap">
  21.     select 
  22.     <include refid="Base_Column_List" />
  23.     from user
  24.     <where>
  25.         <if test=" uname != null and uname != '' ">
  26.          and  uname=#{uname,jdbcType=VARCHAR}
  27.         </if>
  28.         <if test=" pwd != null and pwd != '' ">
  29.          and  pwd=#{pwd,jdbcType=VARCHAR}
  30.       </if>
  31.       <if test=" addr != null and addr != '' ">
  32.         and  addr=#{addr,jdbcType=VARCHAR}
  33.       </if>
  34.     </where>
  35.     <include refid="pageSql"/>
  36.   </select>
  38.   <delete id="deleteByPrimaryKey" parameterType="java.lang.String">
  39.     delete from user
  40.     where uid = #{uid,jdbcType=VARCHAR}
  41.   </delete>
  43.   <insert id="insert" parameterType="com.deepexi.domain.entity.User">
  44.     insert into user (uid, uname, pwd, 
  45.       addr)
  46.     values (#{uid,jdbcType=INTEGER}, #{uname,jdbcType=VARCHAR}, #{pwd,jdbcType=VARCHAR}, 
  47.       #{addr,jdbcType=VARCHAR})
  48.   </insert>
  51.   <update id="update" parameterType="com.deepexi.domain.entity.User">
  52.     update user
  53.     <set>
  54.        <if test=" uname != null and uname != '' ">
  55.             uname = #{uname,jdbcType=VARCHAR},
  56.        </if>
  57.        <if test=" pwd != null and pwd != '' ">
  58.             pwd = #{pwd,jdbcType=VARCHAR},
  59.        </if>
  60.        <if test=" addr != null and addr != '' ">
  61.             addr = #{addr,jdbcType=VARCHAR},
  62.        </if>
  63.     </set>
  64.     <if test=" uid != null and uid !='' ">
  65.             where uid=#{uid,jdbcType=VARCHAR}
  66.     </if>
  67.   </update>
  68. </mapper>

13创建完后项目结构如下：

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjkzODI4_size_16_color_FFFFFF_t_70

14 开启swagger界面测试接口：

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjkzODI4_size_16_color_FFFFFF_t_70 1

15 添加用户时调用Message服务的接口：（返回的内容是Message应用服务提供内容）

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjkzODI4_size_16_color_FFFFFF_t_70 2

二 服务提供者deepeximessage-spring-cloud
1 表结构：

  1. create table message(
  2. id int primary key auto_increment,
  3. msg varchar(100)
  4. )

2 实体类com.deepexi.domain.entity下Message：

  1. package com.deepexi.domain.entity;
  2. import lombok.Data;
  4. @Data
  5. public class Message {
  6.     private Integer id;
  7.     private String msg;
  8. }

3 Mapper层接口MessageMapper:

  1. package com.deepexi.mapper;
  2. import com.deepexi.domain.entity.Message;
  3. import org.apache.ibatis.annotations.Mapper;
  4. import org.apache.ibatis.annotations.Param;
  6. import java.util.List;
  7. @Mapper
  8. public interface MessageMapper {
  9.     int deleteByPrimaryKey(@Param(value="id") String id);
  11.     int insert(Message message);
  13.     List<Message> selectByMessage(Message message);
  15.     int update(Message message);
  17. }

4 业务层接口MessageService：

  1. package com.deepexi.service;
  2. import com.deepexi.domain.entity.Message;
  3. import org.apache.ibatis.annotations.Param;
  4. import java.util.List;
  5. public interface MessageService {
  6.     int deleteByPrimaryKey( String id);
  8.     int insert(Message message);
  10.     List<Message> selectByMessage(Message message);
  12.     int update(Message message);
  13. }

5 业务层实现MessageServiceImpl:

  1. package com.deepexi.service.impl;
  3. import com.deepexi.domain.entity.Message;
  4. import com.deepexi.mapper.MessageMapper;
  5. import com.deepexi.service.MessageService;
  6. import org.springframework.beans.factory.annotation.Autowired;
  7. import org.springframework.stereotype.Service;
  9. import java.util.List;
  10. @Service
  11. public class MessageServiceImpl implements MessageService {
  13.     @Autowired(required = false)
  14.     MessageMapper messageMapper;
  15.     @Override
  16.     public int deleteByPrimaryKey(String id) {
  17.         return messageMapper.deleteByPrimaryKey(id);
  18.     }
  20.     @Override
  21.     public int insert(Message message) {
  22.         return messageMapper.insert(message);
  23.     }
  25.     @Override
  26.     public List<Message> selectByMessage(Message message) {
  27.         return messageMapper.selectByMessage(message);
  28.     }
  30.     @Override
  31.     public int update(Message message) {
  32.         return messageMapper.update(message);
  33.     }
  34. }

6 控制层代码MessageController:

  1. package com.deepexi.controller;
  3. import com.alibaba.fastjson.JSONObject;
  4. import com.deepexi.domain.entity.Message;
  5. import com.deepexi.domain.vo.ResultVo;
  6. import com.deepexi.enums.StatusEnum;
  7. import com.deepexi.service.MessageService;
  8. import io.swagger.annotations.Api;
  9. import io.swagger.annotations.ApiOperation;
  10. import org.slf4j.Logger;
  11. import org.slf4j.LoggerFactory;
  12. import org.springframework.beans.factory.annotation.Autowired;
  13. import org.springframework.http.ResponseEntity;
  14. import org.springframework.web.bind.annotation.PostMapping;
  15. import org.springframework.web.bind.annotation.RequestBody;
  16. import org.springframework.web.bind.annotation.RequestParam;
  17. import org.springframework.web.bind.annotation.RestController;
  19. import java.util.List;
  21. @RestController
  22. @Api(value="信息管理")
  23. public class MessageController {
  24.     private final Logger log= LoggerFactory.getLogger(MessageController.class);
  26.     @Autowired
  27.     private MessageService messageService;
  29.     @PostMapping(value="/addMessage")
  30.     @ApiOperation(value="信息添加")
  31.     public ResponseEntity add(@RequestBody Message message){
  32.         try {
  33.             log.info("request add message: {}", JSONObject.toJSON(message));
  34.             messageService.insert(message);
  35.         } catch (Exception e) {
  36.             log.info("添加信息失败");
  37.             return ResponseEntity.ok().body(ResultVo.getInstance(StatusEnum.ADDFAIL));
  38.         }
  39.         return ResponseEntity.ok().body(ResultVo.getInstance(StatusEnum.SUCCESS));
  40.     }
  42.     @PostMapping(value="/updateMessage")
  43.     @ApiOperation(value="修改信息")
  44.     public ResponseEntity updateMessage(@RequestBody  Message message){
  45.         try {
  46.             log.info("request update message: {}",JSONObject.toJSON(message));
  47.             messageService.update(message);
  48.         } catch (Exception e) {
  49.             log.info("修改信息失败");
  50.             return ResponseEntity.ok().body(ResultVo.getInstance(StatusEnum.UPDATEFAIL));
  51.         }
  52.         return ResponseEntity.ok().body(ResultVo.getInstance(StatusEnum.SUCCESS));
  53.     }
  55.     @PostMapping(value="/selectMessage")
  56.     @ApiOperation(value="查询信息")
  57.     public ResponseEntity selectMessage(@RequestBody  Message message){
  58.         List<Message> list=null;
  59.         try {
  60.             log.info("request select message: {}",JSONObject.toJSON(message));
  61.            list=messageService.selectByMessage(message);
  62.         } catch (Exception e) {
  63.             log.info("查询获取信息失败");
  64.             return ResponseEntity.ok().body(ResultVo.getInstance(StatusEnum.FAIL));
  65.         }
  66.         return ResponseEntity.ok().body(list);
  67.     }
  69.     @PostMapping(value="/deleteMessage")
  70.     @ApiOperation(value="删除信息",notes = "根据id删除信息")
  71.     public ResponseEntity deleteMessage(@RequestParam(value="id") String id){
  72.         try {
  73.             log.info("request delete message: {}",id);
  74.             messageService.deleteByPrimaryKey(id);
  75.         } catch (Exception e) {
  76.             log.info("删除信息失败");
  77.             return ResponseEntity.ok().body(ResultVo.getInstance(StatusEnum.DALETEFAIL));
  78.         }
  79.         return ResponseEntity.ok().body(ResultVo.getInstance(StatusEnum.SUCCESS));
  80.     }
  82.     @PostMapping(value="/alertInfo")
  83.     @ApiOperation(value="返回一个提示信息",notes = "用于其他服务调用")
  84.     public ResponseEntity registerInfo(){
  85.         String msg=null;
  86.         //返回所有消息列表的第一条内容返回给其他服务
  87.         List<Message> list=messageService.selectByMessage(null);
  88.         if(list.size()>0){
  89.             for (Message item:list){
  90.                 msg=item.getMsg();
  91.             }
  92.         }
  93.         return ResponseEntity.ok().body(msg);
  94.     }
  95. }

7 配置文件、启动类与上面服务相似，不同是应用名称、端口号配置

8 配置文件：

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  3. <mapper namespace="com.deepexi.mapper.MessageMapper">
  4.   <resultMap id="BaseResultMap" type="com.deepexi.domain.entity.Message">
  5.     <id column="id" jdbcType="INTEGER" property="id" />
  6.     <result column="msg" jdbcType="VARCHAR" property="msg" />
  7.   </resultMap>
  8.   <sql id="Base_Column_List">
  9.     id, msg
  10.   </sql>
  11.   <select id="selectByMessage" parameterType="com.deepexi.domain.entity.Message" resultMap="BaseResultMap">
  12.     select
  13.     <include refid="Base_Column_List" />
  14.     from message
  15.     <where>
  16.       <if test=" id!=null">
  17.      and id= #{id,jdbcType=VARCHAR} order by id desc
  18.       </if>
  19.     </where>
  20.   </select>
  21.   <delete id="deleteByPrimaryKey" parameterType="java.lang.String">
  22.     delete from message
  23.     where id = #{id,jdbcType=VARCHAR}
  24.   </delete>
  25.   <insert id="insert" parameterType="com.deepexi.domain.entity.Message">
  26.     insert into message (id, msg)
  27.     values (#{id,jdbcType=INTEGER}, #{msg,jdbcType=VARCHAR})
  28.   </insert>
  30.   <update id="update" parameterType="com.deepexi.domain.entity.Message">
  31.     update message
  32.     <set>
  33.       <if test="msg != null">
  34.         msg=#{msg,jdbcType=VARCHAR},
  35.       </if>
  36.     </set>
  37.     <if test="id != null ">
  38.       where id = #{id,jdbcType=VARCHAR}
  39.     </if>
  40.   </update>
  41. </mapper>

9 开启wagger2界面：watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjkzODI4_size_16_color_FFFFFF_t_70 3

10 测试修改信息接口：

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjkzODI4_size_16_color_FFFFFF_t_70 4

11 测试返回提示信息接口，给消费者调用：

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjkzODI4_size_16_color_FFFFFF_t_70 5

三 注册中心
注册中心没有用脚手架生成，采用简单springboot项目导入依赖jar包，步骤如下：
1 pom文件：

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <modelVersion>4.0.0</modelVersion>
  5.     <parent>
  6.         <groupId>org.springframework.boot</groupId>
  7.         <artifactId>spring-boot-starter-parent</artifactId>
  8.         <version>2.1.6.RELEASE</version>
  9.         <relativePath/> <!-- lookup parent from repository -->
  10.     </parent>
  11.     <groupId>com.example</groupId>
  12.     <artifactId>demo</artifactId>
  13.     <version>0.0.1-SNAPSHOT</version>
  14.     <name>demo</name>
  15.     <description>Demo project for Spring Boot</description>
  17.     <properties>
  18.         <java.version>1.8</java.version>
  19.     </properties>
  21.     <dependencies>
  22.         <dependency>
  23.             <groupId>org.springframework.boot</groupId>
  24.             <artifactId>spring-boot-starter</artifactId>
  25.         </dependency>
  26.         <dependency>
  27.             <groupId>org.springframework.cloud</groupId>
  28.             <artifactId>spring-cloud-starter</artifactId>
  29.             <version>2.0.2.RELEASE</version>
  30.         </dependency>
  31.         <dependency>
  32.             <groupId>org.springframework.cloud</groupId>
  33.             <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
  34.             <version>2.0.2.RELEASE</version>
  35.         </dependency>
  37.         <dependency>
  38.             <groupId>org.projectlombok</groupId>
  39.             <artifactId>lombok</artifactId>
  40.             <optional>true</optional>
  41.         </dependency>
  42.         <dependency>
  43.             <groupId>org.springframework.boot</groupId>
  44.             <artifactId>spring-boot-starter-test</artifactId>
  45.             <scope>test</scope>
  46.         </dependency>
  47.     </dependencies>
  49.     <build>
  50.         <plugins>
  51.             <plugin>
  52.                 <groupId>org.springframework.boot</groupId>
  53.                 <artifactId>spring-boot-maven-plugin</artifactId>
  54.             </plugin>
  55.         </plugins>
  56.     </build>
  58. </project>

2 application.properties配置文件:

  1. spring.application.name=springcloud-register-center
  2. server.port=8761
  3. eureka.client.register-with-eureka=false
  4. eureka.client.fetch-registry=false
  5. eureka.client.service-url.defaultZone=http://127.0.0.1:8761/eureka/

3 启动类：

  1. package com.example.demo;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
  7. @SpringBootApplication
  8. @EnableEurekaServer
  9. public class DemoApplication {
  11.     public static void main(String[] args) {
  12.         SpringApplication.run(DemoApplication.class, args);
  13.     }
  15. }

4 启动后，分别启动上面两个应用，结果如下：（有两个实例）

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjkzODI4_size_16_color_FFFFFF_t_70 6

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjkzODI4_size_16_color_FFFFFF_t_70 7

发表评论

表情：
评论列表 （有 0 条评论，167人围观）

还没有评论，来说两句吧...

相关阅读