{"id":1924,"date":"2023-04-01T09:48:10","date_gmt":"2023-04-01T01:48:10","guid":{"rendered":"https:\/\/www.appblog.cn\/?p=1924"},"modified":"2023-04-22T08:50:25","modified_gmt":"2023-04-22T00:50:25","slug":"dubbo-spring-cloud-service-provider-non-web-application-development-steps","status":"publish","type":"post","link":"https:\/\/www.appblog.cn\/index.php\/2023\/04\/01\/dubbo-spring-cloud-service-provider-non-web-application-development-steps\/","title":{"rendered":"Dubbo Spring Cloud \u670d\u52a1\u63d0\u4f9b\u65b9\uff08\u975eWeb\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\u4e3aNetty<\/code>\uff0c\u7aef\u53e3\u4e3a9090
\ndubbo\u534f\u8bae\u572820880+n<\/code>\u7aef\u53e3\u66b4\u9732\u670d\u52a1\n<\/p><\/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    <!-- Resolve the Dubbo REST RPC issue -->\n    <dependency>\n        <groupId>javax.servlet<\/groupId>\n        <artifactId>javax.servlet-api<\/artifactId>\n        <version>3.1.0<\/version>\n    <\/dependency>\n\n    <!-- Resolve the Spring Cloud registration issue -->\n    <dependency>\n        <groupId>org.springframework<\/groupId>\n        <artifactId>spring-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    <!-- REST support dependencies -->\n    <dependency>\n        <groupId>io.netty<\/groupId>\n        <artifactId>netty-all<\/artifactId>\n    <\/dependency>\n\n    <dependency>\n        <groupId>org.jboss.resteasy<\/groupId>\n        <artifactId>resteasy-jaxrs<\/artifactId>\n    <\/dependency>\n\n    <dependency>\n        <groupId>org.jboss.resteasy<\/groupId>\n        <artifactId>resteasy-client<\/artifactId>\n    <\/dependency>\n\n    <dependency>\n        <groupId>org.jboss.resteasy<\/groupId>\n        <artifactId>resteasy-netty4<\/artifactId>\n    <\/dependency>\n\n    <dependency>\n        <groupId>javax.validation<\/groupId>\n        <artifactId>validation-api<\/artifactId>\n    <\/dependency>\n\n    <dependency>\n        <groupId>org.jboss.resteasy<\/groupId>\n        <artifactId>resteasy-jackson-provider<\/artifactId>\n    <\/dependency>\n\n    <dependency>\n        <groupId>org.jboss.resteasy<\/groupId>\n        <artifactId>resteasy-jaxb-provider<\/artifactId>\n    <\/dependency>\n\n    <dependency>\n        <groupId>org.hibernate.validator<\/groupId>\n        <artifactId>hibernate-validator<\/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    rest:\n      name: rest\n      port: 9090\n      server: netty\nfeign:\n  hystrix:\n    enabled: true<\/code><\/pre>\n
      \u670d\u52a1\u5b9e\u73b0<\/h2>\n
      @EnableDiscoveryClient\n@EnableAutoConfiguration\npublic class DubboSpringCloudProviderBootstrap {\n\n    public static void main(String[] args) {\n        new SpringApplicationBuilder(DubboSpringCloudProviderBootstrap.class)\n                .properties("spring.profiles.active=nacos").web(WebApplicationType.NONE)\n                .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 javax.ws.rs.Consumes;\nimport javax.ws.rs.FormParam;\nimport javax.ws.rs.GET;\nimport javax.ws.rs.HeaderParam;\nimport javax.ws.rs.POST;\nimport javax.ws.rs.Path;\nimport javax.ws.rs.PathParam;\nimport javax.ws.rs.Produces;\nimport javax.ws.rs.QueryParam;\nimport javax.ws.rs.core.MediaType;\n\nimport org.apache.dubbo.config.annotation.DubboService;\n\nimport org.slf4j.Logger;\nimport org.slf4j.LoggerFactory;\n\nimport static com.alibaba.cloud.dubbo.util.LoggerUtils.log;\nimport static org.springframework.util.MimeTypeUtils.APPLICATION_JSON_VALUE;\n\n\/**\n * Default {@link RestService}.\n *\/\n@DubboService(version = "1.0.0", protocol = { "dubbo", "rest" })\n@Path("\/")\npublic class StandardRestService implements RestService {\n\n    private Logger logger = LoggerFactory.getLogger(getClass());\n\n    @Override\n    @Path("param")\n    @GET\n    public String param(@QueryParam("param") String param) {\n        log("\/param", param);\n        return param;\n    }\n\n    @Override\n    @Path("params")\n    @POST\n    public String params(@QueryParam("a") int a, @QueryParam("b") String b) {\n        log("\/params", a + b);\n        return a + b;\n    }\n\n    @Override\n    @Path("headers")\n    @GET\n    public String headers(@HeaderParam("h") String header,\n            @HeaderParam("h2") String header2, @QueryParam("v") Integer param) {\n        String result = header + " , " + header2 + " , " + param;\n        log("\/headers", result);\n        return result;\n    }\n\n    @Override\n    @Path("path-variables\/{p1}\/{p2}")\n    @GET\n    public String pathVariables(@PathParam("p1") String path1,\n            @PathParam("p2") String path2, @QueryParam("v") String param) {\n        String result = path1 + " , " + path2 + " , " + param;\n        log("\/path-variables", result);\n        return result;\n    }\n\n    \/\/ @CookieParam does not support : https:\/\/github.com\/OpenFeign\/feign\/issues\/913\n    \/\/ @CookieValue also does not support\n\n    @Override\n    @Path("form")\n    @POST\n    public String form(@FormParam("f") String form) {\n        return String.valueOf(form);\n    }\n\n    @Override\n    @Path("request\/body\/map")\n    @POST\n    @Produces(APPLICATION_JSON_VALUE)\n    public User requestBodyMap(Map<String, Object> data,\n            @QueryParam("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    @Path("request\/body\/user")\n    @POST\n    @Override\n    @Consumes(MediaType.APPLICATION_JSON)\n    public Map<String, Object> requestBodyUser(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\u4e3aNetty\uff0c\u7aef\u53e3\u4e3a9090 dubbo\u534f\u8bae\u572820880+n\u7aef\u53e3\u66b4\u9732\u670d […]<\/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-1924","post","type-post","status-publish","format-standard","hentry","category-dubbo"],"_links":{"self":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts\/1924","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=1924"}],"version-history":[{"count":0,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts\/1924\/revisions"}],"wp:attachment":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/media?parent=1924"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/categories?post=1924"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/tags?post=1924"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}