获取配置信息测试的代码：

package com.taobao.diamond.test;

import java.util.concurrent.Executor;

import com.taobao.diamond.manager.DiamondManager;

import com.taobao.diamond.manager.ManagerListener;

import com.taobao.diamond.manager.impl.DefaultDiamondManager;

public class DiamondClient{

public static void main(String[] str){

DiamondManager manager = new DefaultDiamondManager("DEFAULT_GROUP", "topicConfig",

new ManagerListener() {//填写你服务端后台保存过的group和dataId

public void receiveConfigInfo(String configInfo){

System.out.println("changed config: " + configInfo);

}

public Executor getExecutor(){

return null;

}

}, "127.0.0.1,10.126.53.16,10.126.53.17");

//设置diamond-server服务的端口

manager.getDiamondConfigure().setPort(8080);

String availableConfigureInfomation = manager.getAvailableConfigureInfomation(5000);

System.out.println("start config: " + availableConfigureInfomation);

}

}

对DefaultDiamondManager的扩展，支持手动指定服务端地址

添加了它的一个构造函数

public DefaultDiamondManager(String group, String dataId, ManagerListener managerListener,String diamondServer){

this.dataId = dataId;

this.group = group;

diamondSubscriber = DiamondClientFactory.getSingletonDiamondSubscriber();

this.managerListeners.add(managerListener);

((DefaultSubscriberListener) diamondSubscriber.getSubscriberListener()).addManagerListeners(this.dataId,

this.group, this.managerListeners);

String s[] = diamondServer.split(",");

if (s != null && s.length > 0) {

for (String o : s) {

if (o != null && !o.trim().equals(""))

diamondSubscriber.getDiamondConfigure().getDomainNameList().add(o.trim());

}

}

diamondSubscriber.addDataId(this.dataId, this.group);

diamondSubscriber.start();

}

这样的话，就能获取到配置信息了。

上面这个例子通过手动指定diamondServer可以跳过服务端寻址的这个过程。

在配置diamond-server集群的时候，各个server之间的端口并没有要求相同，

但是在这的时候，发现它的端口，只能是相同的，无法每个IP对应自己的端口。

所以这里的diamondServer地址应该是nginx地址，端口的话，也应该是nginx提供diamond-server服务的端口。

nginx提供负载均衡的策略，同一的访问域名，对应了多台diamond-server后台机器，这里面的端口可以是不同的，解决diamond-server的单点问题。

虽然上面的那个例子手动指定了diamondServer地址，但是我们还是要去大体了解获取服务端地址的逻辑。

new

DefaultDiamondManager的构造函数，最后一句是diamondSubscriber.start();

点击进去

serverAddressProcessor = new

ServerAddressProcessor(this.diamondConfigure,

this.scheduledExecutor);

serverAddressProcessor.start();

然后在查看serverAddressProcessor.start()的具体逻辑

public synchronized void start(){

if (isRun) {

return;

}

isRun = true;

initHttpClient();

if (this.diamondConfigure.isLocalFirst()) {

acquireServerAddressFromLocal();

}

else {

synAcquireServerAddress();//首先执行的是这个

asynAcquireServerAddress();

}

}

protected void synAcquireServerAddress(){

if (!isRun) {

throw new RuntimeException("ServerAddressProcessor不在运行状态，无法同步获取服务器地址列表");

}

if (MockServer.isTestMode()) {

diamondConfigure.addDomainName("测试模式，没有使用的真实服务器");

return;

}

int acquireCount = 0;

if (diamondConfigure.getDomainNameList().size() == 0) {

if (!acquireServerAddressOnce(acquireCount)) {

acquireCount++;

if (acquireServerAddressOnce(acquireCount)) {

// 存入本地文件

storeServerAddressesToLocal();

log.info("在同步获取服务器列表时，向日常ConfigServer服务器获取到了服务器列表");

}

else {

log.info("从本地获取Diamond地址列表");

reloadServerAddresses();

if (diamondConfigure.getDomainNameList().size() == 0)

throw new RuntimeException("当前没有可用的服务器列表");

}

}

else {

log.info("在同步获取服务器列表时，向线上ConfigServer服务器获取到了服务器列表");

// 存入本地文件

storeServerAddressesToLocal();

}

}

}

private boolean acquireServerAddressOnce(int acquireCount){

HostConfiguration hostConfiguration = configHttpClient.getHostConfiguration();

String configServerAddress;

int port;

if (null != diamondConfigure.getConfigServerAddress()) {

configServerAddress = diamondConfigure.getConfigServerAddress();

port = diamondConfigure.getConfigServerPort();

}

else {

if (acquireCount == 0) {

configServerAddress = Constants.DEFAULT_DOMAINNAME;//a.b.c

port = Constants.DEFAULT_PORT;//端口

}

else {

configServerAddress = Constants.DAILY_DOMAINNAME;//d.e.f

port = Constants.DEFAULT_PORT;//端口

}

}

hostConfiguration.setHost(configServerAddress, port);

String serverAddressUrl = Constants.CONFIG_HTTP_URI_FILE;

//默认为/url，并且配置域名a.b.c或者d.e.f 访问url==>http://a.b.c:port/url返回以换行分隔的diamond ip列表行.

//所以这个/url很有可能需要被改掉

HttpMethod httpMethod = new GetMethod(serverAddressUrl);

// 设置HttpMethod的参数

HttpMethodParams params = new HttpMethodParams();

params.setSoTimeout(diamondConfigure.getOnceTimeout());

// ///

httpMethod.setParams(params);

try {

if (SC_OK == configHttpClient.executeMethod(httpMethod)) {

InputStreamReader reader = new InputStreamReader(httpMethod.getResponseBodyAsStream());

BufferedReader bufferedReader = new BufferedReader(reader);

String address = null;

List newDomainNameList = new LinkedList();

while ((address = bufferedReader.readLine()) != null) {//以换行分割

address = address.trim();

if (StringUtils.isNotBlank(address)) {

newDomainNameList.add(address);

}

}

if (newDomainNameList.size() > 0) {

log.debug("更新使用的服务器列表");

this.diamondConfigure.setDomainNameList(newDomainNameList);

return true;

}

}

else {

log.warn("没有可用的新服务器列表");

}

}

catch (HttpException e) {

log.error(getErrorMessage(configServerAddress) + ", " + e);

}

catch (IOException e) {

log.error(getErrorMessage(configServerAddress) + ", " + e);

}

catch (Exception e) {

log.error(getErrorMessage(configServerAddress) + ", " + e);

}

finally {

httpMethod.releaseConnection();

}

return false;

}

函数reloadServerAddresses，本地获取服务地址列表

File serverAddressFile = new

File(generateLocalFilePath(this.diamondConfigure.getFilePath(),

"ServerAddress"));

//这里的地址，在我的机器，默认为C:\Users\linchengjun\diamond\ServerAddress

============================分割线==========================================

到这为止，diamond-client获取server列表的顺序出来了

1.如果像我那样对DefaultDiamondManager进行了扩展，手动指定了地址列表，就不会进行其他的寻址逻辑了。

2.如果没有的话，先进行http://a.b.c:port/url请求sever地址列表行，获取不到，再进行http://d.e.f:port/url请求获取；

如果这两个都不行，就会调用reloadServerAddresses，进行本地文件的获取，比如C:\Users\linchengjun\diamond\ServerAddress

--------------------------------------------------读取服务端配置信息的顺序------------------------------------

分析测试代码

String availableConfigureInfomation = manager.getAvailableConfigureInfomation(5000);

public String getAvailableConfigureInfomation(String dataId, String group, long timeout){

// 尝试先从本地和网络获取配置信息

try {

String result = getConfigureInfomation(dataId, group, timeout);

if (result != null && result.length() > 0) {

return result;

}

}

catch (Throwable t) {

log.error(t.getMessage(), t);

}

// 测试模式不使用本地dump

if (MockServer.isTestMode()) {

return null;

}

return getSnapshotConfiginfomation(dataId, group);//从快照文件获取

}

具体断点进行调试，就能总结出来，读取的顺序

先从本地缓存读取

发现本地缓存localConfigInfoProcessor并没有缓存住，就从网络提取，这个时候需要注意Constants.HTTP_URI_FILE这个值，需要被改成/diamond-server/config.co

要不然老是获取不正确，即Constants.java中HTTP_URI_FILE改成public static final

String HTTP_URI_FILE = "/diamond-server/config.co";

从网络获取到数据之后，会先保存到快照里面，然后是保存到本地缓存。