org.springframework.util.SocketUtils#findAvailableTcpPort ( )源码实例Demo

@Test
public void scheduledConnect() throws IOException, InterruptedException {
    final PinpointClientFactory clientFactory = new DefaultPinpointClientFactory();
    clientFactory.setReconnectDelay(200);
    PinpointClient client = null;

    TestPinpointServerAcceptor testPinpointServerAcceptor = null;
    try {
        int availableTcpPort = SocketUtils.findAvailableTcpPort(47000);
        client = clientFactory.scheduledConnect("localhost", availableTcpPort);

        testPinpointServerAcceptor = new TestPinpointServerAcceptor(testServerMessageListenerFactory);
        testPinpointServerAcceptor.bind(availableTcpPort);
        assertClientConnected(client);

        logger.debug("request server");
        byte[] randomByte = TestByteUtils.createRandomByte(10);
        byte[] response = PinpointRPCTestUtils.request(client, randomByte);

        Assert.assertArrayEquals(randomByte, response);
    } finally {
        PinpointRPCTestUtils.close(client);
        clientFactory.release();
        TestPinpointServerAcceptor.staticClose(testPinpointServerAcceptor);
    }
}
 

@Before
public void setUp() throws Exception {

	logger.debug("Setting up before '" + this.testName.getMethodName() + "'");

	int port = SocketUtils.findAvailableTcpPort(61613);

	this.activeMQBroker = new BrokerService();
	this.activeMQBroker.addConnector("stomp://127.0.0.1:" + port);
	this.activeMQBroker.setStartAsync(false);
	this.activeMQBroker.setPersistent(false);
	this.activeMQBroker.setUseJmx(false);
	this.activeMQBroker.getSystemUsage().getMemoryUsage().setLimit(1024 * 1024 * 5);
	this.activeMQBroker.getSystemUsage().getTempUsage().setLimit(1024 * 1024 * 5);
	this.activeMQBroker.start();

	ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
	taskScheduler.afterPropertiesSet();

	this.client = new Reactor2TcpStompClient("127.0.0.1", port);
	this.client.setMessageConverter(new StringMessageConverter());
	this.client.setTaskScheduler(taskScheduler);
}
 

@Test
public void contextLoads() throws Exception {
	int zkPort = SocketUtils.findAvailableTcpPort();
	TestingServer server = new TestingServer(zkPort);

	int port = SocketUtils.findAvailableTcpPort(zkPort + 1);

	ConfigurableApplicationContext context = new SpringApplicationBuilder(
			SampleZookeeperApplication.class).run("--server.port=" + port,
					"--management.endpoints.web.exposure.include=*",
					"--spring.cloud.zookeeper.connect-string=localhost:" + zkPort);

	ResponseEntity<String> response = new TestRestTemplate()
			.getForEntity("http://localhost:" + port + "/hi", String.class);
	assertThat(response.getStatusCode()).isEqualTo(HttpStatus.OK);

	context.close();
	server.close();
}
 

@Override
public void setup() {
	this.port = SocketUtils.findAvailableTcpPort();

	Connector connector = new Connector(Http11NioProtocol.class.getName());
	connector.setPort(this.port);

	File baseDir = createTempDir("tomcat");
	String baseDirPath = baseDir.getAbsolutePath();

	this.tomcatServer = new Tomcat();
	this.tomcatServer.setBaseDir(baseDirPath);
	this.tomcatServer.setPort(this.port);
	this.tomcatServer.getService().addConnector(connector);
	this.tomcatServer.setConnector(connector);
}
 

@Test
public void testHealthInfoCommand() {
    int smtpPort = SocketUtils.findAvailableTcpPort();
    ServerSetup setup = new ServerSetup(smtpPort, null, ServerSetup.PROTOCOL_SMTP);
    setup.setServerStartupTimeout(5000);
    GreenMail mailServer = new GreenMail(setup);
    JavaMailSenderImpl jmsi = (JavaMailSenderImpl) mailSender;
    mailServer.setUser(jmsi.getUsername(), jmsi.getPassword());
    mailServer.start();
    jmsi.setPort(smtpPort);
    sshCallShell((is, os) -> {
        write(os, "health info");
        verifyResponseContains(is, "{\r\n  \"status\" : \"UP\"");
        mailServer.stop();
    });
}
 

@Before
public void setup() throws Exception {
	logger.debug("Setting up before '" + this.testName.getMethodName() + "'");
	this.port = SocketUtils.findAvailableTcpPort(61613);
	this.responseChannel = new ExecutorSubscribableChannel();
	this.responseHandler = new TestMessageHandler();
	this.responseChannel.subscribe(this.responseHandler);
	this.eventPublisher = new TestEventPublisher();
	startActiveMqBroker();
	createAndStartRelay();
}
 

@Test
public void simpleHessianServiceExporter() throws IOException {
	final int port = SocketUtils.findAvailableTcpPort();

	TestBean tb = new TestBean("tb");
	SimpleHessianServiceExporter exporter = new SimpleHessianServiceExporter();
	exporter.setService(tb);
	exporter.setServiceInterface(ITestBean.class);
	exporter.setDebug(true);
	exporter.prepare();

	HttpServer server = HttpServer.create(new InetSocketAddress(port), -1);
	server.createContext("/hessian", exporter);
	server.start();
	try {
		HessianClientInterceptor client = new HessianClientInterceptor();
		client.setServiceUrl("http://localhost:" + port + "/hessian");
		client.setServiceInterface(ITestBean.class);
		//client.setHessian2(true);
		client.prepare();
		ITestBean proxy = ProxyFactory.getProxy(ITestBean.class, client);
		assertEquals("tb", proxy.getName());
		proxy.setName("test");
		assertEquals("test", proxy.getName());
	}
	finally {
		server.stop(Integer.MAX_VALUE);
	}
}
 

@Test
public void connectFail() {
    try {
        int availableTcpPort = SocketUtils.findAvailableTcpPort(47000);
        clientFactory.connect("127.0.0.1", availableTcpPort);
        Assert.fail();
    } catch (PinpointSocketException e) {
        Assert.assertTrue(ConnectException.class.isInstance(e.getCause()));
    } 
}
 

@BeforeClass
public static void init() {
    int port = SocketUtils.findAvailableTcpPort();
    System.setProperty("server.port", String.valueOf(port));
    System.setProperty("retrofit.client.url.tests.url", "http://localhost:"+port);
}
 

/**
 * Construct an EmbeddedZooKeeper with a random port.
 */
public EmbeddedZooKeeper() {
    clientPort = SocketUtils.findAvailableTcpPort();
}
 

/**
 * Construct an EmbeddedZooKeeper with a random port.
 */
public EmbeddedZooKeeper() {
    clientPort = SocketUtils.findAvailableTcpPort();
}
 

/**
 * Construct an EmbeddedZooKeeper with a random port.
 */
public EmbeddedZooKeeper() {
    clientPort = SocketUtils.findAvailableTcpPort();
}
 

@BeforeClass
public static void init() {
	int port = SocketUtils.findAvailableTcpPort();
	System.setProperty("server.port", String.valueOf(port));
	System.setProperty("retrofit.client.url.tests.url", "http://localhost:"+port);
}
 

/**
 * Construct an EmbeddedZooKeeper with a random port.
 */
public EmbeddedZooKeeper() {
    clientPort = SocketUtils.findAvailableTcpPort();
}
 

public static int randomFreePort() throws IOException {
    return SocketUtils.findAvailableTcpPort();
}
 

/**
 * Construct an EmbeddedZooKeeper with a random port.
 */
public EmbeddedZooKeeper() {
    clientPort = SocketUtils.findAvailableTcpPort();
}
 

public int bind() {
    int port = SocketUtils.findAvailableTcpPort(47000);
    return bind(port);
}
 

/**
 * Construct an EmbeddedZooKeeper with a random port.
 */
public EmbeddedZooKeeper() {
    clientPort = SocketUtils.findAvailableTcpPort();
}
 

/**
 * Construct an EmbeddedZooKeeper with a random port.
 */
public EmbeddedZooKeeper() {
    clientPort = SocketUtils.findAvailableTcpPort();
}
 

/**
 * Construct an EmbeddedZooKeeper with a random port.
 */
public EmbeddedZooKeeper() {
    clientPort = SocketUtils.findAvailableTcpPort();
}