• 第二章、dubbo 框架（直连方式 dubbo）

    2.5 直连方式 dubbo
            点对点的直连项目 : 消费者直接访问服务提供者，没有注册中心。消费者必须指定服务提供者的访问地址（ url ）。
            消费者直接通过 url 地址访问固定的服务提供者。这个 url 地址是不变的。

    2.5.1 实现目标

    （1） 创建服务提供者：

    A 、新建 空工程java project
    创建archety-webapp的model
    项目名称： 001-link-userservice-provider
    设置 version 为 1.0.0
    项目结构

     

    B 、 maven pom.xml 
    2.  
    3. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4.   xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    5.   <modelVersion>4.0.0modelVersion>
    6.  
    7.   <groupId>com.it.dubbogroupId>
    8.   <artifactId>001-link-userservice-providerartifactId>
    9.   <version>1.0.0version>
    10.   <packaging>warpackaging>
    11.  
    12.   <dependencies>
    14.     <dependency>
    15.       <groupId>org.springframeworkgroupId>
    16.       <artifactId>spring-contextartifactId>
    17.       <version>4.3.16.RELEASEversion>
    18.     dependency>
    19.     <dependency>
    20.       <groupId>org.springframeworkgroupId>
    21.       <artifactId>spring-webmvcartifactId>
    22.         <version>4.3.16.RELEASEversion>
    23.     dependency>
    24.       
    25.       <dependency>
    26.           <groupId>com.alibabagroupId>
    27.           <artifactId>dubboartifactId>
    28.           <version>2.6.2version>
    29.       dependency>
    30.   dependencies>
    31.  
    32. <build>
    33.     <plugins>
    34.         
    35.         <plugin>
    36.             <artifactId>maven-compiler-pluginartifactId>
    37.             <version>3.1version>
    38.             <configuration>
    39.                 <source>1.8source>
    40.                 <target>1.8target>
    41.             configuration>
    42.         plugin>
    43.     plugins>
    44. build>
    45.  
    46.  
    47. project>
    C 、 创建订单实体类：User 
    1. package com.it.dubbo.entity;
    2.  
    3. import java.io.Serializable;
    4.  
    5. public class User implements Serializable {
    6.     private Integer id;
    7.     private String name;
    8.     private Integer age;
    9.  
    10.     public Integer getId() {
    11.         return id;
    12.     }
    13.  
    14.     public void setId(Integer id) {
    15.         this.id = id;
    16.     }
    17.  
    18.     public String getName() {
    19.         return name;
    20.     }
    21.  
    22.     public void setName(String name) {
    23.         this.name = name;
    24.     }
    25.  
    26.     public Integer getAge() {
    27.         return age;
    28.     }
    29.  
    30.     public void setAge(Integer age) {
    31.         this.age = age;
    32.     }
    33.  
    34.     @Override
    35.     public String toString() {
    36.         return "User{" +
    37.                 "id=" + id +
    38.                 ", name='" + name + '\'' +
    39.                 ", age=" + age +
    40.                 '}';
    41.     }
    42. }
    D 、新建订单服务接口： UserService 
    1. package com.it.dubbo.service;
    2.  
    3. import com.it.dubbo.entity.User;
    4.  
    5. public interface UserService {
    6.     //根据用户标识获取用户信息
    7.     User queryUserById(Integer id);
    8. }
    E 、 新建接口的实现类： UserServiceImpl 
    1. package com.it.dubbo.service.impl;
    2.  
    3. import com.it.dubbo.entity.User;
    4. import com.it.dubbo.service.UserService;
    5.  
    6. public class UserServiceImpl implements UserService {
    7.  
    8.     @Override
    9.     public User queryUserById(Integer id) {
    10.         User user=new User();
    11.         user.setId(id);
    12.         user.setName("小明");
    13.         user.setAge(19);
    14.         return user;
    15.     }
    16. }
    F 、 创建 dubbo 配置文件
    dubbo-userservice-provider.xml 
    2. <beans xmlns="http://www.springframework.org/schema/beans"
    3.        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
    4.        xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
    5.  
    7.     <dubbo:application name="001-link-userservice-provider"/>
    8.     
    9.     
    10.     <dubbo:protocol name="dubbo" port="20880"/>
    11.     
    12.     <dubbo:service interface="com.it.dubbo.service.UserService" ref="userService" registry="N/A"/>
    13.     
    14.     <bean id="userService" class="com.it.dubbo.service.impl.UserServiceImpl"/>
    15.  
    16. beans>
    F 、 创建 web.xml文件 
    2. <web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee"
    3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4.          xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_4_0.xsd"
    5.          version="4.0">
    6.     <context-param>
    7.         <param-name>contextConfigLocationparam-name>
    8.         <param-value>classpath:dubbo-userservice-provider.xmlparam-value>
    9.     context-param>
    10.     <listener>
    11.         <listener-class>org.springframework.web.context.ContextLoaderListenerlistener-class>
    12.     listener>
    13. web-app>

    G 、安装本地 jar 到 maven 仓库
    服务接口中的方法要给消费者使用，消费者项目需要知道接口名称和接口中的方法名称、参
    数等。这些信息服务提供者才知道。需要把接口的 class 文件打包为 jar .
    服务接口项目的类文件打包为 jar ， 安装到 maven 仓库，仓库中的提供者 jar 可以被消费者
    使用。
    使用 idea 的 maven 窗口执行 install
    本机打包到maven仓库的地址
    D:\jsp\Maven\MavenTest\repository\com\it\dubbo\001-link-userservice-provider

    （2） 创建服务消费者

    A、新建archet-webapp的model

    002-link-consumer

     B、 maven pom.xml

    2.  
    3. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4.   xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    5.   <modelVersion>4.0.0modelVersion>
    6.  
    7.   <groupId>com.it.dubbogroupId>
    8.   <artifactId>002-link-comsumerartifactId>
    9.   <version>1.0.0version>
    10.   <packaging>warpackaging>
    11.  
    12.   <dependencies>
    13.     
    14.     <dependency>
    15.       <groupId>org.springframeworkgroupId>
    16.       <artifactId>spring-contextartifactId>
    17.       <version>4.3.16.RELEASEversion>
    18.     dependency>
    19.     <dependency>
    20.       <groupId>org.springframeworkgroupId>
    21.       <artifactId>spring-webmvcartifactId>
    22.       <version>4.3.16.RELEASEversion>
    23.     dependency>
    24.     
    25.     <dependency>
    26.       <groupId>com.alibabagroupId>
    27.       <artifactId>dubboartifactId>
    28.       <version>2.6.2version>
    29.     dependency>
    30.     
    31.     <dependency>
    32.       <groupId>com.it.dubbogroupId>
    33.       <artifactId>001-link-userservice-providerartifactId>
    34.       <version>1.0.0version>
    35.     dependency>
    36.   dependencies>
    37.  
    38. <build>
    39.   <plugins>
    40.     <plugin>
    41.       <artifactId>maven-compiler-pluginartifactId>
    42.       <version>3.1version>
    43.       <configuration>
    44.         <source>1.8source>
    45.         <target>1.8target>
    46.       configuration>
    47.     plugin>
    48.   plugins>
    49. build>
    50.  
    51. project>
    C 、 创建控制层UserController 
    1. package com.it.dubbo.web;
    2.  
    3. import com.it.dubbo.entity.User;
    4. import com.it.dubbo.service.UserService;
    5. import org.springframework.beans.factory.annotation.Autowired;
    6. import org.springframework.stereotype.Controller;
    7. import org.springframework.ui.Model;
    8. import org.springframework.web.bind.annotation.RequestMapping;
    9.  
    10. @Controller
    11. public class UserController {
    12.  
    13.     @Autowired
    14.     private UserService userService;
    15.  
    16.     @RequestMapping(value = "/user")
    17.     public String userDetail(Model model,Integer id){
    18.         User user = userService.queryUserById(id);
    19.         model.addAttribute("user",user);
    20.         return "userDetail";
    21.     }
    22. }
    D 、 创建 dubbo 配置文件
    link-consumer.xml 
    2. <beans xmlns="http://www.springframework.org/schema/beans"
    3.        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
    4.        xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
    5.  
    6.     
    7.     <dubbo:application name="002-link-consumer"/>
    8.  
    9.     
    10.     <dubbo:reference id="userService" interface="com.it.dubbo.service.UserService"
    11.                      url="dubbo://localhost:20880" registry="N/A"/>
    12.  
    13. beans>
    application.xml 
    2. <beans xmlns="http://www.springframework.org/schema/beans"
    3.        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4.        xmlns:context="http://www.springframework.org/schema/context"
    5.        xmlns:mvc="http://www.springframework.org/schema/mvc"
    6.        xsi:schemaLocation="http://www.springframework.org/schema/beans
    7.        http://www.springframework.org/schema/beans/spring-beans.xsd
    8.         http://www.springframework.org/schema/context
    9.          http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd">
    10.  
    11.     
    12.     <context:component-scan base-package="com.it.dubbo.web"/>
    13.     
    14.     <mvc:annotation-driven/>
    15.     
    16.     <bean class="org.springframework.web.servlet.view.InternalResourceViewResolver">
    17.         <property name="prefix" value="/"/>
    18.         <property name="suffix" value=".jsp"/>
    19.     bean>
    20.  
    21.  
    22. beans>

    E、 创建web.xml文件

    2. <web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee"
    3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4.          xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_4_0.xsd"
    5.          version="4.0">
    6.     <servlet>
    7.         <servlet-name>dispatcherServletservlet-name>
    8.         <servlet-class>org.springframework.web.servlet.DispatcherServletservlet-class>
    9.         <init-param>
    10.             <param-name>contextConfigLocationparam-name>
    11.             <param-value>classpath:application.xml,classpath:link-consumer.xmlparam-value>
    12.         init-param>
    13.     servlet>
    14.     <servlet-mapping>
    15.         <servlet-name>dispatcherServletservlet-name>
    16.         <url-pattern>/url-pattern>
    17.     servlet-mapping>
    18. web-app>

    F、 创建jsp页面

    1.  
    2. <%@ page contentType="text/html;charset=UTF-8" language="java" %>
    3. <html>
    4. <head>
    5.     <title>用户详情title>
    6. head>
    7. <body>
    8. body>
    9. <h1>用户详情h1>
    10. <div>用户标识：${user.id}div>
    11. <div>用户名称：${user.name}div>
    12. <div>用户年龄：${user.age}div>
    13. html>

    给两个model配置两个tomcat，端口号不能相同

     

     

     

     运行结果

     

  • 相关阅读:
    深度学习-消融实验
    前端面试题集锦（2）
    基于SSM的车辆维修管理系统
    [附源码]JAVA毕业设计课程网站设计（系统+LW）
    【黑马程序员】Python文件、异常、模块、包
    请小心ETCD的Compact
    Apipost - 自动化测试
    JAVA如何保留小数点后两位
    ApplicationListener和@EventListener
    电饭锅的用例图UML
  • 原文地址：https://blog.csdn.net/weixin_59334478/article/details/126266948