{"type":"doc","content":[{"type":"paragraph","content":[{"text":"As a local balancer, Ribbon allows you to invoke services in the CaaS infrastructure transparently regardless of the number of Pods behind the service. In infrastructures with Kubernetes, you can also do without a discovery service (such as Eureka, Consul ...) since Ribbon uses the Kubernetes API to discover the Pods.","type":"text"}]},{"type":"paragraph","content":[{"text":"To integrate Ribbon, you must add the Ribbon dependence to your Maven project:","type":"text"}]},{"type":"codeBlock","content":[{"text":"\n org.springframework.cloud\n spring-cloud-starter-netflix-ribbon\n\n","type":"text"}]},{"type":"paragraph","content":[{"text":"Add the ","type":"text"},{"text":"@LoadBalanced ","type":"text","marks":[{"type":"strong"}]},{"text":"annotation to the RestTemplate:","type":"text"}]},{"type":"codeBlock","content":[{"text":"@LoadBalanced\n\t@Bean\n\tpublic RestTemplate restTemplate() {\n\t\treturn new RestTemplate(factory());\n\t}","type":"text"}]},{"type":"paragraph","content":[{"text":"Each Ribbon client is associated with a service name, so in your application, you must declare as many Ribbon customers (No RestTemplate, these only need to be ","type":"text"},{"text":"@LoadBalanced","type":"text","marks":[{"type":"strong"}]},{"text":") as balanced destinations you have. This can be done in the SpringBootApplication class itself to which you also need to add the ","type":"text"},{"text":"@EnableDiscoveryClient ","type":"text","marks":[{"type":"strong"}]},{"text":"annotation.","type":"text"}]},{"type":"codeBlock","content":[{"text":"@RibbonClients(value = {\n\t\t@RibbonClient(name = \"${connection-protocol-redsys.protocolredsys.service}\", configuration = RibbonConfiguration.class),\n\t\t@RibbonClient(name = \"${connection-protocol-sat.protocolsat.service}\", configuration = RibbonConfiguration.class),\n})\n@EnableDiscoveryClient\npublic class BackendBusinessAuthorizationApplication {\n\n\tpublic static void main(String[] args) {\n\t\tSpringApplication.run(BackendBusinessAuthorizationApplication.class, args);\n\t}\n\n}","type":"text"}]},{"type":"paragraph","content":[{"text":"As you can see, you have the @RibbonClient name parameterized and you indicate a Configuration class for each client: ","type":"text"},{"text":"RibbonConfiguration.class","type":"text","marks":[{"type":"strong"}]}]},{"type":"paragraph","content":[{"text":"In this class, a basic configuration would be:","type":"text"}]},{"type":"bulletList","content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"The declaration of a Bean that declares the rule to follow to choose a destination (specific Pod) behind a service. In this case it is based on response time, although there are many others, and they can even be programmed ad-hoc, such as RoundRobin, Geographical affinity...","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"The declaration of a Bean that will periodically ping the Pods behind the service to identify which ones are \"alive\".","type":"text"}]}]}]},{"type":"codeBlock","content":[{"text":"public class RibbonConfiguration {\n\t\n @Autowired\n IClientConfig ribbonClientConfig;\n \n @Bean\n public IPing ribbonPing(IClientConfig config) {\n \treturn new PingUrl(false, \"/balancer/ping\");\n }\n \n @Bean\n public IRule ribbonRule(IClientConfig config) {\n \treturn new WeightedResponseTimeRule();\n }\n\n}","type":"text"}]},{"type":"paragraph","content":[{"text":"The Ping's previous configuration forces each destination to implement a controller that responds to the Ping url:","type":"text"}]},{"type":"codeBlock","content":[{"text":"@RestController\n@RequestMapping(value =\"/balancer\")\npublic class PingController {\n\t\n\t@GetMapping(path = \"/ping\")\n\tpublic void ping() {\n\t\t\n\t}\n}","type":"text"}]},{"type":"paragraph","content":[{"text":"Once you have all this programmatic configuration, the application is ready to use Ribbon locally balancing for the services indicated in the declared RibbonClients. The following is to configure the services:","type":"text"}]},{"type":"bulletList","content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Local Development. You do not need to have any discovery service, you can declare the service in the ","type":"text"},{"text":"application.yml","type":"text","marks":[{"type":"strong"}]},{"text":":","type":"text"}]}]}]},{"type":"codeBlock","content":[{"text":"connection-protocol-redsys:\n protocolredsys.service: protocolredsys\n endpoint: http://${connection-protocol-redsys.protocolredsys.service}/protocol/redsys/v1\n\nconnection-protocol-sat:\n protocolsat.service: protocolsat\n endpoint: http://${connection-protocol-sat.protocolsat.service}/protocolsat/protocol/v1\n \nprotocolredsys:\n ribbon:\n eureka:\n enabled: false\n listOfServers: localhost:9866\n ServerListRefreshInterval: 30000\n \nprotocolsat:\n ribbon:\n eureka:\n enabled: false\n listOfServers: localhost:9890\n ServerListRefreshInterval: 30000\n","type":"text"}]},{"type":"paragraph","content":[{"text":"As you can see, this is done to declare two services with Ribbon: ","type":"text"},{"text":"protocolredsys ","type":"text","marks":[{"type":"strong"}]},{"text":"and ","type":"text"},{"text":"protocolsat","type":"text","marks":[{"type":"strong"}]},{"text":", which are those indicated in the url as a service name and those that were included parameterized for the ","type":"text"},{"text":"name ","type":"text","marks":[{"type":"strong"}]},{"text":"attribute in the ","type":"text"},{"text":"@RibbonClient ","type":"text","marks":[{"type":"strong"}]},{"text":"in the SpringBootApplication class. Thus, protocolredsys points to localhost:9866 and protocolsat to localhost:9890","type":"text"}]},{"type":"bulletList","content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Deployment in Kubernetes. In this case, the ","type":"text"},{"text":"application-docker.yml ","type":"text","marks":[{"type":"strong"}]},{"text":"is configured so that the name of the services can be passed as an environment variable:","type":"text"}]}]}]},{"type":"codeBlock","content":[{"text":"connection-protocol-redsys:\n protocolredsys.service: ${protocol-redsys-service}\nconnection-protocol-sat:\n protocolsat.service: ${protocol-sat-service}","type":"text"}]},{"type":"paragraph","content":[{"text":"To use Ribbon in Kubernetes, add the dependency through a specific profile, so that it is added only if the destination of the compile is a CaaS kubernetes:","type":"text"}]},{"type":"paragraph"},{"type":"codeBlock","content":[{"text":" \n \n kubernetes\n \n \n org.springframework.cloud\n spring-cloud-starter-kubernetes-ribbon\n \n \n \n \n ","type":"text"}]},{"type":"paragraph"},{"type":"paragraph","content":[{"text":"In the latest versions of Spring Cloud, this dependency is already included in the starter itself, so you don’t need to indicate version. If you are using an old version of Spring cloud, please check consult the version of this library to use, since not all of them are valid.","type":"text"}]},{"type":"paragraph"},{"type":"paragraph","content":[{"text":"The next thing is to enable the service in Kubernetes. By default, a service is created for each workload, but this service points to port 42. Therefore, you need to create a service that points to the correct port exposed by your pods:","type":"text"}]},{"type":"mediaSingle","attrs":{"layout":"center","width":83.0},"content":[{"type":"media","attrs":{"width":934,"id":"a5c893e5-8e2e-4171-a756-d107cd0fdabe","collection":"contentId-2220818761","type":"file","height":565}}]},{"type":"paragraph","content":[{"text":"Once the service is created, you can configure the environment variables indicated in your application’s ","type":"text"},{"text":"application-docker.yml:","type":"text","marks":[{"type":"strong"}]}]},{"type":"mediaSingle","attrs":{"layout":"center","width":83.0},"content":[{"type":"media","attrs":{"width":966,"id":"7bf7e16e-eaa9-43ac-82ee-40cee94a6cad","collection":"contentId-2220818761","type":"file","height":85}}]},{"type":"paragraph","content":[{"text":"And the integration of Spring Cloud and Kubernetes will be in charge of balancing between the different Pods behind each service.","type":"text"}]},{"type":"paragraph","content":[{"text":"Important note:","type":"text","marks":[{"type":"strong"}]}]},{"type":"paragraph","content":[{"text":"It is very likely that, when starting the application for the first time, you will have a permission error like this one:","type":"text"}]},{"type":"codeBlock","content":[{"text":"io.fabric8.kubernetes.client.KubernetesClientException: Failure executing: GET at: https://10.43.0.1/api/v1/namespaces/testloadbalancing/endpoints. Message: Forbidden!Configured service account doesn't have access. Service account may have been revoked. endpoints is forbidden: User \"system:serviceaccount:testloadbalancing:default\" cannot list resource \"endpoints\" in API group \"\" in the namespace \"testloadbalancing\".","type":"text"}]},{"type":"paragraph","content":[{"text":"This is because the Ribbon library for Kubernetes invokes the Kubernetes API and does not have permission. To give it permission, you need to enter the kubernetes console and create a role that allows the user account that runs your workload to consult the Kubernetes API with:","type":"text"}]},{"type":"paragraph","content":[{"text":" ","type":"text"}]},{"type":"codeBlock","content":[{"text":"kubectl create clusterrolebinding testloadbalancing:default --clusterrole=cluster-admin --serviceaccount=testloadbalancing:default","type":"text"}]},{"type":"paragraph"},{"type":"paragraph","content":[{"text":"Where:","type":"text"}]},{"type":"bulletList","content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"testloadbalancing:default","type":"text","marks":[{"type":"strong"}]},{"text":" --> Is the role’s name.","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"-clusterrole=","type":"text"},{"text":"cluster-admin","type":"text","marks":[{"type":"strong"}]},{"text":" --> Are the role’s permissions.","type":"text"}]}]}]},{"type":"bulletList","content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"-serviceaccount=","type":"text"},{"text":"testloadbalancing:default","type":"text","marks":[{"type":"strong"}]},{"text":" --> Is the user’s account.","type":"text"}]}]}]},{"type":"paragraph","content":[{"text":" ","type":"text"}]},{"type":"paragraph","content":[{"text":"The three parameters can be identified in the error message itself.","type":"text"}]}],"version":1}

Browser not supported