0
点赞
收藏
分享

微信扫一扫

dubbo直连案例（提供者+消费者+接口工程，官方推荐使用）

sullay 2022-05-02 阅读 82
javarpcspringDUbbo

dubbo直连案例（提供者+消费者+接口工程，官方推荐使用）

1.项目结构图

在这里插入图片描述

2.接口工程

1.pom.xml

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.yl</groupId>
    <artifactId>link-interface</artifactId>
    <version>1.0-SNAPSHOT</version>


</project>

2.model

package com.yl.model;

import java.io.Serializable;

public class User implements Serializable {

    private Integer id;

    private String username;

    private String password;

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getUsername() {
        return username;
    }

    public void setUsername(String username) {
        this.username = username;
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }
}

3.interface

package com.yl.service;

import com.yl.model.User;

public interface UserService {

    User getUserById(Integer id);
}

3.提供者

1.pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<!--
  Licensed to the Apache Software Foundation (ASF) under one
  or more contributor license agreements.  See the NOTICE file
  distributed with this work for additional information
  regarding copyright ownership.  The ASF licenses this file
  to you under the Apache License, Version 2.0 (the
  "License"); you may not use this file except in compliance
  with the License.  You may obtain a copy of the License at

   http://www.apache.org/licenses/LICENSE-2.0

  Unless required by applicable law or agreed to in writing,
  software distributed under the License is distributed on an
  "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
  KIND, either express or implied.  See the License for the
  specific language governing permissions and limitations
  under the License.
-->
<!-- $Id: pom.xml 642118 2008-03-28 08:04:16Z reinhard $ -->
<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/maven-v4_0_0.xsd">

  <modelVersion>4.0.0</modelVersion>
  <packaging>war</packaging>

  <name>link-provider</name>
  <groupId>com.yl</groupId>
  <artifactId>link-provider</artifactId>
  <version>1.0-SNAPSHOT</version>

  <dependencies>
    <!--dubbo依赖-->
    <dependency>
      <groupId>com.alibaba</groupId>
      <artifactId>dubbo</artifactId>
      <version>2.6.0</version>
    </dependency>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-context</artifactId>
      <version>4.3.16.RELEASE</version>
    </dependency>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-webmvc</artifactId>
      <version>4.3.16.RELEASE</version>
    </dependency>
    <!--先install服务提供者到本地仓库，再使用其依赖-->
    <dependency>
      <groupId>com.yl</groupId>
      <artifactId>link-interface</artifactId>
      <version>1.0-SNAPSHOT</version>
    </dependency>
  </dependencies>

</project>

2.interface的实现类

package com.yl.service.impl;

import com.yl.model.User;
import com.yl.service.UserService;

public class UserServiceImpl implements UserService {
    @Override
    public User getUserById(Integer id) {
        User user = new User();
        user.setId(id);
        user.setUsername("root");
        user.setPassword("123");
        return user;
    }
}

3.dubbo的配置

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

    <!--声明提供者的名称，必须唯一-->
    <dubbo:application name="link-provider"/>

    <!--指定dubbo的协议和端口号-->
    <dubbo:protocol name="dubbo" port="20880"/>

    <!--暴露服务
        使用dubbo:service来暴露服务
        interface 要暴露的服务的接口全限定类名
        ref 引用接口在spring容器中的标识值
        registry    使用直连方式的话，值为N/A
    -->
    <dubbo:service interface="com.yl.service.UserService" ref="userServiceImpl" registry="N/A"/>

    <!--加载接口实现类-->
    <bean id="userServiceImpl" class="com.yl.service.impl.UserServiceImpl"/>
</beans>

4.web.xml

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_4_0.xsd"
         version="4.0">

  <!--spring的监听器配置-->
  <context-param>
    <param-name>contextConfigLocation</param-name>
    <param-value>classpath:dubbo-provider.xml</param-value>
  </context-param>
  <listener>
    <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
  </listener>

</web-app>

4.消费者

1.pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<!--
  Licensed to the Apache Software Foundation (ASF) under one
  or more contributor license agreements.  See the NOTICE file
  distributed with this work for additional information
  regarding copyright ownership.  The ASF licenses this file
  to you under the Apache License, Version 2.0 (the
  "License"); you may not use this file except in compliance
  with the License.  You may obtain a copy of the License at

   http://www.apache.org/licenses/LICENSE-2.0

  Unless required by applicable law or agreed to in writing,
  software distributed under the License is distributed on an
  "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
  KIND, either express or implied.  See the License for the
  specific language governing permissions and limitations
  under the License.
-->
<!-- $Id: pom.xml 642118 2008-03-28 08:04:16Z reinhard $ -->
<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/maven-v4_0_0.xsd">

  <modelVersion>4.0.0</modelVersion>
  <packaging>war</packaging>

  <name>link-consumer</name>
  <groupId>com.yl</groupId>
  <artifactId>link-consumer</artifactId>
  <version>1.0-SNAPSHOT</version>
  <dependencies>
    <!--dubbo依赖-->
    <dependency>
      <groupId>com.alibaba</groupId>
      <artifactId>dubbo</artifactId>
      <version>2.6.0</version>
    </dependency>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-context</artifactId>
      <version>4.3.16.RELEASE</version>
    </dependency>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-webmvc</artifactId>
      <version>4.3.16.RELEASE</version>
    </dependency>
    <!--先install服务提供者到本地仓库，再使用其依赖-->
    <dependency>
      <groupId>com.yl</groupId>
      <artifactId>link-interface</artifactId>
      <version>1.0-SNAPSHOT</version>
    </dependency>
  </dependencies>

</project>

2.controller

package com.yl.controller;

import com.yl.model.User;
import com.yl.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.GetMapping;

@Controller
public class UserController {

    @Autowired
    private UserService userService;

    @GetMapping("/getUserById")
    public String getUserById(Model model,Integer id) {
        User user = userService.getUserById(id);
        //调用远程服务接口
        model.addAttribute("user",user);
        return "user";
    }
}

3.dubbo的配置

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

    <!--声明消费者名称，唯一-->
    <dubbo:application name="link-consumer"/>

    <!--引用远程接口
        id 引用远程接口服务的代理对象名称
        interface 接口都全限定类名
        url 调用远程服务接口的地址
        registry 直连方式，暂时不用注册中心
    -->
    <dubbo:reference id = "userService" interface="com.yl.service.UserService"
                     url = "dubbo://localhost:20880" registry="N/A"/>
</beans>

4.springmvc的配置

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:mvc="http://www.springframework.org/schema/mvc"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/mvc
        https://www.springframework.org/schema/mvc/spring-mvc.xsd
        http://www.springframework.org/schema/context
        http://www.springframework.org/schema/context/spring-context-4.3.xsd">

    <!--扫描组件-->
    <context:component-scan base-package="com.yl.controller" />
    <!--注解驱动-->
    <mvc:annotation-driven/>
    <!--配置视图解析器-->
    <bean class="org.springframework.web.servlet.view.InternalResourceViewResolver">
        <property name="prefix" value="/"/>
        <property name="suffix" value=".jsp"/>
    </bean>
</beans>

5.user.jsp文件

<%--
  Created by IntelliJ IDEA.
  User: mirror
  Date: 2022/5/1
  Time: 22:27
  To change this template use File | Settings | File Templates.
--%>
<%@ page contentType="text/html;charset=UTF-8" language="java" %>
<html>
<head>
    <title>Title</title>
</head>
<body>
<table>
    <tr>
        <td>用户id</td>
        <td>${user.id}</td>
    </tr>
    <tr>
        <td>用户名</td>
        <td>${user.username}</td>
    </tr>
    <tr>
        <td>密码</td>
        <td>${user.password}</td>
    </tr>
</table>
</body>
</html>

5.测试

1.启动提供者和消费者
2.访问getUserById接口
在这里插入图片描述

举报

相关推荐

dubbo服务既是服务提供者也是服务消费者

rpczookeeperjava

Rest环境搭建：服务提供者和消费者---SpringCloud

springjavaspring bootidexml

微服务概念篇-服务提供者/服务消费者

大数据

Eureka注册中心、服务提供者和服务消费者

eureka微服务spring cloud

Kafka消费者使用案例

ubuntulinux

Dubbo服务提供者几种启动方式

操作系统javaxmlidespringStorm大数据

生产者和消费者案例

同步锁java同步方法Html/CSS前端开发

Dubbo高手之路4，Dubbo服务提供者详解

服务提供者线程模型HTTPJava后端开发

Spring Cloud Rest的环境搭建详解【服务提供者和服务消费者】

springxmlJavaspring boot后端开发私藏项目实操分享

Java 生产者消费者案例

java
0 条评论