Κοινή χρήση τεχνολογίας

SpringCloud--Σμήνος Eureka

2024-07-12

한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina

Σύμπλεγμα κέντρου εγγραφής Eureka

Γιατί συστάδα

Εάν υπάρχει μόνο ένας διακομιστής κέντρου εγγραφής, θα υπάρχει ένα μόνο σημείο αποτυχίας και δεν είναι δυνατή η επεξεργασία του με υψηλή ταυτόχρονη, επομένως απαιτείται σύμπλεγμα.

Πώς να ομαδοποιήσετε

Προετοιμάστε τρεις EurekaServer για εγγραφή μεταξύ τους, πράγμα που σημαίνει ότι κάθε EurekaServer πρέπει να εγγραφεί σε όλους τους EureakServers, συμπεριλαμβανομένου του εαυτού του Κάθε EurekaServer λειτουργεί και ως διακομιστής και ως πελάτης. Οι άλλες μικρουπηρεσίες μας (παραγγελία, χρήστης) χρειάζεται μόνο να υποδείξουν τη διεύθυνση εγγραφής σε όλους τους EurekaServers.

Κώδικας:

Αυτό που χρησιμοποιείται εδώ είναι μια λειτουργική μονάδα Eureka, η οποία διαμορφώνει πολλά αρχεία yml για να επιτύχει το αποτέλεσμα της ομαδοποίησης.

Τάξη εκκίνησης

  1. package org.example;
  2.  
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
  6.  
  7. /**
  8.  * @ClassName EurekaStart
  9.  * @Author 23
  10.  * @Date 2024/7/10 19:12
  11.  * @Version 1.0
  12.  * @Description TODO
  13.  **/
  14. @SpringBootApplication
  15. @EnableEurekaServer
  16. public class EurekaStart {
  17.     public static void main(String[] args) {
  18.         SpringApplication.run(EurekaStart.class,args);
  19.     }
  20. }

yml

  1. spring:
  2.   profiles:
  3.     active: peer3
  4. ---
  5. spring:
  6.   profiles: peer1
  7.   application:
  8.     name: Eureka1
  9. eureka:
  10.   instance:
  11.     hostname: localhost
  12.   client:
  13.     serviceUrl:
  14.       defaultZone: http://localhost:10070/eureka/
  15. server:
  16.   port: 10070
  17. ---
  18. spring:
  19.   profiles: peer2
  20.   application:
  21.     name: Eureka2
  22. eureka:
  23.   instance:
  24.     hostname: localhost
  25.   client:
  26.     serviceUrl:
  27.       defaultZone: http://localhost:10071/eureka/
  28. server:
  29.   port: 10071
  30. ---
  31. spring:
  32.   profiles: peer3
  33.   application:
  34.     name: Eureka3
  35. eureka:
  36.   instance:
  37.     hostname: localhost
  38.   client:
  39.     serviceUrl:
  40.       defaultZone: http://localhost:10072/eureka/
  41. server:
  42.   port: 10072

pom.xml

  1. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  2.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  3.     <modelVersion>4.0.0</modelVersion>
  4.     <parent>
  5.         <groupId>org.example</groupId>
  6.         <artifactId>Springcloud-Netflix</artifactId>
  7.         <version>1.0-SNAPSHOT</version>
  8.     </parent>
  9.  
  10.     <artifactId>Eureka-Service</artifactId>
  11.     <packaging>jar</packaging>
  12.  
  13.     <name>Eureka-Service</name>
  14.     <url>http://maven.apache.org</url>
  15.  
  16.     <properties>
  17.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  18.     </properties>
  19.  
  20.     <dependencies>
  21.         <dependency>
  22.             <groupId>junit</groupId>
  23.             <artifactId>junit</artifactId>
  24.             <version>3.8.1</version>
  25.             <scope>test</scope>
  26.         </dependency>
  27.         <dependency>
  28.             <groupId>org.springframework.boot</groupId>
  29.             <artifactId>spring-boot-starter-web</artifactId>
  30.         </dependency>
  31.         <dependency>
  32.             <groupId>org.springframework.boot</groupId>
  33.             <artifactId>spring-boot-starter-test</artifactId>
  34.         </dependency>
  35.         <!-- Eureka服务端支持 -->
  36.         <dependency>
  37.             <groupId>org.springframework.cloud</groupId>
  38.             <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
  39.         </dependency>
  40.     </dependencies>
  41. </project>

Εξισορρόπηση φορτίου σέρβις

Γιατί απαιτείται εξισορρόπηση φορτίου

Για την παροχή ταυτόχρονης λειτουργίας, μερικές φορές ο ίδιος πάροχος υπηρεσιών μπορεί να αναπτύξει πολλαπλές (υπηρεσίες εμπορευμάτων). Αυτός ο πελάτης πρέπει να ολοκληρώσει την κλήση φόρτωσης σύμφωνα με μια συγκεκριμένη στρατηγική υπεύθυνης εξισορρόπησης κατά την κλήση.

Διαμόρφωση παρόχου υπηρεσιών

  1. spring:
  2.   profiles:
  3.     active: order2
  4. ---
  5. server:
  6.   port: 10010
  7. spring:
  8.   profiles: order1
  9.   application:
  10.     name: order-service
  11. eureka:
  12.   client:
  13.     service-url:
  14.       defaultZone:  http://localhost:10072/eureka
  15.   instance:
  16.     prefer-ip-address: true
  17. ---
  18. server:
  19.   port: 10012
  20. spring:
  21.   profiles: order2
  22.   application:
  23.     name: order-service
  24. eureka:
  25.   client:
  26.     service-url:
  27.       defaultZone: http://localhost:10072/eureka
  28.   instance:
  29.     prefer-ip-address: true

Κοινές τεχνολογίες υλοποίησης εξισορρόπησης φορτίου

Ταινία

Μέσω του RestTmplate, ολοκληρώστε την κλήση υπηρεσίας με url

Εφαρμογή κώδικα (από πλευράς καταναλωτή υπηρεσιών):

  1. package org.example.Controller;
  2.  
  3. import org.example.domain.Order;
  4. import org.springframework.beans.factory.annotation.Autowired;
  5. import org.springframework.cloud.client.ServiceInstance;
  6. import org.springframework.cloud.client.discovery.DiscoveryClient;
  7. import org.springframework.web.bind.annotation.GetMapping;
  8. import org.springframework.web.bind.annotation.PathVariable;
  9. import org.springframework.web.bind.annotation.RequestMapping;
  10. import org.springframework.web.bind.annotation.RestController;
  11. import org.springframework.web.client.RestTemplate;
  12.  
  13. import java.util.Arrays;
  14. import java.util.List;
  15.  
  16. /**
  17.  * @ClassName UserController
  18.  * @Author 23
  19.  * @Date 2024/7/10 18:52
  20.  * @Version 1.0
  21.  * @Description TODO
  22.  **/
  23. @RestController
  24. @RequestMapping("/User")
  25. public class UserControllerrlb {
  26.     @Autowired
  27.     private RestTemplate restTemplate;
  28. //    @Autowired
  29. //    private DiscoveryClient discoveryClient;
  30.     @GetMapping("/getOrder/{id}")
  31.     public List<Order> getOrderById(@PathVariable("id") Integer id) {
  32. //        Order[] order = restTemplate.getForObject("http://localhost:10010/OrderService/user/" + id, Order[].class);
  33. //        return Arrays.asList(order);
  34. //        List<ServiceInstance> instances=discoveryClient.getInstances("order-service");//通过服务的名字去获取服务实例
  35. //        ServiceInstance serviceInstance=instances.get(0);//定死只获取第一个服务实例对象
  36. //        String ip=serviceInstance.getHost();//获取服务对象ip
  37. //        int port=serviceInstance.getPort();//获取获取的实例对象的服务端口号
  38.         Order[] orders=restTemplate.getForObject("http://Order-Service/OrderService/user/"+id,Order[].class);
  39.         return Arrays.asList(orders);
  40.  
  41.     }
  42. }

Κλήση εξισορρόπησης φορτίου κορδέλας

Το Ribbon είναι ένα έργο ανοιχτού κώδικα υπηρεσίας μεσαίου επιπέδου cloud που κυκλοφόρησε από το Netflix. Η κύρια λειτουργία του είναι να παρέχει αλγόριθμο εξισορρόπησης φορτίου πελάτη. Το στοιχείο πελάτη Ribbon παρέχει μια σειρά από πλήρη στοιχεία διαμόρφωσης, όπως λήξη χρόνου σύνδεσης, επανάληψη, κ.λπ. Με απλά λόγια, το Ribbon είναι ένα πρόγραμμα εξισορρόπησης φορτίου πελάτη Μπορούμε να αναφέρουμε όλα τα μηχανήματα πίσω από τον εξισορροπητή φορτίου στο αρχείο διαμόρφωσης και το Ribbon θα σας βοηθήσει αυτόματα να συνδεθείτε βάσει ορισμένων κανόνων (όπως απλή δημοσκόπηση, τυχαίες συνδέσεις, κ.λπ.). μηχανών, μπορούμε εύκολα να χρησιμοποιήσουμε το Ribbon για να εφαρμόσουμε προσαρμοσμένους αλγόριθμους εξισορρόπησης φορτίου. Το Ribbon είναι ένα πρόγραμμα εξισορρόπησης φόρτου πελάτη που μπορεί να ολοκληρώσει κλήσεις εξισορρόπησης φορτίου για πολλαπλές παρουσίες υπηρεσίας μιας υπηρεσίας σύμφωνα με ορισμένους κανόνες Αυτοί οι κανόνες υποστηρίζουν επίσης την προσαρμογή.

Σχηματικός:

Εξισορρόπηση φορτίου OpenFeign

Το OpenFeign είναι ένα δηλωτικό πρόγραμμα-πελάτη της υπηρεσίας Web, σκοπός του οποίου είναι να διευκολύνει τις κλήσεις της Υπηρεσίας Ιστού. Το Feign παρέχει ένα πρότυπο διεπαφής για αιτήματα HTTP (η διεύθυνση πρόσβασης επισημαίνεται σε αυτό γράφοντας μια απλή διεπαφή και εισάγοντας σχολιασμούς, μπορείτε να ορίσετε τις παραμέτρους, τη μορφή, τη διεύθυνση και άλλες πληροφορίες του αιτήματος HTTP). Το OpenFeign θα εκτελεί πλήρως τα αιτήματα HTTP μεσολάβησης (δυναμικό διακομιστή μεσολάβησης). Χρειάζεται μόνο να το καλέσουμε ως μέθοδο για την ολοκλήρωση του αιτήματος υπηρεσίας και της σχετικής επεξεργασίας. Το Feign ενσωματώνει το Ribbon και το Hystrix (θα μιλήσουμε για το Hystrix αργότερα), έτσι ώστε να μην χρειάζεται πλέον να χρησιμοποιούμε ρητά αυτά τα δύο συστατικά.

Στρατηγική εξισορρόπησης φορτίου

Κυβερνώ

Διαμορφώνοντας διαφορετικές υποκατηγορίες IRule, μπορείτε να επιλέξετε διαφορετικές στρατηγικές εξισορρόπησης φορτίου, δηλαδή να επιλέξετε μια υπηρεσία από τη λίστα υπηρεσιών με μια συγκεκριμένη στρατηγική για να ολοκληρώσετε την κλήση. Φυσικά μπορεί και να προσαρμοστεί. Επομένως, οι στρατηγικές εξισορρόπησης φορτίου μπορούν να χωριστούν σε ενσωματωμένες και προσαρμοσμένες.

Ενσωματωμένη στρατηγική εξισορρόπησης φορτίου

 

Προσωπικό προφίλ

Έχει αφοσιωθεί στην έρευνα της τεχνολογίας για περισσότερα από τριάντα χρόνια και είναι ικανός σε διάφορες γλώσσες όπως java, linux, javascript, php, css, κ.λπ., και έχει κάνει πολλές συνεισφορές στον τομέα του ανοιχτού κώδικα ένας σταθμός τεκμηρίωσης προγραμματιστή για κοινή χρήση ορισμένων ζητημάτων στην ανάπτυξη τεχνολογίας για μελλοντική αναφορά

τα στοιχεία επικοινωνίας μου

Ταχυδρομείο