程序员经验分享-hwhale

(三)springcloud之Consul注册服务与发现

2023-11-06

此文主要记录springcloud的zookeeper的注册与发现，没有过多解释，只是为了提供后期拷贝使用
主要模块分为：
0.父工程模块:主要用来作为版本管理
1.公共模块Common-API：用来封装其他模块的共同的功能，比如bean类，共同的异常处理等
2.服务提供者：ConsulClientProvider8001,ConsulClientProvider8002
3.服务消费者：ConsulClientConsumer80
具体配置如下：

父工程（只有pom.xml）

参照springcloud之Zookeeper注册服务与发现

公共模块Common-API

参照springcloud之Zookeeper注册服务与发现

服务提供者ConsulClientProvider8001

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">
    <parent>
        <artifactId>springcloud</artifactId>
        <groupId>com.qwy</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>ConsulClientProvider8001</artifactId>
    <dependencies>
        <!--SpringCloud consul-server -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-consul-discovery</artifactId>
        </dependency>
        <!-- SpringBoot整合Web组件 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!--自己的jar-->
        <dependency>
            <groupId>com.qwy</groupId>
            <artifactId>Common-API</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>1.1.10</version>
        </dependency>
        <!--mysql-connector-java-->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>
        <!--jdbc-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>
        <!--热部署依赖-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

</project>

application.yml

 server:
  port: 8001
spring:
  application:
    name: consul-client-provider
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    driver-class-name: org.gjt.mm.mysql.Driver
    url: jdbc:mysql://localhost:3306/mydb
    username: root
    password: admin

  cloud:
    consul:
      host: localhost
      port: 8500
      discovery:
        service-name: ${spring.application.name}

主启动类

package com.qwy;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

/**
 * @Author：齐
 * @Package：com.qwy
 * @Project：springcloud1
 * @name：ConsulClientProvider8001
 * @Date：2022/12/12 16:27
 * @Filename：ConsulClientProvider8001
 */
@SpringBootApplication
@EnableDiscoveryClient
public class ConsulClientProvider8001 {
    public static void main(String[] args) {
        SpringApplication.run(ConsulClientProvider8001.class,args);
    }
}

mapper代理接口

参照springcloud之Zookeeper注册服务与发现

服务接口

参照springcloud之Zookeeper注册服务与发现

服务实现类

参照springcloud之Zookeeper注册服务与发现

业务控制器

参照springcloud之Zookeeper注册服务与发现

服务提供者ConsulClientProvider8002

参照服务提供者ConsulClientProvider8001

服务消费者ConsulClientConsumer80

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">
    <parent>
        <artifactId>springcloud</artifactId>
        <groupId>com.qwy</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>EurekaClientConsumer80</artifactId>
    <dependencies>
    <!--eureka-client-->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>
    <!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
    <dependency>
        <groupId>com.qwy</groupId>
        <artifactId>Common-API</artifactId>
        <version>1.0-SNAPSHOT</version>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>
    <dependency>
        <groupId>org.mybatis.spring.boot</groupId>
        <artifactId>mybatis-spring-boot-starter</artifactId>
    </dependency>
    <dependency>
        <groupId>com.baomidou</groupId>
        <artifactId>mybatis-plus-boot-starter</artifactId>
    </dependency>
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>druid-spring-boot-starter</artifactId>
        <version>1.1.10</version>
    </dependency>
    <!--mysql-connector-java-->
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
    </dependency>
    <!--jdbc-->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-jdbc</artifactId>
    </dependency>
    <!--热部署依赖-->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-devtools</artifactId>
        <scope>runtime</scope>
        <optional>true</optional>
    </dependency>
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <optional>true</optional>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>2.0.20</version>
        </dependency>
    </dependencies>
</project>

application.yml

server:
  port: 80

spring:
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    driver-class-name: org.gjt.mm.mysql.Driver
    url: jdbc:mysql://localhost:3306/mydb2
    username: root
    password: admin

  application:
    name: consul-client-consumer
  cloud:
    consul:
      host: localhost
      port: 8500
      discovery:
        service-name: ${spring.application.name}

主启动类

package com.qwy;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

/**
 * @Author：齐
 * @Package：com.qwy
 * @Project：springcloud1
 * @name：EurekaClientConsumer80
 * @Date：2022/12/11 3:50
 * @Filename：EurekaClientConsumer80
 */
@SpringBootApplication
@EnableEurekaClient
public class EurekaClientConsumer80 {
    public static void main(String[] args) {
        SpringApplication.run(EurekaClientConsumer80.class,args);
    }
}

mapper代理接口

参照springcloud之Zookeeper注册服务与发现

服务接口

参照springcloud之Zookeeper注册服务与发现

服务实现类

参照springcloud之Zookeeper注册服务与发现

spring的配置类

 package com.qwy.config;

import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;

/**
 * @Author：齐文勇
 * @Package：com.qwy.config
 * @Project：springcloud1
 * @name：ApplicationConfig
 * @Date：2022/12/11 4:04
 * @Filename：ApplicationConfig
 */
@Configuration
public class ApplicationConfig {
    @Bean
    @LoadBalanced
    public RestTemplate restTemplate(){
        return  new RestTemplate();
    }
}

业务控制器

package com.qwy.controller;

import com.alibaba.fastjson2.JSONObject;
import com.qwy.bean.*;
import com.qwy.service.OrdersService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.client.RestTemplate;

/**
 * @Author：齐文勇
 * @Package：com.qwy.controller
 * @Project：springcloud1
 * @name：OrderController
 * @Date：2022/12/11 4:15
 * @Filename：OrderController
 */
@RestController
@RequestMapping("/orders")
public class OrderController {
    private final String CLIENT_PROVIDER_URL="http://consul-client-provider";
    @Autowired
    private OrdersService ordersService;
    @Autowired
    private RestTemplate restTemplate;
    @PostMapping
    public CommonResult save(@RequestBody Orders orders){
        boolean save = ordersService.save(orders);
        return  new CommonResult(save? Code.SAVE_OK:Code.SAVE_ERR,save);
    }
    @GetMapping("/{id}")
    public CommonResult findOrderAndUserById(@PathVariable("id") Long id){

        Orders orders = ordersService.findById(id);
        Long usersId = orders.getUsersId();

        CommonResult commonResult = restTemplate.getForObject(CLIENT_PROVIDER_URL + "/users/" + usersId, CommonResult.class, usersId);

        String josn = JSONObject.toJSONString(commonResult.getData());
        Users users = JSONObject.parseObject(josn, Users.class);
        ExtendsOrders extendsOrders= new ExtendsOrders();
       extendsOrders.setUsers(users);
        extendsOrders.setCreateTime(orders.getCreateTime());
        extendsOrders.setId(orders.getId());
        extendsOrders.setName(orders.getName());
        Integer code = orders != null ? Code.SELECT_OK : Code.SELECT_ERR;
        String message = orders != null ? "" : "查询失败";
        return  new CommonResult(code,extendsOrders,message);
    }
}
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

springCloud

springboot

spring cloud

javaconsul

Consul

(三)springcloud之Consul注册服务与发现 的相关文章

随机推荐

  • 开源物联网平台ThingsBoard的安装

    ThingsBoard是一个开源平台 功能强大 性能稳定 用于收集和可视化物联网设备的数据 可以将来自任意数量设备的数据发送到云服务器 在云服务器中可以通过可自定义的仪表板查看或共享 ThingsBoard相关概念 租户tenant 拥有或

  • SQLi-Labs 学习笔记（Less 51-65）

    点击打开链接 Less 51 本关的Sql语句为 plain view plain copy sql SELECT FROM users ORDER BY id 因为此处用的是执行多个针对数据库的查询函数 mysqli multi quer

  • Linux——（第四章）关机、重启和用户登录注销

    目录 1 关机 重启命令 2 用户的登录和注销 1 关机 重启命令 一般情况很少遇到服务器关机操作 基本语法 sync 将数据由内存同步到硬盘中 该命令在重启和关机前执行 halt 立刻关机 关闭系统 但不断电 poweroff 关机 断电

  • Windows的AppData 文件夹

    文章目录 前言 AppData 文件夹是什么 如何查看 AppData 文件夹 AppData 文件夹的应用 有些软件为什么安装到AppData而不是Program Files AppData文件可以删除吗 可以删除的文件 其他常识文件 前

  • 知乎广告效果怎么样？有哪些优势呢？

    随着移动互联网的不断发展 在当下流量越来越贵的背景下 知乎平台以其独特的优势 特别失在内容营销方面独树一帜 相比较其它平台有着明显的优势 主要体现在 1 转化率高 因为知乎作为国内领先的互动问答平台 很多用户是因为有问题 上知乎找解决方案的

  • web 前后台数据交互的方式

    做web开发 很重要的一个环节就是前后台的数据的交互 数据从页面提交到contoller层 数据从controler层传送到jsp页面来显示 这2个过程中数据具体是如何来传送的 是本节讲解的内容 首先说一下数据如何从后台的contorlle

  • ubuntu22.04.1设置root登陆

    一 设置root密码 sudo passwd root 输入自己的超级用户密码 设置root账户密码 二 设置系统登陆界面 1 su root 2 gedit etc pam d gdm autologin 在弹出窗口中找到 auth re

  • numpy.argsort()函数参数以及案例问题

    参考博客网址是 numpy argsort函数 summer2day的博客 CSDN博客 argsort函数numpy argsort a axis 1 kind quicksort order None 返回的是数组值从小到大的索引值 参

  • JAVA获取部门人员树

    直接上代码 无需多言 主要还是递归 实体类 Data ApiModel NoArgsConstructor public class TreeDept implements Serializable type 0 表示是部门 type 1

  • 一个好用的在线RSS阅读器

    最近用国外IP访问有道阅读貌似有问题 于是找了一些替代品尝试 http reader aol com 这个和Google Reader最相似 不过导入有道阅读的OPML总是不成功 http www inoreader com 这个也相当好

  • Debian 10 安装网络yum源

    Debian 10 安装网络yum源 实验环境一台最小化Debian10 IP地址是192 168 10 1 24 还需要一张外网的网卡 配置网络 vim etc network interfaces 编辑网络配置文件 auto ens37

  • Python提取评论（使用pycharm+Python）

    一 安装调用所要用到的库函数 import requests from bs4 import BeautifulSoup 二 自定义根据每页影评的url爬取影评的方法 1 请求url def getData url 三 请求头为字典格式 h

  • java图片转base64注意事项

    java转base64有两点需要注意的地方 在window操作系统中 图片转换为base64 在base64的字符串中会有默认换行 这就破坏了json格式 所以这里需要做一下处理 除此之外 在java转base64时 会缺少base64字符

  • torch.cat的参数dim到底是在哪个维度拼接

    如果将两个维度为 n c h w 进行拼接 如果指定dim为以下值 dim 0 拼接后维度为 2n c h w dim 1 拼接后维度为 n 2c h w dim 2 拼接后维度为 n c 2h w dim 3 拼接后维度为 n c h 2

  • C#常见变量类型和使用规则

    C 常见变量类型和使用规则 常见变量类型 C 中值类型的变量主要包括整数类型 浮点类型 金钱 decimal 类型和布尔 bool 类型等 1 整数类型 int 范围 2 147 483 648 2 147 483 647 大小 32位有符

  • 合宙Air001点灯+闪烁（寄存器版）

    观前提醒 只是我学单片机的一个简单记录 会比较啰嗦 但是我在研究单片机寄存器过程中真实的心得体会 希望能帮到读者 打完电赛觉得自己的单片机白学了 于是想从寄存器从头开始学一遍单片机 刚好前段时间发现合宙AIR001这款单片机 外设较少且相对

  • QT之TCP网络传输系列 - 目录

    最近被大boss安排做纯软件开发项目 囧 本来我硕士方向是 传统机器学习特征提取 这一部分 读博近两年主要做 以深度学习为基础的视频分析 相关研究 我一个搞算法的去做软件开发 都是泪啊 但为了毕业 给啥任务都能 得 完成 o o 以下整理一

  • 热门去水印小助手小程序独立安装版+前端免费分享

    热门去水印小助手小程序独立安装版来自网络资源 请自测 该源码是本人在外面找回来 大家可以测试自用下 看看有什么瑰丽 去水印的也是比较火的 现在各大平台 搬运视频 大家都需要的 但是给大家一个建议 这个网上分享的共享开源源码 一般是有限制的

  • Python连接hive数据中遇到的各种坑

    这里选择的是使用 impala Python3 6来连接hive数据库 第一步要先在服务器开启hiveserver2 服务 不然会连不上的 报如下错误 开启方法很简单 到hive安装目录的bin目录下 your path apache hi

  • (三)springcloud之Consul注册服务与发现

    此文主要记录springcloud的zookeeper的注册与发现 没有过多解释 只是为了提供后期拷贝使用 主要模块分为 0 父工程模块 主要用来作为版本管理 1 公共模块Common API 用来封装其他模块的共同的功能 比如bean类

热门标签