{"id":1925,"date":"2023-04-01T09:48:55","date_gmt":"2023-04-01T01:48:55","guid":{"rendered":"https:\/\/www.appblog.cn\/?p=1925"},"modified":"2023-04-22T08:49:30","modified_gmt":"2023-04-22T00:49:30","slug":"dubbo-spring-cloud-service-provider-web-application-development-steps","status":"publish","type":"post","link":"https:\/\/www.appblog.cn\/index.php\/2023\/04\/01\/dubbo-spring-cloud-service-provider-web-application-development-steps\/","title":{"rendered":"Dubbo Spring Cloud \u670d\u52a1\u63d0\u4f9b\u65b9\uff08Web\u5e94\u7528\uff09\u5f00\u53d1\u6b65\u9aa4"},"content":{"rendered":"
\n

\u6ce8\u518c\u4e2d\u5fc3\u91c7\u7528\u963f\u91cc\u5df4\u5df4Nacos
\n\u670d\u52a1\u5bb9\u5668\u4e3aTomcat<\/code>\uff0c\u7aef\u53e3\u4e3a8080
\ndubbo\u534f\u8bae\u572820880+n<\/code>\u7aef\u53e3\u66b4\u9732\u670d\u52a1<\/p>\n<\/blockquote>\n

\u63a5\u53e3<\/h2>\n

<\/p>\n

\u63a5\u53e3\u5b9a\u4e49<\/h3>\n
public interface UserService {\n\n    boolean save(User user);\n\n    boolean remove(Long userId);\n\n    Collection<User> findAll();\n}<\/code><\/pre>\n
public interface RestService {\n\n    String param(String param);\n\n    String params(int a, String b);\n\n    String headers(String header, String header2, Integer param);\n\n    String pathVariables(String path1, String path2, String param);\n\n    String form(String form);\n\n    User requestBodyMap(Map<String, Object> data, String param);\n\n    Map<String, Object> requestBodyUser(User user);\n}<\/code><\/pre>\n
\u5de5\u5177\u7c7b<\/h3>\n
import org.apache.dubbo.rpc.RpcContext;\nimport org.slf4j.Logger;\nimport org.slf4j.LoggerFactory;\n\n\/**\n * Logger Utilities.\n *\/\npublic abstract class LoggerUtils {\n\n    private static final Logger logger = LoggerFactory.getLogger(LoggerUtils.class);\n\n    public static void log(String url, Object result) {\n        String message = String\n                .format("The client[%s] uses '%s' protocol to call %s : %s",\n                        RpcContext.getContext().getRemoteHostName(),\n                        RpcContext.getContext().getUrl() == null ? "N\/A"\n                                : RpcContext.getContext().getUrl().getProtocol(),\n                        url, result);\n        if (logger.isInfoEnabled()) {\n            logger.info(message);\n        }\n    }\n\n}<\/code><\/pre>\n
\u4f9d\u8d56\u5f15\u5165<\/h2>\n
<dependencies>\n\n    <!-- Production Ready features -->\n    <dependency>\n        <groupId>org.springframework.boot<\/groupId>\n        <artifactId>spring-boot-starter-actuator<\/artifactId>\n    <\/dependency>\n\n    <dependency>\n        <groupId>org.springframework.boot<\/groupId>\n        <artifactId>spring-boot-starter-web<\/artifactId>\n    <\/dependency>\n\n    <!-- Sample API -->\n    <dependency>\n        <groupId>com.alibaba.cloud<\/groupId>\n        <artifactId>spring-cloud-dubbo-sample-api<\/artifactId>\n        <version>${project.version}<\/version>\n    <\/dependency>\n\n    <!-- Dubbo Spring Cloud Starter -->\n    <dependency>\n        <groupId>com.alibaba.cloud<\/groupId>\n        <artifactId>spring-cloud-starter-dubbo<\/artifactId>\n    <\/dependency>\n\n    <!-- Spring Cloud Nacos Service Discovery -->\n    <dependency>\n        <groupId>com.alibaba.cloud<\/groupId>\n        <artifactId>spring-cloud-starter-alibaba-nacos-discovery<\/artifactId>\n    <\/dependency>\n\n<\/dependencies><\/code><\/pre>\n
\u9879\u76ee\u914d\u7f6e<\/h2>\n
    \n
  • bootstrap.yaml<\/code><\/li>\n<\/ul>\n
    spring:\n  application:\n    name: spring-cloud-alibaba-dubbo-provider\n  main:\n    allow-bean-definition-overriding: true\n  profiles: nacos\n  cloud:\n    nacos:\n      username: test\n      password: test\n      discovery:\n        enabled: true\n        register-enabled: true\n        server-addr: 192.168.1.5:8848\n        context-path: \/nacos\n        ephemeral: false<\/code><\/pre>\n
      \n
    • application.yaml<\/code><\/li>\n<\/ul>\n
      dubbo:\n  scan:\n    base-packages: com.alibaba.cloud.dubbo.service\n  protocols:\n    dubbo:\n      name: dubbo\n      port: -1\n\nfeign:\n  hystrix:\n    enabled: true\n\nserver:\n  port: 8080\n\nmanagement:\n  endpoints:\n    web:\n      exposure:\n        include: dubborestmetadata<\/code><\/pre>\n
      \u670d\u52a1\u5b9e\u73b0<\/h2>\n
      @EnableDiscoveryClient\n@EnableAutoConfiguration\npublic class DubboSpringCloudWebProviderBootstrap {\n\n    public static void main(String[] args) {\n        new SpringApplicationBuilder(DubboSpringCloudWebProviderBootstrap.class)\n                .properties("spring.profiles.active=nacos").run(args);\n    }\n\n}<\/code><\/pre>\n
      import org.apache.dubbo.config.annotation.DubboService;\n\n\/**\n * In-Memory {@link UserService} implementation.\n *\/\n@DubboService(protocol = "dubbo")\npublic class InMemoryUserService implements UserService {\n\n    private Map<Long, User> usersRepository = new HashMap<>();\n\n    @Override\n    public boolean save(User user) {\n        return usersRepository.put(user.getId(), user) == null;\n    }\n\n    @Override\n    public boolean remove(Long userId) {\n        return usersRepository.remove(userId) != null;\n    }\n\n    @Override\n    public Collection<User> findAll() {\n        return usersRepository.values();\n    }\n}<\/code><\/pre>\n
      import org.apache.dubbo.config.annotation.DubboService;\n\nimport org.slf4j.Logger;\nimport org.slf4j.LoggerFactory;\n\nimport org.springframework.http.MediaType;\nimport org.springframework.web.bind.annotation.GetMapping;\nimport org.springframework.web.bind.annotation.PathVariable;\nimport org.springframework.web.bind.annotation.PostMapping;\nimport org.springframework.web.bind.annotation.RequestBody;\nimport org.springframework.web.bind.annotation.RequestHeader;\nimport org.springframework.web.bind.annotation.RequestParam;\nimport org.springframework.web.bind.annotation.RestController;\n\nimport static com.alibaba.cloud.dubbo.util.LoggerUtils.log;\n\n\/**\n * Spring MVC {@link RestService}.\n *\/\n@DubboService(version = "1.0.0")\n@RestController\npublic class SpringRestService implements RestService {\n\n    private Logger logger = LoggerFactory.getLogger(getClass());\n\n    @Override\n    @GetMapping("\/param")\n    public String param(@RequestParam String param) {\n        log("\/param", param);\n        return param;\n    }\n\n    @Override\n    @PostMapping("\/params")\n    public String params(@RequestParam int a, @RequestParam String b) {\n        log("\/params", a + b);\n        return a + b;\n    }\n\n    @Override\n    @GetMapping("\/headers")\n    public String headers(@RequestHeader("h") String header,\n            @RequestHeader("h2") String header2, @RequestParam("v") Integer param) {\n        String result = header + " , " + header2 + " , " + param;\n        log("\/headers", result);\n        return result;\n    }\n\n    @Override\n    @GetMapping("\/path-variables\/{p1}\/{p2}")\n    public String pathVariables(@PathVariable("p1") String path1,\n            @PathVariable("p2") String path2, @RequestParam("v") String param) {\n        String result = path1 + " , " + path2 + " , " + param;\n        log("\/path-variables", result);\n        return result;\n    }\n\n    @Override\n    @PostMapping("\/form")\n    public String form(@RequestParam("f") String form) {\n        return String.valueOf(form);\n    }\n\n    @Override\n    @PostMapping(value = "\/request\/body\/map",\n            produces = MediaType.APPLICATION_JSON_UTF8_VALUE)\n    public User requestBodyMap(@RequestBody Map<String, Object> data,\n            @RequestParam("param") String param) {\n        User user = new User();\n        user.setId(((Integer) data.get("id")).longValue());\n        user.setName((String) data.get("name"));\n        user.setAge((Integer) data.get("age"));\n        log("\/request\/body\/map", param);\n        return user;\n    }\n\n    @PostMapping(value = "\/request\/body\/user",\n            consumes = MediaType.APPLICATION_JSON_UTF8_VALUE)\n    @Override\n    public Map<String, Object> requestBodyUser(@RequestBody User user) {\n        Map<String, Object> map = new HashMap<>();\n        map.put("id", user.getId());\n        map.put("name", user.getName());\n        map.put("age", user.getAge());\n        return map;\n    }\n}<\/code><\/pre>\n","protected":false},"excerpt":{"rendered":"
      \u6ce8\u518c\u4e2d\u5fc3\u91c7\u7528\u963f\u91cc\u5df4\u5df4Nacos \u670d\u52a1\u5bb9\u5668\u4e3aTomcat\uff0c\u7aef\u53e3\u4e3a8080 dubbo\u534f\u8bae\u572820880+n\u7aef\u53e3\u66b4\u9732 […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[196],"tags":[],"class_list":["post-1925","post","type-post","status-publish","format-standard","hentry","category-dubbo"],"_links":{"self":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts\/1925","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/comments?post=1925"}],"version-history":[{"count":0,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts\/1925\/revisions"}],"wp:attachment":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/media?parent=1925"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/categories?post=1925"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/tags?post=1925"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}