いっしょにRPCのフレームワーク(26)RPCのテスト編の3---限流のテストを書きます

このセクションでは、ストリーム制限機能をテストします.まず、単純なクラスを定義し、単位時間あたり最大の呼び出し回数を構成します.

package org.laopopo.example.generic.test_5;

import org.laopopo.client.annotation.RPCService;
import org.laopopo.example.demo.service.HelloSerivce;

public class HelloServiceFlowControllerImpl implements HelloSerivce {

	@Override
	@RPCService(responsibilityName="xiaoy",serviceName="LAOPOPO.TEST.SAYHELLO",maxCallCountInMinute = 40)
	public String sayHello(String str) {
		return "hello "+ str;
	}

}

サービスプロバイダのコードは基本的に動かない:

package org.laopopo.example.generic.test_5;

import org.laopopo.client.provider.DefaultProvider;
import org.laopopo.common.exception.remoting.RemotingException;

/**
 * 
 * @author BazingaLyn
 * @description  
 * @time 2016 9 14 
 * @modifytime
 */
public class ProviderTest {
	
public static void main(String[] args) throws InterruptedException, RemotingException {
		
		DefaultProvider defaultProvider = new DefaultProvider();
		
		defaultProvider.serviceListenPort(8899) // 
					   .publishService(new HelloServiceFlowControllerImpl()) // 
					   .start(); // 
		
	}

}

消費者のコードは基本的に変更する必要はありません.

package org.laopopo.example.generic.test_5;

import org.laopopo.client.consumer.ConsumerClient;
import org.laopopo.client.consumer.proxy.ProxyFactory;
import org.laopopo.common.utils.UnresolvedAddress;

/**
 * 
 * @author BazingaLyn
 * @description  
 * @time
 * @modifytime
 */
public class ConsumerTest {
	
	public static void main(String[] args) throws Exception {
		
		ConsumerClient client = new ConsumerClient();

		client.start();
		
		UnresolvedAddress addresses = new UnresolvedAddress("127.0.0.1", 8899);
		
		HelloService helloService = ProxyFactory.factory(HelloService.class).consumer(client).addProviderAddress(addresses).timeoutMillis(3000l).newProxyInstance();
		
		for(int index = 1;index < 45;index++){
			
			String str = helloService.sayHello("Lyncc");
			System.out.println(" ：" + index);
			System.out.println(str);
			
		}
		
	}

}

サービスプロバイダを実行してから、サービス消費者を実行します.
基本的には問題なし~