Spring Cloud入门（二）

红太狼 2023-03-05 03:27 3阅读 0赞

### 文章目录 ###

*  一、service服务
 *  二、commons 通用项目
 *   *  2.1 先创建一个简单工程，然后在工程下面创建Maven项目
     *  2.2 Java源文件
     *   *  2.2.1 POJO
         *  2.2.2 service
         *  2.2.3 Util
 *  三、item service 商品服务
 *   *  3.1 项目创建
     *  3.2 Java源文件
     *  3.3 Spring MVC 接收参数的几个注解
     *  3.4 访问测试
 *  四、user service用户服务
 *   *  4.1 项目创建
     *  4.2 Java源文件
     *  4.3 访问测试
 *  五、order service 订单服务
 *   *  5.1 项目创建
     *  5.2 Java源文件
     *  5.3 访问测试
 *  六、service 访问测试汇总

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70]

# 一、service服务 #

![在这里插入图片描述][20200804150129129.png]  
三个服务之间相互调用，通用代码单独创建一个commons项目存放

*  商品服务 item service，端口 8001
 *  用户服务 user service，端口 8101
 *  订单服务 order service，端口 8201

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 1]

# 二、commons 通用项目 #

使用IDEA演示

## 2.1 先创建一个简单工程，然后在工程下面创建Maven项目 ##

（1）新建 maven 项目（使用简单的模板创建）  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 2]  
（2）添加依赖，pom.xml

<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/xsd/maven-4.0.0.xsd">
    	<modelVersion>4.0.0</modelVersion>
    	<groupId>cn.tedu</groupId>
    	<artifactId>sp01-commons</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    	<name>sp01-commons</name>
    	<dependencies>
    		<dependency>
    			<groupId>com.fasterxml.jackson.module</groupId>
    			<artifactId>jackson-module-parameter-names</artifactId>
    			<version>2.9.8</version>
    		</dependency>
    		<dependency>
    			<groupId>com.fasterxml.jackson.datatype</groupId>
    			<artifactId>jackson-datatype-jdk8</artifactId>
    			<version>2.9.8</version>
    		</dependency>
    		<dependency>
    			<groupId>com.fasterxml.jackson.datatype</groupId>
    			<artifactId>jackson-datatype-jsr310</artifactId>
    			<version>2.9.8</version>
    		</dependency>
    		<dependency>
    			<groupId>com.fasterxml.jackson.datatype</groupId>
    			<artifactId>jackson-datatype-guava</artifactId>
    			<version>2.9.8</version>
    		</dependency>
    
    		<dependency>
    			<groupId>org.projectlombok</groupId>
    			<artifactId>lombok</artifactId>
    			<version>1.18.6</version>
    		</dependency>
    		<dependency>
    			<groupId>javax.servlet</groupId>
    			<artifactId>javax.servlet-api</artifactId>
    			<version>3.1.0</version>
    		</dependency>
    		<dependency>
    			<groupId>org.slf4j</groupId>
    			<artifactId>slf4j-api</artifactId>
    			<version>1.7.26</version>
    		</dependency>
    		<dependency>
    		    <groupId>org.apache.commons</groupId>
    		    <artifactId>commons-lang3</artifactId>
    		    <version>3.9</version>
    		</dependency>
    
    	</dependencies>
    
    	<build>
    		<plugins>
    			<plugin>
    				<groupId>org.apache.maven.plugins</groupId>
    				<artifactId>maven-compiler-plugin</artifactId>
    				<version>3.8.0</version>
    				<configuration>
    					<source>1.8</source>
    					<target>1.8</target>
    				</configuration>
    			</plugin>
    		</plugins>
    	</build>
    </project>

## 2.2 Java源文件 ##

一共九个文件(三个包)，自己手动写一下，尽量不要复制  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 3]

> 注意要提前安装Lombok插件，自己在插件市场安装即可，否则可能会报错

### 2.2.1 POJO ###

**Item**

package cn.tedu.sp01.pojo;
    
    import lombok.AllArgsConstructor;
    import lombok.Data;
    import lombok.NoArgsConstructor;
    
    @Data
    @NoArgsConstructor
    @AllArgsConstructor
    public class Item { 
        private Integer id;
        private String name;
        private Integer number;
    }

**User**

package cn.tedu.sp01.pojo;
    
    import lombok.AllArgsConstructor;
    import lombok.Data;
    import lombok.NoArgsConstructor;
    @Data
    @NoArgsConstructor
    @AllArgsConstructor
    public class User { 
        private Integer id;
        private String username;
        private String password;
    }

**Order**

package cn.tedu.sp01.pojo;
    
    import lombok.AllArgsConstructor;
    import lombok.Data;
    import lombok.NoArgsConstructor;
    
    import java.util.List;
    
    @Data
    @NoArgsConstructor
    @AllArgsConstructor
    public class Order { 
        private String id;
        private User user;
        private List<Item> items;
    }

### 2.2.2 service ###

**ItemService**

package cn.tedu.sp01.service;
    
    import cn.tedu.sp01.pojo.Item;
    
    import java.util.List;
    
    public interface ItemService { 
        //查询订单中的商品列表
        List<Item> getItems(String orderId);
    
        //减少商品的库存
        void decreaseNumbers(List<Item> list);
    }

**UserService**

package cn.tedu.sp01.service;
    
    import cn.tedu.sp01.pojo.User;
    
    public interface UserService { 
        //查询用户
        User getUser(Integer id);
        //增加用户积分
        void addScore(Integer id, Integer score);
    }

**OrderService**

package cn.tedu.sp01.service;
    
    import cn.tedu.sp01.pojo.Item;
    import cn.tedu.sp01.pojo.Order;
    
    import java.util.List;
    
    public interface OrderService { 
        //查询订单
        Order getOrder(String orderId);
        //添加订单
        void addOrder(Order order);
    }

### 2.2.3 Util ###

**CookieUtil**

package cn.tedu.web.util;
    
    import javax.servlet.http.Cookie;
    import javax.servlet.http.HttpServletRequest;
    import javax.servlet.http.HttpServletResponse;
    
    public class CookieUtil { 
        /** * @param response * @param name * @param value * @param domain * @param path * @param maxAge */
        public static void setCookie(HttpServletResponse response,
                                     String name, String value, String domain, String path, int maxAge) { 
            Cookie cookie = new Cookie(name, value);
            if(domain != null) { 
                cookie.setDomain(domain);
            }
            cookie.setPath(path);
            cookie.setMaxAge(maxAge);
            response.addCookie(cookie);
        }
        public static void setCookie(HttpServletResponse response, String name, String value, int maxAge) { 
            setCookie(response, name, value, null, "/", maxAge);
        }
        public static void setCookie(HttpServletResponse response, String name, String value) { 
            setCookie(response, name, value, null, "/", 3600);
        }
        public static void setCookie(HttpServletResponse response, String name) { 
            setCookie(response, name, "", null, "/", 3600);
        }
    
        /** * @param request * @param name * @return */
        public static String getCookie(HttpServletRequest request, String name) { 
            String value = null;
            Cookie[] cookies = request.getCookies();
            if (null != cookies) { 
                for (Cookie cookie : cookies) { 
                    if (cookie.getName().equals(name)) { 
                        value = cookie.getValue();
                    }
                }
            }
            return value;
        }
    
        /** * @param response * @param name * @return */
        public static void removeCookie(HttpServletResponse response, String name, String domain, String path) { 
            setCookie(response, name, "", domain, path, 0);
        }
    }

**JsonResult**

package cn.tedu.web.util;
    
    import lombok.Getter;
    import lombok.Setter;
    
    @Getter
    @Setter
    public class JsonResult<T> { 
        /** 成功 */
        public static final int SUCCESS = 200;
    
        /** 没有登录 */
        public static final int NOT_LOGIN = 400;
    
        /** 发生异常 */
        public static final int EXCEPTION = 401;
    
        /** 系统错误 */
        public static final int SYS_ERROR = 402;
    
        /** 参数错误 */
        public static final int PARAMS_ERROR = 403;
    
        /** 不支持或已经废弃 */
        public static final int NOT_SUPPORTED = 410;
    
        /** AuthCode错误 */
        public static final int INVALID_AUTHCODE = 444;
    
        /** 太频繁的调用 */
        public static final int TOO_FREQUENT = 445;
    
        /** 未知的错误 */
        public static final int UNKNOWN_ERROR = 499;
    
        private int code;
        private String msg;
        private T data;
    
        public static JsonResult build() { 
            return new JsonResult();
        }
        public static JsonResult build(int code) { 
            return new JsonResult().code(code);
        }
        public static JsonResult build(int code, String msg) { 
            return new JsonResult<String>().code(code).msg(msg);
        }
        public static <T> JsonResult<T> build(int code, T data) { 
            return new JsonResult<T>().code(code).data(data);
        }
        public static <T> JsonResult<T> build(int code, String msg, T data) { 
            return new JsonResult<T>().code(code).msg(msg).data(data);
        }
    
        public JsonResult<T> code(int code) { 
            this.code = code;
            return this;
        }
        public JsonResult<T> msg(String msg) { 
            this.msg = msg;
            return this;
        }
        public JsonResult<T> data(T data) { 
            this.data = data;
            return this;
        }
    
        public static JsonResult ok() { 
            return build(SUCCESS);
        }
        public static JsonResult ok(String msg) { 
            return build(SUCCESS, msg);
        }
        public static <T> JsonResult<T> ok(T data) { 
            return build(SUCCESS, data);
        }
        public static JsonResult err() { 
            return build(EXCEPTION);
        }
        public static JsonResult err(String msg) { 
            return build(EXCEPTION, msg);
        }
        @Override
        public String toString() { 
            return JsonUtil.to(this);
        }
    }

**JsonUtil**

package cn.tedu.web.util;
    
    import java.io.File;
    import java.io.FileWriter;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.InputStreamReader;
    import java.io.Writer;
    import java.math.BigDecimal;
    import java.math.BigInteger;
    import java.net.URL;
    import java.nio.charset.StandardCharsets;
    import java.text.SimpleDateFormat;
    import java.util.ArrayList;
    import java.util.List;
    
    import org.apache.commons.lang3.StringUtils;
    
    import com.fasterxml.jackson.annotation.JsonInclude;
    import com.fasterxml.jackson.core.JsonGenerator;
    import com.fasterxml.jackson.core.JsonParser;
    import com.fasterxml.jackson.core.JsonProcessingException;
    import com.fasterxml.jackson.core.type.TypeReference;
    import com.fasterxml.jackson.databind.DeserializationFeature;
    import com.fasterxml.jackson.databind.JsonNode;
    import com.fasterxml.jackson.databind.ObjectMapper;
    import com.fasterxml.jackson.databind.SerializationFeature;
    import com.fasterxml.jackson.databind.node.ObjectNode;
    import com.fasterxml.jackson.datatype.guava.GuavaModule;
    import com.fasterxml.jackson.datatype.jdk8.Jdk8Module;
    import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
    import com.fasterxml.jackson.module.paramnames.ParameterNamesModule;
    
    import lombok.extern.slf4j.Slf4j;
    
    @Slf4j
    public class JsonUtil { 
        private static ObjectMapper mapper;
        private static JsonInclude.Include DEFAULT_PROPERTY_INCLUSION = JsonInclude.Include.NON_DEFAULT;
        private static boolean IS_ENABLE_INDENT_OUTPUT = false;
        private static String CSV_DEFAULT_COLUMN_SEPARATOR = ",";
        static { 
            try { 
                initMapper();
                configPropertyInclusion();
                configIndentOutput();
                configCommon();
            } catch (Exception e) { 
                log.error("jackson config error", e);
            }
        }
    
        private static void initMapper() { 
            mapper = new ObjectMapper();
        }
    
        private static void configCommon() { 
            config(mapper);
        }
    
        private static void configPropertyInclusion() { 
            mapper.setSerializationInclusion(DEFAULT_PROPERTY_INCLUSION);
        }
    
        private static void configIndentOutput() { 
            mapper.configure(SerializationFeature.INDENT_OUTPUT, IS_ENABLE_INDENT_OUTPUT);
        }
    
        private static void config(ObjectMapper objectMapper) { 
            objectMapper.enable(JsonGenerator.Feature.WRITE_BIGDECIMAL_AS_PLAIN);
            objectMapper.enable(DeserializationFeature.ACCEPT_EMPTY_STRING_AS_NULL_OBJECT);
            objectMapper.enable(DeserializationFeature.ACCEPT_SINGLE_VALUE_AS_ARRAY);
            objectMapper.enable(DeserializationFeature.FAIL_ON_READING_DUP_TREE_KEY);
            objectMapper.enable(DeserializationFeature.FAIL_ON_NUMBERS_FOR_ENUMS);
            objectMapper.disable(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES);
            objectMapper.disable(DeserializationFeature.FAIL_ON_NULL_FOR_PRIMITIVES);
            objectMapper.disable(SerializationFeature.FAIL_ON_EMPTY_BEANS);
            objectMapper.enable(JsonParser.Feature.ALLOW_COMMENTS);
            objectMapper.disable(JsonGenerator.Feature.ESCAPE_NON_ASCII);
            objectMapper.enable(JsonGenerator.Feature.IGNORE_UNKNOWN);
            objectMapper.enable(JsonParser.Feature.ALLOW_UNQUOTED_FIELD_NAMES);
            objectMapper.disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS);
            objectMapper.setDateFormat(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"));
            objectMapper.enable(JsonParser.Feature.ALLOW_SINGLE_QUOTES);
            objectMapper.registerModule(new ParameterNamesModule());
            objectMapper.registerModule(new Jdk8Module());
            objectMapper.registerModule(new JavaTimeModule());
            objectMapper.registerModule(new GuavaModule());
        }
        public static void setSerializationInclusion(JsonInclude.Include inclusion) { 
            DEFAULT_PROPERTY_INCLUSION = inclusion;
            configPropertyInclusion();
        }
    
        public static void setIndentOutput(boolean isEnable) { 
            IS_ENABLE_INDENT_OUTPUT = isEnable;
            configIndentOutput();
        }
    
        public static <V> V from(URL url, Class<V> c) { 
            try { 
                return mapper.readValue(url, c);
            } catch (IOException e) { 
                log.error("jackson from error, url: {}, type: {}", url.getPath(), c, e);
                return null;
            }
        }
    
        public static <V> V from(InputStream inputStream, Class<V> c) { 
            try { 
                return mapper.readValue(inputStream, c);
            } catch (IOException e) { 
                log.error("jackson from error, type: {}", c, e);
                return null;
            }
        }
    
        public static <V> V from(File file, Class<V> c) { 
            try { 
                return mapper.readValue(file, c);
            } catch (IOException e) { 
                log.error("jackson from error, file path: {}, type: {}", file.getPath(), c, e);
                return null;
            }
        }
    
        public static <V> V from(Object jsonObj, Class<V> c) { 
            try { 
                return mapper.readValue(jsonObj.toString(), c);
            } catch (IOException e) { 
                log.error("jackson from error, json: {}, type: {}", jsonObj.toString(), c, e);
                return null;
            }
        }
    
        public static <V> V from(String json, Class<V> c) { 
            try { 
                return mapper.readValue(json, c);
            } catch (IOException e) { 
                log.error("jackson from error, json: {}, type: {}", json, c, e);
                return null;
            }
        }
    
        public static <V> V from(URL url, TypeReference<V> type) { 
            try { 
                return mapper.readValue(url, type);
            } catch (IOException e) { 
                log.error("jackson from error, url: {}, type: {}", url.getPath(), type, e);
                return null;
            }
        }
    
        public static <V> V from(InputStream inputStream, TypeReference<V> type) { 
            try { 
                return mapper.readValue(inputStream, type);
            } catch (IOException e) { 
                log.error("jackson from error, type: {}", type, e);
                return null;
            }
        }
    
        public static <V> V from(File file, TypeReference<V> type) { 
            try { 
                return mapper.readValue(file, type);
            } catch (IOException e) { 
                log.error("jackson from error, file path: {}, type: {}", file.getPath(), type, e);
                return null;
            }
        }
    
        public static <V> V from(Object jsonObj, TypeReference<V> type) { 
            try { 
                return mapper.readValue(jsonObj.toString(), type);
            } catch (IOException e) { 
                log.error("jackson from error, json: {}, type: {}", jsonObj.toString(), type, e);
                return null;
            }
        }
    
        public static <V> V from(String json, TypeReference<V> type) { 
            try { 
                return mapper.readValue(json, type);
            } catch (IOException e) { 
                log.error("jackson from error, json: {}, type: {}", json, type, e);
                return null;
            }
        }
    
        public static <V> String to(List<V> list) { 
            try { 
                return mapper.writeValueAsString(list);
            } catch (JsonProcessingException e) { 
                log.error("jackson to error, obj: {}", list, e);
                return null;
            }
        }
    
        public static <V> String to(V v) { 
            try { 
                return mapper.writeValueAsString(v);
            } catch (JsonProcessingException e) { 
                log.error("jackson to error, obj: {}", v, e);
                return null;
            }
        }
    
        public static <V> void toFile(String path, List<V> list) { 
            try (Writer writer = new FileWriter(new File(path), true)) { 
                mapper.writer().writeValues(writer).writeAll(list);
                writer.flush();
            } catch (Exception e) { 
                log.error("jackson to file error, path: {}, list: {}", path, list, e);
            }
        }
    
        public static <V> void toFile(String path, V v) { 
            try (Writer writer = new FileWriter(new File(path), true)) { 
                mapper.writer().writeValues(writer).write(v);
                writer.flush();
            } catch (Exception e) { 
                log.error("jackson to file error, path: {}, obj: {}", path, v, e);
            }
        }
    
        public static String getString(String json, String key) { 
            if (StringUtils.isEmpty(json)) { 
                return null;
            }
            try { 
                JsonNode node = mapper.readTree(json);
                if (null != node) { 
                    return node.get(key).toString();
                } else { 
                    return null;
                }
            } catch (IOException e) { 
                log.error("jackson get string error, json: {}, key: {}", json, key, e);
                return null;
            }
        }
    
        public static Integer getInt(String json, String key) { 
            if (StringUtils.isEmpty(json)) { 
                return null;
            }
            try { 
                JsonNode node = mapper.readTree(json);
                if (null != node) { 
                    return node.get(key).intValue();
                } else { 
                    return null;
                }
            } catch (IOException e) { 
                log.error("jackson get int error, json: {}, key: {}", json, key, e);
                return null;
            }
        }
    
        public static Long getLong(String json, String key) { 
            if (StringUtils.isEmpty(json)) { 
                return null;
            }
            try { 
                JsonNode node = mapper.readTree(json);
                if (null != node) { 
                    return node.get(key).longValue();
                } else { 
                    return null;
                }
            } catch (IOException e) { 
                log.error("jackson get long error, json: {}, key: {}", json, key, e);
                return null;
            }
        }
    
        public static Double getDouble(String json, String key) { 
            if (StringUtils.isEmpty(json)) { 
                return null;
            }
            try { 
                JsonNode node = mapper.readTree(json);
                if (null != node) { 
                    return node.get(key).doubleValue();
                } else { 
                    return null;
                }
            } catch (IOException e) { 
                log.error("jackson get double error, json: {}, key: {}", json, key, e);
                return null;
            }
        }
    
        public static BigInteger getBigInteger(String json, String key) { 
            if (StringUtils.isEmpty(json)) { 
                return new BigInteger(String.valueOf(0.00));
            }
            try { 
                JsonNode node = mapper.readTree(json);
                if (null != node) { 
                    return node.get(key).bigIntegerValue();
                } else { 
                    return null;
                }
            } catch (IOException e) { 
                log.error("jackson get biginteger error, json: {}, key: {}", json, key, e);
                return null;
            }
        }
    
        public static BigDecimal getBigDecimal(String json, String key) { 
            if (StringUtils.isEmpty(json)) { 
                return null;
            }
            try { 
                JsonNode node = mapper.readTree(json);
                if (null != node) { 
                    return node.get(key).decimalValue();
                } else { 
                    return null;
                }
            } catch (IOException e) { 
                log.error("jackson get bigdecimal error, json: {}, key: {}", json, key, e);
                return null;
            }
        }
    
        public static boolean getBoolean(String json, String key) { 
            if (StringUtils.isEmpty(json)) { 
                return false;
            }
            try { 
                JsonNode node = mapper.readTree(json);
                if (null != node) { 
                    return node.get(key).booleanValue();
                } else { 
                    return false;
                }
            } catch (IOException e) { 
                log.error("jackson get boolean error, json: {}, key: {}", json, key, e);
                return false;
            }
        }
    
        public static byte[] getByte(String json, String key) { 
            if (StringUtils.isEmpty(json)) { 
                return null;
            }
            try { 
                JsonNode node = mapper.readTree(json);
                if (null != node) { 
                    return node.get(key).binaryValue();
                } else { 
                    return null;
                }
            } catch (IOException e) { 
                log.error("jackson get byte error, json: {}, key: {}", json, key, e);
                return null;
            }
        }
    
        public static <T> ArrayList<T> getList(String json, String key) { 
            if (StringUtils.isEmpty(json)) { 
                return null;
            }
            String string = getString(json, key);
            return from(string, new TypeReference<ArrayList<T>>() { });
        }
    
        public static <T> String add(String json, String key, T value) { 
            try { 
                JsonNode node = mapper.readTree(json);
                add(node, key, value);
                return node.toString();
            } catch (IOException e) { 
                log.error("jackson add error, json: {}, key: {}, value: {}", json, key, value, e);
                return json;
            }
        }
    
        private static <T> void add(JsonNode jsonNode, String key, T value) { 
            if (value instanceof String) { 
                ((ObjectNode) jsonNode).put(key, (String) value);
            } else if (value instanceof Short) { 
                ((ObjectNode) jsonNode).put(key, (Short) value);
            } else if (value instanceof Integer) { 
                ((ObjectNode) jsonNode).put(key, (Integer) value);
            } else if (value instanceof Long) { 
                ((ObjectNode) jsonNode).put(key, (Long) value);
            } else if (value instanceof Float) { 
                ((ObjectNode) jsonNode).put(key, (Float) value);
            } else if (value instanceof Double) { 
                ((ObjectNode) jsonNode).put(key, (Double) value);
            } else if (value instanceof BigDecimal) { 
                ((ObjectNode) jsonNode).put(key, (BigDecimal) value);
            } else if (value instanceof BigInteger) { 
                ((ObjectNode) jsonNode).put(key, (BigInteger) value);
            } else if (value instanceof Boolean) { 
                ((ObjectNode) jsonNode).put(key, (Boolean) value);
            } else if (value instanceof byte[]) { 
                ((ObjectNode) jsonNode).put(key, (byte[]) value);
            } else { 
                ((ObjectNode) jsonNode).put(key, to(value));
            }
        }
    
        public static String remove(String json, String key) { 
            try { 
                JsonNode node = mapper.readTree(json);
                ((ObjectNode) node).remove(key);
                return node.toString();
            } catch (IOException e) { 
                log.error("jackson remove error, json: {}, key: {}", json, key, e);
                return json;
            }
        }
    
        public static <T> String update(String json, String key, T value) { 
            try { 
                JsonNode node = mapper.readTree(json);
                ((ObjectNode) node).remove(key);
                add(node, key, value);
                return node.toString();
            } catch (IOException e) { 
                log.error("jackson update error, json: {}, key: {}, value: {}", json, key, value, e);
                return json;
            }
        }
    
        public static String format(String json) { 
            try { 
                JsonNode node = mapper.readTree(json);
                return mapper.writerWithDefaultPrettyPrinter().writeValueAsString(node);
            } catch (IOException e) { 
                log.error("jackson format json error, json: {}", json, e);
                return json;
            }
        }
    
        public static boolean isJson(String json) { 
            try { 
                mapper.readTree(json);
                return true;
            } catch (Exception e) { 
                log.error("jackson check json error, json: {}", json, e);
                return false;
            }
        }
    
        private static InputStream getResourceStream(String name) { 
            return JsonUtil.class.getClassLoader().getResourceAsStream(name);
        }
    
        private static InputStreamReader getResourceReader(InputStream inputStream) { 
            if (null == inputStream) { 
                return null;
            }
            return new InputStreamReader(inputStream, StandardCharsets.UTF_8);
        }
    }

# 三、item service 商品服务 #

1.  新建项目
2.  配置依赖 pom.xml
3.  配置 application.yml
4.  配置主程序
5.  编写代码

## 3.1 项目创建 ##

（1）新建 spring boot 项目  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 4]  
（2）选择依赖项，只添加web即可  
![在这里插入图片描述][20200804164034409.png]  
（3）填加 sp01-commons 项目依赖  
![在这里插入图片描述][20200804164045948.png]  
（4）修改`application.properties`的名字为`application.yml`(也可以不改)  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 5]  
（5）添加上下图所示的内容  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 6]

## 3.2 Java源文件 ##

主程序是默认生成的，不需要修改  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 7]  
**（1）ItemServiceImpl**

package cn.tedu.sp02.item.service;
    
    import java.util.ArrayList;
    import java.util.List;
    
    import org.springframework.stereotype.Service;
    
    import cn.tedu.sp01.pojo.Item;
    import cn.tedu.sp01.service.ItemService;
    
    import lombok.extern.slf4j.Slf4j;
    
    @Slf4j
    @Service
    public class ItemServiceImpl implements ItemService { 
    
        @Override
        public List<Item> getItems(String orderId) { 
            ArrayList<Item> list = new ArrayList<Item>();
            list.add(new Item(1, "商品 1",1));
            list.add(new Item(2, "商品 2",2));
            list.add(new Item(3, "商品 3",3));
            list.add(new Item(4, "商品 4",4));
            list.add(new Item(5, "商品 5",5));
            return list;
        }
    
        @Override
        public void decreaseNumbers(List<Item> list) { 
            for(Item item : list) { 
                log.info("减少库存 - "+item);
            }
        }
    }

**（2）ItemController**

package cn.tedu.sp02.item.controller;
    
    import java.util.List;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.PostMapping;
    import org.springframework.web.bind.annotation.RequestBody;
    import org.springframework.web.bind.annotation.RestController;
    
    import cn.tedu.sp01.pojo.Item;
    import cn.tedu.sp01.service.ItemService;
    import cn.tedu.web.util.JsonResult;
    
    import lombok.extern.slf4j.Slf4j;
    
    @Slf4j
    @RestController
    public class ItemController { 
        @Autowired
        private ItemService itemService;
    
        @Value("${server.port}")
        private int port;
    
        @GetMapping("/{orderId}")
        public JsonResult<List<Item>> getItems(@PathVariable String orderId) { 
            log.info("server.port="+port+", orderId="+orderId);
    
            List<Item> items = itemService.getItems(orderId);
            return JsonResult.ok(items).msg("port="+port);
        }
    
        @PostMapping("/decreaseNumber")
        public JsonResult decreaseNumber(@RequestBody List<Item> items) { 
            itemService.decreaseNumbers(items);
            return JsonResult.ok();
        }
    }

## 3.3 Spring MVC 接收参数的几个注解 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 8]

## 3.4 访问测试 ##

*  根据orderid，查询商品  
    `http://localhost:8001/35`
 *  减少商品库存  
    `http://localhost:8001/decreaseNumber`
 *  使用postman，POST发送以下格式数据：  
    `[{"id":1, "name":"abc", "number":23},{"id":2, "name":"def", "number":11}]`

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 9]

# 四、user service用户服务 #

1.  新建项目
2.  配置依赖 pom.xml
3.  配置 application.yml
4.  配置主程序
5.  编写代码

## 4.1 项目创建 ##

（1）新建 spring boot 起步项目  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 10]  
（2）添加依赖项  
![在这里插入图片描述][20200805100725141.png]  
（3）在pom.xml中要填加 sp01-commons 项目依赖

<?xml version="1.0" encoding="UTF-8"?>
    <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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.3.2.RELEASE</version>
            <relativePath/> 
        </parent>
        <groupId>cn.tedu</groupId>
        <artifactId>sp03-userservice</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>sp03-userservice</name>
        <description>Demo project for Spring Boot</description>
    
        <properties>
            <java.version>1.8</java.version>
        </properties>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
                <exclusions>
                    <exclusion>
                        <groupId>org.junit.vintage</groupId>
                        <artifactId>junit-vintage-engine</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
            <dependency>
                <groupId>cn.tedu</groupId>
                <artifactId>sp01-commons</artifactId>
                <version>1.0-SNAPSHOT</version>
            </dependency>
    
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    
    </project>

（4）application.yml

*  其中 `sp.user-service.users` 属性为自定义属性，提供用于测试的用户数据

sp:
      user-service:
        users: "[{\"id\":7, \"username\":\"abc\",\"password\":\"123\"},{\"id\":8, \"username\":\"def\",\"password\":\"456\"},{\"id\":9, \"username\":\"ghi\",\"password\":\"789\"}]"
    
    spring:
      application:
        name: user-service
    
    server:
      port: 8101

> 主程序默认生成，不需要修改

## 4.2 Java源文件 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 11]  
（1）**UserServiceImpl**

package cn.tedu.sp03.user.service;
    
    import java.util.List;
    
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.stereotype.Service;
    
    import com.fasterxml.jackson.core.type.TypeReference;
    import cn.tedu.sp01.pojo.User;
    import cn.tedu.sp01.service.UserService;
    import cn.tedu.web.util.JsonUtil;
    
    import lombok.extern.slf4j.Slf4j;
    
    @Slf4j
    @Service
    public class UserServiceImpl implements UserService { 
    	@Value("${sp.user-service.users}")
    	private String userJson;
    	
    	@Override
    	public User getUser(Integer id) { 
    		log.info("users json string : "+userJson);
    		List<User> list = JsonUtil.from(userJson, new TypeReference<List<User>>() { });
    		for (User u : list) { 
    			if (u.getId().equals(id)) { 
    				return u;
    			}
    		}
    		
    		return new User(id, "name-"+id, "pwd-"+id);
    	}
    
    	@Override
    	public void addScore(Integer id, Integer score) { 
    		// 这里增加积分
    		log.info("user "+id+" - 增加积分 "+score);
    	}
    
    }

（2）**UserController**

package cn.tedu.sp03.user.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.RestController;
    
    import cn.tedu.sp01.pojo.User;
    import cn.tedu.sp01.service.UserService;
    import cn.tedu.web.util.JsonResult;
    
    import lombok.extern.slf4j.Slf4j;
    
    @Slf4j
    @RestController
    public class UserController { 
    	
    	@Autowired
    	private UserService userService;
    	
    	@GetMapping("/{userId}")
    	public JsonResult<User> getUser(@PathVariable Integer userId) { 
    		log.info("get user, userId="+userId);
    		User u = userService.getUser(userId);
    		return JsonResult.ok(u);
    	}
    	
    	@GetMapping("/{userId}/score") 
    	public JsonResult addScore(
    			@PathVariable Integer userId, Integer score) { 
    		userService.addScore(userId, score);
    		return JsonResult.ok();
    	}
    }

## 4.3 访问测试 ##

*  根据userid查询用户信息  
    `http://localhost:8101/7`
 *  根据userid，为用户增加积分  
    `http://localhost:8101/7/score?score=100`

# 五、order service 订单服务 #

1.  新建项目
2.  配置依赖 pom.xml
3.  配置 application.yml
4.  配置主程序
5.  编写代码

## 5.1 项目创建 ##

（3）`pom.xml`文件添加sp01的依赖，参考4.3

（4）`application.yml`

spring:
      application:
        name: order-service
        
    server:
      port: 8201

（5）主程序默认生成，不需要修改

## 5.2 Java源文件 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 13]  
（1）**OrderServiceImpl**

package cn.tedu.sp04.order.service;
    
    import org.springframework.stereotype.Service;
    
    import cn.tedu.sp01.pojo.Order;
    import cn.tedu.sp01.service.OrderService;
    
    import lombok.extern.slf4j.Slf4j;
    
    @Slf4j
    @Service
    public class OrderServiceImpl implements OrderService { 
    
    	@Override
    	public Order getOrder(String orderId) { 
    		//TODO: 调用user-service获取用户信息
    		//TODO: 调用item-service获取商品信息
    		Order order = new Order();
    		order.setId(orderId);
    		return order;
    	}
    
    	@Override
    	public void addOrder(Order order) { 
    		//TODO: 调用item-service减少商品库存
    		//TODO: 调用user-service增加用户积分
    		log.info("保存订单："+order);
    	}
    }

（2）**OrderController**

package cn.tedu.sp04.order.controller;
    
    import java.util.Arrays;
    
    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.RestController;
    
    import cn.tedu.sp01.pojo.Item;
    import cn.tedu.sp01.pojo.Order;
    import cn.tedu.sp01.pojo.User;
    import cn.tedu.sp01.service.OrderService;
    import cn.tedu.web.util.JsonResult;
    
    import lombok.extern.slf4j.Slf4j;
    
    @Slf4j
    @RestController
    public class OrderController { 
    	@Autowired
    	private OrderService orderService;
    	
    	@GetMapping("/{orderId}")
    	public JsonResult<Order> getOrder(@PathVariable String orderId) { 
    		log.info("get order, id="+orderId);
    		
    		Order order = orderService.getOrder(orderId);
    		return JsonResult.ok(order);
    	}
    	
    	@GetMapping("/")
    	public JsonResult addOrder() { 
    		//模拟post提交的数据
    		Order order = new Order();
    		order.setId("123abc");
    		order.setUser(new User(7,null,null));
    		order.setItems(Arrays.asList(new Item[] { 
    				new Item(1,"aaa",2),
    				new Item(2,"bbb",1),
    				new Item(3,"ccc",3),
    				new Item(4,"ddd",1),
    				new Item(5,"eee",5),
    		}));
    		orderService.addOrder(order);
    		return JsonResult.ok();
    	}
    }

## 5.3 访问测试 ##

*  根据orderid，获取订单  
    `http://localhost:8201/123abc`
 *  保存订单，观察控制台日志输出  
    `http://localhost:8201/`

# 六、service 访问测试汇总 #

*  item-service

根据orderid，查询商品  
`http://localhost:8001/35`

减少商品库存  
`http://localhost:8001/decreaseNumber`

使用postman，POST发送以下格式数据：  
`[{"id":1, "name":"abc", "number":23},{"id":2, "name":"def", "number":11}]`

*  user-service

根据userid查询用户信息  
`http://localhost:8101/7`

根据userid，为用户增加积分  
`http://localhost:8101/7/score?score=100`

*  order-service

根据orderid，获取订单  
`http://localhost:8201/123abc`

保存订单，观察控制台日志输出  
`http://localhost:8201/`

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70]: /images/20230208/8f8f5436abd14dd189f6e11948e24545.png
[20200804150129129.png]: /images/20230208/2b9e62220e514abeb2219492e2ea1574.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 1]: /images/20230208/6cee319c11954c018c3a4563a1fc355f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 2]: /images/20230208/02cd364bf4dc4f33a201f205af151f0a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 3]: /images/20230208/522febb916cd40ffa23ab8c752cb3786.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 4]: /images/20230208/424ffcc84e0142698b187102e93bbfdf.png
[20200804164034409.png]: /images/20230208/fdacd09e1ea24843bf46a2f8187c9ebc.png
[20200804164045948.png]: /images/20230208/83c1560398014194a0595d1e91743654.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 5]: /images/20230208/1c5f9c233fb54bd39742ccbed693e720.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 6]: /images/20230208/2cb27849503d4a10b5d9dcdd774a4b18.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 7]: /images/20230208/1bcd4babb84e433190f230f4e3133b54.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 8]: /images/20230208/db9f59b6a4734ce4ba2da83660d2d909.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 9]: /images/20230208/021eb7d4e37042029143ba01063cb7a3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 10]: /images/20230208/7acbd44f39184bb4989450a77572316b.png
[20200805100725141.png]: /images/20230208/acfdf1780c2f4d519a1becbd25a51153.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 11]: /images/20230208/85e1d71abfb94793b5fbb33dfe8aa85f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 12]: /images/20230208/4606a4bc05074bde9d35cdae688b891c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 13]: /images/20230208/5dace12ea0ed4fde80c74f95e4819b47.png