Eureka 的 Application Service 客户端的注册以及运行示例

标签：架构   设计   负载均衡   集群   eureka   

<applications>
	<versions__delta>1</versions__delta>
	<apps__hashcode>UP_1_</apps__hashcode>
	<application>
		<name>EUREKA</name>
		<instance>
			<hostName>localhost.localdomain</hostName>
			<app>EUREKA</app>
			<ipAddr>127.0.0.1</ipAddr>
			<status>UP</status>
			<overriddenstatus>UNKNOWN</overriddenstatus>
			<port enabled="true">8080</port>
			<securePort enabled="false">443</securePort>
			<countryId>1</countryId>
			<dataCenterInfo
				class="com.netflix.appinfo.InstanceInfo$DefaultDataCenterInfo">
				<name>MyOwn</name>
			</dataCenterInfo>
			<leaseInfo>
				<renewalIntervalInSecs>30</renewalIntervalInSecs>
				<durationInSecs>90</durationInSecs>
				<registrationTimestamp>1404789864122</registrationTimestamp>
				<lastRenewalTimestamp>1404798147096</lastRenewalTimestamp>
				<evictionTimestamp>0</evictionTimestamp>
				<serviceUpTimestamp>1404789841811</serviceUpTimestamp>
			</leaseInfo>
			<metadata class="java.util.Collections$EmptyMap" />
			<appGroupName>UNKNOWN</appGroupName>
			<homePageUrl>http://localhost.localdomain:8080/</homePageUrl>
			<statusPageUrl>http://localhost.localdomain:8080/Status</statusPageUrl>
			<healthCheckUrl>http://localhost.localdomain:8080/healthcheck</healthCheckUrl>
			<vipAddress>eureka.mydomain.net</vipAddress>
			<isCoordinatingDiscoveryServer>true</isCoordinatingDiscoveryServer>
			<lastUpdatedTimestamp>1404789864122</lastUpdatedTimestamp>
			<lastDirtyTimestamp>1404789841863</lastDirtyTimestamp>
			<actionType>ADDED</actionType>
		</instance>
	</application>
</applications>

###Eureka Client configuration for Sample Eureka Service


#Properties based configuration for eureka client. The properties specified here is mostly what the users
#need to change. All of these can be specified as a java system property with -D option (eg)-Deureka.region=us-east-1
#For additional tuning options refer <url to go here>




#Region where eureka is deployed -For AWS specify one of the AWS regions, for other datacenters specify a arbitrary string
#indicating the region.This is normally specified as a -D option (eg) -Deureka.region=us-east-1
eureka.region=default


#Name of the application to be identified by other services


eureka.name=sampleservice


#Virtual host name by which the clients identifies this service
eureka.vipAddress=sampleservice.mydomain.net


#The port where the service will be running and serving requests
eureka.port=1935


#For eureka clients running in eureka server, it needs to connect to servers in other zones
eureka.preferSameZone=false


#Change this if you want to use a DNS based lookup for determining other eureka servers. For example
#of specifying the DNS entries, check the eureka-client-test.properties, eureka-client-prod.properties
eureka.shouldUseDns=false


eureka.us-east-1.availabilityZones=default


eureka.serviceUrl.default=http://serverIP:8080/eureka/v2/

log4j.rootCategory=INFO,stdout
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%d %-5p %C:%L [%t] [%M] %m%n

    private static final DynamicPropertyFactory configInstance = com.netflix.config.DynamicPropertyFactory.getInstance();


    private static final Logger logger = LoggerFactory.getLogger(SampleEurekaService.class);


    public void registerWithEureka() {
        // Register with Eureka
        DiscoveryManager.getInstance().initComponent(
                new MyDataCenterInstanceConfig(),
                new DefaultEurekaClientConfig());
        ApplicationInfoManager.getInstance().setInstanceStatus(
                InstanceStatus.UP);
	}

        String vipAddress = configInstance.getStringProperty(
                "eureka.vipAddress", "sampleservice.mydomain.net").get();
        InstanceInfo nextServerInfo = null;
        while (nextServerInfo == null) {
            try {
                nextServerInfo = DiscoveryManager.getInstance()
                .getDiscoveryClient()
                .getNextServerFromEureka(vipAddress, false);
            } catch (Throwable e) {
                System.out
                .println("Waiting for service to register with eureka..");


                try {
                    Thread.sleep(10000);
                } catch (InterruptedException e1) {
                    // TODO Auto-generated catch block
                    e1.printStackTrace();
                }


            }
        }
        System.out.println("Service started and ready to process requests..");


        try {
            ServerSocket serverSocket = new ServerSocket(configInstance
                    .getIntProperty("eureka.port", 8010).get());
            final Socket s = serverSocket.accept();
            System.out
            .println("Client got connected..Processing request from the client");
            processRequest(s);


        } catch (IOException e) {
            e.printStackTrace();
        }

    private void processRequest(final Socket s) {
        try {
            BufferedReader rd = new BufferedReader(new InputStreamReader(
                    s.getInputStream()));
            String line = rd.readLine();
            if (line != null) {
                System.out.println("Received the request from the client.");
            }
            PrintStream out = new PrintStream(s.getOutputStream());
            System.out.println("Sending the response to the client...");


            out.println("Reponse at " + new Date());


        } catch (Throwable e) {
            System.err.println("Error processing requests");
        } finally {
            if (s != null) {
                try {
                    s.close();
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        }


    }	

    public void unRegisterWithEureka() {
        // Un register from eureka.
        DiscoveryManager.getInstance().shutdownComponent();
    }

/*
 * Copyright 2012 Netflix, Inc.
 *
 *    Licensed under the Apache License, Version 2.0 (the "License");
 *    you may not use this file except in compliance with the License.
 *    You may obtain a copy of the License at
 *
 *        http://www.apache.org/licenses/LICENSE-2.0
 *
 *    Unless required by applicable law or agreed to in writing, software
 *    distributed under the License is distributed on an "AS IS" BASIS,
 *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 *    See the License for the specific language governing permissions and
 *    limitations under the License.
 */


package com.netflix.eureka;


import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Date;


import org.slf4j.Logger;
import org.slf4j.LoggerFactory;


import com.netflix.appinfo.ApplicationInfoManager;
import com.netflix.appinfo.InstanceInfo;
import com.netflix.appinfo.InstanceInfo.InstanceStatus;
import com.netflix.appinfo.MyDataCenterInstanceConfig;
import com.netflix.config.DynamicPropertyFactory;
import com.netflix.discovery.DefaultEurekaClientConfig;
import com.netflix.discovery.DiscoveryManager;


/**
 * Sample Eureka service that registers with Eureka to receive and process
 * requests.
 * 
 * <p>
 * This example just receives one request and exits once it receives the request
 * after processing it.
 * </p>
 * 
 * @author Karthik Ranganathan
 * 
 */
public class SampleEurekaService {
	
    private static final DynamicPropertyFactory configInstance = com.netflix.config.DynamicPropertyFactory
    .getInstance();


    private static final Logger logger = LoggerFactory
    .getLogger(SampleEurekaService.class);


    public void registerWithEureka() {
        // Register with Eureka
        DiscoveryManager.getInstance().initComponent(
                new MyDataCenterInstanceConfig(),
                new DefaultEurekaClientConfig());
        ApplicationInfoManager.getInstance().setInstanceStatus(
                InstanceStatus.UP);
        String vipAddress = configInstance.getStringProperty(
                "eureka.vipAddress", "sampleservice.mydomain.net").get();
        InstanceInfo nextServerInfo = null;
        while (nextServerInfo == null) {
            try {
                nextServerInfo = DiscoveryManager.getInstance()
                .getDiscoveryClient()
                .getNextServerFromEureka(vipAddress, false);
            } catch (Throwable e) {
                System.out
                .println("Waiting for service to register with eureka..");


                try {
                    Thread.sleep(10000);
                } catch (InterruptedException e1) {
                    // TODO Auto-generated catch block
                    e1.printStackTrace();
                }


            }
        }
        System.out.println("Service started and ready to process requests..");


        try {
            ServerSocket serverSocket = new ServerSocket(configInstance
                    .getIntProperty("eureka.port", 8010).get());
            final Socket s = serverSocket.accept();
            System.out
            .println("Client got connected..Processing request from the client");
            processRequest(s);


        } catch (IOException e) {
            e.printStackTrace();
        }
        this.unRegisterWithEureka();
        System.out.println("Shutting down server.Demo over.");


    }


    public void unRegisterWithEureka() {
        // Un register from eureka.
        DiscoveryManager.getInstance().shutdownComponent();
    }


    private void processRequest(final Socket s) {
        try {
            BufferedReader rd = new BufferedReader(new InputStreamReader(
                    s.getInputStream()));
            String line = rd.readLine();
            if (line != null) {
                System.out.println("Received the request from the client.");
            }
            PrintStream out = new PrintStream(s.getOutputStream());
            System.out.println("Sending the response to the client...");


            out.println("Reponse at " + new Date());


        } catch (Throwable e) {
            System.err.println("Error processing requests");
        } finally {
            if (s != null) {
                try {
                    s.close();
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        }


    }


    public static void main(String args[]) {
        SampleEurekaService sampleEurekaService = new SampleEurekaService();
        sampleEurekaService.registerWithEureka();
    }


}

<dependency>
	<groupId>com.netflix.eureka</groupId>
	<artifactId>eureka-client</artifactId>
	<version>1.1.134</version>
</dependency>

<applications>
	<versions__delta>1</versions__delta>
	<apps__hashcode>UP_2_</apps__hashcode>
	<application>
		<name>SAMPLESERVICE</name>
		<instance>
			<hostName>defonds-win7</hostName>
			<app>SAMPLESERVICE</app>
			<ipAddr>172.21.40.134</ipAddr>
			<status>UP</status>
			<overriddenstatus>UNKNOWN</overriddenstatus>
			<port enabled="true">1935</port>
			<securePort enabled="false">443</securePort>
			<countryId>1</countryId>
			<dataCenterInfo
				class="com.netflix.appinfo.InstanceInfo$DefaultDataCenterInfo">
				<name>MyOwn</name>
			</dataCenterInfo>
			<leaseInfo>
				<renewalIntervalInSecs>30</renewalIntervalInSecs>
				<durationInSecs>90</durationInSecs>
				<registrationTimestamp>1404812488643</registrationTimestamp>
				<lastRenewalTimestamp>1404812609036</lastRenewalTimestamp>
				<evictionTimestamp>0</evictionTimestamp>
				<serviceUpTimestamp>1404812458545</serviceUpTimestamp>
			</leaseInfo>
			<metadata class="java.util.Collections$EmptyMap" />
			<appGroupName>UNKNOWN</appGroupName>
			<homePageUrl>http://defonds-win7:1935/</homePageUrl>
			<statusPageUrl>http://defonds-win7:1935/Status</statusPageUrl>
			<healthCheckUrl>http://defonds-win7:1935/healthcheck</healthCheckUrl>
			<vipAddress>sampleservice.mydomain.net</vipAddress>
			<isCoordinatingDiscoveryServer>false</isCoordinatingDiscoveryServer>
			<lastUpdatedTimestamp>1404812488643</lastUpdatedTimestamp>
			<lastDirtyTimestamp>1404812513644</lastDirtyTimestamp>
			<actionType>ADDED</actionType>
		</instance>
	</application>
	<application>
		<name>EUREKA</name>
		<instance>
			<hostName>localhost.localdomain</hostName>
			<app>EUREKA</app>
			<ipAddr>127.0.0.1</ipAddr>
			<status>UP</status>
			<overriddenstatus>UNKNOWN</overriddenstatus>
			<port enabled="true">8080</port>
			<securePort enabled="false">443</securePort>
			<countryId>1</countryId>
			<dataCenterInfo
				class="com.netflix.appinfo.InstanceInfo$DefaultDataCenterInfo">
				<name>MyOwn</name>
			</dataCenterInfo>
			<leaseInfo>
				<renewalIntervalInSecs>30</renewalIntervalInSecs>
				<durationInSecs>90</durationInSecs>
				<registrationTimestamp>1404812408111</registrationTimestamp>
				<lastRenewalTimestamp>1404812618042</lastRenewalTimestamp>
				<evictionTimestamp>0</evictionTimestamp>
				<serviceUpTimestamp>1404812385938</serviceUpTimestamp>
			</leaseInfo>
			<metadata class="java.util.Collections$EmptyMap" />
			<appGroupName>UNKNOWN</appGroupName>
			<homePageUrl>http://localhost.localdomain:8080/</homePageUrl>
			<statusPageUrl>http://localhost.localdomain:8080/Status
			</statusPageUrl>
			<healthCheckUrl>http://localhost.localdomain:8080/healthcheck
			</healthCheckUrl>
			<vipAddress>eureka.mydomain.net</vipAddress>
			<isCoordinatingDiscoveryServer>true</isCoordinatingDiscoveryServer>
			<lastUpdatedTimestamp>1404812408111</lastUpdatedTimestamp>
			<lastDirtyTimestamp>1404812385985</lastDirtyTimestamp>
			<actionType>ADDED</actionType>
		</instance>
	</application>
</applications>

• https://github.com/Netflix/eureka/tree/master/eureka-server/conf
• https://github.com/Netflix/archaius/wiki/Getting-Started

Eureka 的 Application Service 客户端的注册以及运行示例,布布扣,bubuko.com

Eureka 的 Application Service 客户端的注册以及运行示例

标签：架构   设计   负载均衡   集群   eureka   

原文地址：http://blog.csdn.net/defonds/article/details/37592123