如何从eureka获取服务的ip和端口号进行Http的调用

目录
  • eureka获取服务ip和端口号进行Http调用
  • eureka页面中显示ip+端口

eureka获取服务ip和端口号进行Http调用

我告诉你们为啥我要先从eureka首先获取 goods的服务ip, 在用ip的方式使用http调用goods的服务.

因为公司的规定, 不让我们用Feigin. 我TMD的都震惊了, 我都不知道为啥. 我也不想写同事的ip地址, 做配置, 因为都去eureka里面注册了, 所以就这样调用了, 真是蛋疼.  这种微服务, 这种奇葩的方式..

package com.util; 
import com.alibaba.fastjson.JSON;
import com.curefun.attendance.appclient.vo.ApplyListVO;
import lombok.extern.slf4j.Slf4j;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
import org.apache.commons.lang3.StringUtils;
 
import java.io.IOException;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.TimeUnit;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
 
/**
 * eureka的工具类
 *
 * @author zhangke
 * @time 2019年12月5日18:11:12
 */
@Slf4j
public class EurekaUtil {
 
    /**
     * 解析eureka的返回数据
     */
    private static Pattern PATTERN_URL = Pattern.compile("<homePageUrl>(.+?)</homePageUrl>");
 
    /**
     * IP的缓存
     */
    private static ConcurrentHashMap<String, List<String>> IP_CACHE = new ConcurrentHashMap<>();
 
    /**
     * 缓存的名字
     */
    private final static String IP_NAME = "goodsIp"; 
 
    /**
     * 获取服务的所有地址(注册在 eureka server 上的服务)
     *
     * @param eurekaIp
     * @return
     */
    public static List<String> getAllServiceAddr(String eurekaIp) {
        //先查询缓存
        List<String> list = IP_CACHE.get(IP_NAME);
        if (list != null && list.size() > 0) {
            return list;
        }
        String serviceName = "GOODS";
        String url = eurekaIp + "apps/" + serviceName;
        OkHttpClient okHttpClient = new OkHttpClient().newBuilder().connectTimeout(2, TimeUnit.SECONDS).build();
        Request request = new Request.Builder()
                //请求接口 如果需要传参拼接到接口后面
                .url(url)
                .addHeader("Content-Type", "application/json")
                .addHeader("Accept", "application/xml")
                .get()
                .build();
        Response response = null;
        List<String> result = new ArrayList<>();
        try {
            response = okHttpClient.newCall(request).execute();
            if (response.isSuccessful()) {
                String responseContent = response.body().string();
                Matcher matcher = PATTERN_URL.matcher(responseContent);
                while (matcher.find()) {
                    String homepage = matcher.group(1).trim();
                    result.add(homepage);
                }
            }
        } catch (IOException e) {
            log.error("从eureka中查询GOODS的服务实例出错了.原因是 {}", e.getMessage());
            return result;
        }
        IP_CACHE.put(IP_NAME, result);
        return result;
    } 
 
    /**
     * GET请求获取列表数据, 同步请求
     *
     * @param ip
     * @param userId
     * @param state
     * @param pageNo
     * @param pageSize
     * @param key
     * @return
     */
    public static List<ApplyListVO> getProductList(String ip, String userId, Integer state, Integer pageNo, Integer pageSize, String key) {
        if (StringUtils.isBlank(ip)) {
            return Collections.emptyList();
        }
        StringBuilder sb = new StringBuilder(ip);
        sb.append("goods/apply/getStuGoodsApplyList?user_id=").append(userId);
        sb.append("&state=").append(state).append("&pageNo=").append(pageNo);
        sb.append("&pageSize=").append(pageSize);
        if (StringUtils.isNotBlank(key)) {
            sb.append("&key=").append(key);
        }
        long millis = System.currentTimeMillis();
        Request request = new Request.Builder().url(sb.toString()).get().build();
        OkHttpClient okHttpClient = new OkHttpClient().newBuilder().connectTimeout(2, TimeUnit.SECONDS).build();
        try {
            Response response = okHttpClient.newCall(request).execute();
            if (response.isSuccessful()) {
                String string = response.body().string();
                //json的转换.换成我需要的实体对象,为空的不返回null, 一个小技巧
                List<ApplyListVO> applyListVOS = JSON.parseArray(string, ApplyListVO.class);
                if (applyListVOS == null) {
                    applyListVOS = Collections.emptyList();
                }
                long millis2 = System.currentTimeMillis();
                log.info("从周X那里查询到物资的列表,请求的url是:{},返回结果是:{}", sb.toString(), applyListVOS);
                log.info("查询的耗时是(微秒):{}", (millis2 - millis));
                return applyListVOS;
            } else {
                return Collections.emptyList();
            }
        } catch (Exception e) {
            log.error("从周X的接口中查询List信息出错了.原因是 {}", e.getMessage());
            return Collections.emptyList();
        }
    } 
}

这样就可以很方便的调用了,

做微服务的一定要协调好各个组件的关系, 不然很容易两个人要对不同的接口, 很麻烦.

对了, 现在我们的eureka 配置有个问题, 就是一个服务挂了之后, 需要很长的时间才能去掉. 然后请求到达网关之后还是去了已经关闭的服务, 就很蛋疼了. 需要配置一个参数.

eureka:
  server:    #配置属性,但由于 Eureka 自我保护模式以及心跳周期长的原因,
             #经常会遇到 Eureka Server 不剔除已关停的节点的问题
    enable-self-preservation: false # 设为false,关闭自我保护
    eviction-interval-timer-in-ms: 5000 # 清理间隔(单位毫秒,默认是60*1000)启用主动失效,
                                        #并且每次主动失效检测间隔为3s

先要关闭自我保护 enable-self-preservation: false

eviction-interval-timer-in-ms 启用主动失效,并且每次主动失效检测间隔为5s

Eureka Server会定时(间隔值是eureka.server.eviction-interval-timer-in-ms,默认值为0,默认情况不删除实例)进行检查,如果发现实例在在一定时间(此值由客户端设置的eureka.instance.lease-expiration-duration-in-seconds定义,默认值为90s)内没有收到心跳,则会注销此实例。

  

现在的eureka的配置 已经改过来了。

eureka页面中显示ip+端口

eureka:
  instance:
    prefer-ip-address: true
    instance-id: ${spring.cloud.client.ip-address}:${server.port}
# spring.cloud.client.ip-address 为 2.x 版本,1.x 版本为 spring.cloud.client.ipAddress
# ${spring.cloud.client.ip-address} 这个值从 org.springframework.cloud.client.HostInfoEnvironmentPostProcessor 中获取
@Override
public void postProcessEnvironment(ConfigurableEnvironment environment,
        SpringApplication application) {
    InetUtils.HostInfo hostInfo = getFirstNonLoopbackHostInfo(environment);
    LinkedHashMap<String, Object> map = new LinkedHashMap<>();
    map.put("spring.cloud.client.hostname", hostInfo.getHostname());
    map.put("spring.cloud.client.ip-address", hostInfo.getIpAddress());
    MapPropertySource propertySource = new MapPropertySource(
            "springCloudClientHostInfo", map);
    environment.getPropertySources().addLast(propertySource);
}

以上为个人经验,希望能给大家一个参考,也希望大家多多支持我们。

(0)

相关推荐

  • Spring Cloud 系列之注册中心 Eureka详解

    1.1 简介 1.1.1 概述   Netflix Eureka 是由 Netflix 开源的一款基于 REST 的服务发现组件,包括 Eureka Server 及 Eureka Client.2012 年 9 月在 GitHub 上发布 1.1.2 版本,目前 Netflix 以宣布闭源,所以市面上还是以 1.x 版本为主.Eureka 提供基于 REST 的服务,在集群中主要用于服务管理.Eureka 提供了基于 Java 语言的客户端组件,客户端组件实现了负载均衡的功能,为业务组件的集群

  • 解决springcloud-eureka注册时的ip问题

    目录 springcloud-eureka注册,ip问题 手动指定instance-id 服务调用时外网ip使用 Eureka注册服务后,ip展示不正确,调用失败 问题描述 在eureka上展示出来的效果如下 不废话,核心配置 另外,如果这一行还不够,再加几行 springcloud-eureka注册,ip问题 在微服务注册到eureka时,在开启ip显示时,有时候会出现localhost的情况 手动指定instance-id 在配置文件中 eureka.instance.prefer-ip-a

  • 如何从eureka获取服务的ip和端口号进行Http的调用

    目录 eureka获取服务ip和端口号进行Http调用 eureka页面中显示ip+端口 eureka获取服务ip和端口号进行Http调用 我告诉你们为啥我要先从eureka首先获取 goods的服务ip, 在用ip的方式使用http调用goods的服务. 因为公司的规定, 不让我们用Feigin. 我TMD的都震惊了, 我都不知道为啥. 我也不想写同事的ip地址, 做配置, 因为都去eureka里面注册了, 所以就这样调用了, 真是蛋疼.  这种微服务, 这种奇葩的方式.. package c

  • 通过weblogic API解析如何获取weblogic中服务的IP和端口操作

    我们的服务是部署在weblogic上的,最近遇到一个需求,需要在代码中获取weblogic部署当前服务的IP地址和端口. 后来搜到一段代码,亲测有效: public static String getIpAndPort(){ try { InitialContext initialContext = new InitialContext(); MBeanServer tMBeanServer; MBeanServer platformMBeanServer = ManagementFactory

  • springcloud client指定注册到eureka的ip与端口号方式

    client指定注册到eureka的ip与端口号 #设置使用IP eureka.instance.prefer-ip-address=true #设置外网IP号 eureka.instance.ip-address=49.10.22.106 #设置外网端口号 eureka.instance.non-secure-port=5565 eureka注册时使用ip而不是hostname问题 eureka的client注册到server时默认是使用hostname而不是ip,这就导致client在多台机

  • 基于多网卡环境下Eureka服务注册IP的选择问题

    目录 多网卡环境下Eureka服务注册IP选择 问题场景 问题原因 解决方案 在Eureka中使用IP注册服务 eureka服务端配置 客户端配置 admin服务端配置 客户端配置 多网卡环境下Eureka服务注册IP选择 问题场景 服务器上分别配置了eth0和eth1两块网卡,只有eth1的地址可供其它机器访问,在这种情况下,服务注册时Eureka Client会自动选择eth0作为服务ip, 导致其它服务无法调用. 问题原因 由于官方并没有写明Eureka Client探测本机IP的逻辑,所

  • SpringCloud如何使用Eureka实现服务之间的传递数据

    相信大家最关心的肯定不是什么一大堆的破理论,然后还似懂非懂的,最关心得莫过于服务之间的参数传递,数据获取. Ok,今天就告诉大家三种微服务之间传输数据的方式,分别是: 1.最基本的利用Ip端口进行请求访问接口实现数据的传输 2.使用Eureka取代Ip(硬编码)的方式实现数据的传输 3.使用Feign更加快捷"分服务"的方式实现微服务之间的数据传输(对Feign一点不了解的暂时不用理解,就是SpringCloud的组成的一部分后期会进行详细讲解,在此处讲解只是为自己mark一下) 前提

  • Java中使用HttpRequest获取用户真实IP地址

    在JSP里,获取客户端的IP地址的方法是:request.getRemoteAddr(),这种方法在大部分情况下都是有效的.但是在通过了Apache,Squid,nginx等反向代理软件就不能获取到客户端的真实IP地址了. 如果使用了反向代理软件,将http://192.168.1.110:2046/ 的URL反向代理为 http://www.jb51.net / 的URL时,用request.getRemoteAddr()方法获取的IP地址是:127.0.0.1 或 192.168.1.110

  • Java实现获取客户端真实IP方法小结

    在JSP里,获取客户端的IP地址的方法是:request.getRemoteAddr(),这种方法在大部分情况下都是有效的.但是在通过了Apache,Squid等反向代理软件就不能获取到客户端的真实IP地址了.如果使用了反向代理软件,用request.getRemoteAddr()方法获取的IP地址是:127.0.0.1或192.168.1.110,而并不是客户端的真实IP. 经过代理以后,由于在客户端和服务之间增加了中间层,因此服务器无法直接拿到客户端的 IP,服务器端应用也无法直接通过转发请

  • ASP.NET简单获取服务端和客户端计算机名称的方法

    本文实例讲述了ASP.NET简单获取服务端和客户端计算机名称的方法.分享给大家供大家参考,具体如下: //获取服务端计算机名称 string serverPCName = System.Net.Dns.GetHostName(); //获取客户端计算机名称 System.Net.IPAddress clientIP = System.Net.IPAddress.Parse(Request.UserHostAddress);//根据目标IP地址获取IP对象 System.Net.IPHostEnt

  • java 获取服务器真实IP的实例

     java 获取服务器真实IP的实例 前言: 根据操作系统的不同,获取的结果不同,故需要区分系统,分别获取 实现代码: import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.OutputStream; import java.io.PrintWriter; import java.io.UnsupportedEncodingExcept

  • 获取本机IP地址的实例(JavaScript / Node.js)

    --web 客户端JavaScript <!-- 调用方式 --> <body onload="checkCookie()"></body> function getYourIP() { const RTCPeerConnection = window.RTCPeerConnection || window.webkitRTCPeerConnection || window.mozRTCPeerConnection; if (RTCPeerConne

随机推荐