vlambda博客
学习文章列表

        import org.slf4j.Logger;
        import org.slf4j.LoggerFactory;
        //other code goes here
        private static final Logger logger = LoggerFactory
          .getLogger(SearchRestController.class);

        //other code goes here

        logger.info("Looking to load flights...");
        for (Flight flight : flightRepository
          .findByOriginAndDestinationAndFlightDate
          ("NYC", "SFO", "22-JAN-18")) {
            logger.info(flight.toString());
        }

        <dependency>
          <groupId>net.logstash.logback</groupId>
          <artifactId>logstash-logback-encoder</artifactId>
          <version>4.6</version>
        </dependency>

        <?xml version="1.0" encoding="UTF-8"?>
        <configuration>
          <include resource="org/springframework/boot/logging /logback/defaults.xml"/>
          <include resource="org/springframework/boot/logging /logback/console-appender.xml" />
          <appender name="stash" class="net.logstash.logback.appender .LogstashTcpSocketAppender">
            <destination>localhost:4560</destination>
            <!-- encoder is required -->
            <encoder class="net.logstash.logback.encoder .LogstashEncoder" />
          </appender>
          <root level="INFO">
           <appender-ref ref="CONSOLE" />
           <appender-ref ref="stash" />
          </root>
        </configuration>

        input {
          tcp {
            port => 4560
            host => localhost
          }
        }
        output {
          elasticsearch { hosts => ["localhost:9200"] }
          stdout { codec => rubydebug }
        }

        ./bin/elasticsearch
        ./bin/kibana
        ./bin/logstash -f logstash.conf

        http://localhost:5601

        <dependency>
          <groupId>org.springframework.cloud</groupId>
          <artifactId>spring-cloud-starter-sleuth</artifactId>
        </dependency>

        <property name="spring.application.name" value="search-service"/>
        <property name="spring.application.name" value="search-apigateway"/>

        @RequestMapping("/hubongw")
        String getHub(HttpServletRequest req){
          logger.info("Search Request in API gateway
           for getting Hub, forwarding to search-service ");
          String hub = restTemplate.getForObject("http://search-
           service/search/hub", String.class);
          logger.info("Response for hub received,  Hub "+ hub);
          return hub;
        }

        @RequestMapping("/hub")
        String getHub(){
          logger.info("Searching for Hub, received from
            search-apigateway ");
          return "SFO";
        }

2017-03-31 22:30:17.780  INFO [search-
        apigateway,9f698f7ebabe6b83,9f698f7ebabe6b83,false]
        47158 --- [nio-8095-exec-1] 
        c.b.p.s.a.SearchAPIGatewayController: Response for hub
        received,  Hub SFO

2017-03-31 22:30:17.741 INFO [search-
        service,9f698f7ebabe6b83,3a63748ac46b5a9d,false]
        47106---[nio-8090-exec-
        1]c.b.p.s.controller.SearchRestController  : Searching
        for Hub, received from search-apigateway

        <dependency>
          <groupId>org.springframework.cloud</groupId>
          <artifactId>spring-cloud-starter-hystrix</artifactId>
        </dependency>

        @Component
        class SearchAPIGatewayComponent {
          @LoadBalanced
          @Autowired
          RestTemplate restTemplate;

          @HystrixCommand(fallbackMethod = "getDefaultHub")
          public String getHub(){
            String hub = restTemplate
              .getForObject("http://search-service/search/hub",
              String.class);
            return hub;
          }

          public String getDefaultHub(){
            return "Possibily SFO";
          }
        }

        @RequestMapping("/hubongw")
        String getHub(){
 logger.info("Search Request in API gateway for getting Hub, 
            forwarding to search-service ");
          return component.getHub();
        }

        @EnableTurbine
        @EnableHystrixDashboard
        @SpringBootApplication
        publicclass TurbineServerApplication {

        application:
          name : turbineserver
        turbine:
          clusterNameExpression: new String('default')
          appConfig : search-service,search-apigateway
          server:
            port: 9090
            eureka:
          client:
            serviceUrl:
              defaultZone: http://localhost:8761/eureka/

        turbine:
          aggregator:
            clusterConfig: [comma separated clusternames]

        @HystrixCommand(fallbackMethod = "searchFallback")
        public List<Flight> search(SearchQuery query){

        java -jar -Dserver.port=
          8096 -Deureka.instance.hostname=localdomain2 -
          Dserver.address=localdomain2
          target/search-apigateway-1.0.jar

        java -jar -Dserver.port=
          8095 -Deureka.instance.hostname=localdomain1 -
          Dserver.address=localdomain1
          target/search-apigateway-1.0.jar

        java -jar -Dserver.port=
          8090 -Deureka.instance.hostname=localdomain1 -
          Dserver.address=localdomain1
          target/search-1.0.jar