io.vertx.core.VertxOptions.getClusterPublicPort()方法的使用及代码示例

x33g5p2x  于2022-01-31 转载在 其他  
字(15.1k)|赞(0)|评价(0)|浏览(108)

本文整理了Java中io.vertx.core.VertxOptions.getClusterPublicPort()方法的一些代码示例，展示了VertxOptions.getClusterPublicPort()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。VertxOptions.getClusterPublicPort()方法的具体详情如下：
包路径：io.vertx.core.VertxOptions
类名称：VertxOptions
方法名：getClusterPublicPort

VertxOptions.getClusterPublicPort介绍

[英]Get the public facing port to be used when clustering.
[中]

代码示例

代码示例来源：origin: eclipse-vertx/vert.x

json.put("clusterPublicHost", obj.getClusterPublicHost());
json.put("clusterPublicPort", obj.getClusterPublicPort());
json.put("clustered", obj.isClustered());
if (obj.getEventBusOptions() != null) {

代码示例来源：origin: eclipse-vertx/vert.x

@Test
public void testConfigureClusterPublicHostPortFromCommandLine() throws Exception {
 int clusterPublicPort = TestUtils.randomHighPortInt();
 MyLauncher launcher = new MyLauncher();
 String[] args = {"run", "java:" + TestVerticle.class.getCanonicalName(), "-cluster", "--cluster-public-host", "127.0.0.1", "--cluster-public-port", Integer.toString(clusterPublicPort)};
 launcher.dispatch(args);
 assertWaitUntil(() -> TestVerticle.instanceCount.get() == 1);
 assertEquals("127.0.0.1", launcher.options.getClusterPublicHost());
 assertEquals(clusterPublicPort, launcher.options.getClusterPublicPort());
}

代码示例来源：origin: eclipse-vertx/vert.x

clusterPublicHost = options.getClusterPublicHost();
if (options.getClusterPublicPort() != VertxOptions.DEFAULT_CLUSTER_PUBLIC_PORT) {
 clusterPublicPort = options.getClusterPublicPort();

代码示例来源：origin: eclipse-vertx/vert.x

@Test
public void testConfigureClusterHostPortFromProperties() throws Exception {
 int clusterPort = TestUtils.randomHighPortInt();
 System.setProperty(RunCommand.VERTX_OPTIONS_PROP_PREFIX + "clusterHost", "127.0.0.1");
 System.setProperty(RunCommand.VERTX_OPTIONS_PROP_PREFIX + "clusterPort", Integer.toString(clusterPort));
 MyLauncher launcher = new MyLauncher();
 String[] args = {"run", "java:" + TestVerticle.class.getCanonicalName(), "-cluster"};
 launcher.dispatch(args);
 assertWaitUntil(() -> TestVerticle.instanceCount.get() == 1);
 assertEquals("127.0.0.1", launcher.options.getClusterHost());
 assertEquals(clusterPort, launcher.options.getClusterPort());
 assertNull(launcher.options.getClusterPublicHost());
 assertEquals(-1, launcher.options.getClusterPublicPort());
}

代码示例来源：origin: eclipse-vertx/vert.x

@Test
public void testConfigureClusterHostPortFromCommandLine() throws Exception {
 int clusterPort = TestUtils.randomHighPortInt();
 MyLauncher launcher = new MyLauncher();
 String[] args = {"run", "java:" + TestVerticle.class.getCanonicalName(), "-cluster", "--cluster-host", "127.0.0.1", "--cluster-port", Integer.toString(clusterPort)};
 launcher.dispatch(args);
 assertWaitUntil(() -> TestVerticle.instanceCount.get() == 1);
 assertEquals("127.0.0.1", launcher.options.getClusterHost());
 assertEquals(clusterPort, launcher.options.getClusterPort());
 assertNull(launcher.options.getClusterPublicHost());
 assertEquals(-1, launcher.options.getClusterPublicPort());
}

代码示例来源：origin: eclipse-vertx/vert.x

@Test
public void testOverrideClusterHostPortFromProperties() throws Exception {
 int clusterPort = TestUtils.randomHighPortInt();
 int newClusterPort = TestUtils.randomHighPortInt();
 int newClusterPublicPort = TestUtils.randomHighPortInt();
 System.setProperty(RunCommand.VERTX_OPTIONS_PROP_PREFIX + "clusterHost", "127.0.0.2");
 System.setProperty(RunCommand.VERTX_OPTIONS_PROP_PREFIX + "clusterPort", Integer.toString(clusterPort));
 MyLauncher launcher = new MyLauncher();
 launcher.clusterHost = "127.0.0.1";
 launcher.clusterPort = newClusterPort;
 launcher.clusterPublicHost = "127.0.0.3";
 launcher.clusterPublicPort = newClusterPublicPort;
 String[] args = {"run", "java:" + TestVerticle.class.getCanonicalName(), "-cluster"};
 launcher.dispatch(args);
 assertWaitUntil(() -> TestVerticle.instanceCount.get() == 1);
 assertEquals("127.0.0.1", launcher.options.getClusterHost());
 assertEquals(newClusterPort, launcher.options.getClusterPort());
 assertEquals("127.0.0.3", launcher.options.getClusterPublicHost());
 assertEquals(newClusterPublicPort, launcher.options.getClusterPublicPort());
}

代码示例来源：origin: eclipse-vertx/vert.x

@Test
public void testOverrideClusterHostPortFromCommandLine() throws Exception {
 int clusterPort = TestUtils.randomHighPortInt();
 int clusterPublicPort = TestUtils.randomHighPortInt();
 int newClusterPort = TestUtils.randomHighPortInt();
 int newClusterPublicPort = TestUtils.randomHighPortInt();
 MyLauncher launcher = new MyLauncher();
 launcher.clusterHost = "127.0.0.1";
 launcher.clusterPort = newClusterPort;
 launcher.clusterPublicHost = "127.0.0.3";
 launcher.clusterPublicPort = newClusterPublicPort;
 String[] args = {
  "run", "java:" + TestVerticle.class.getCanonicalName(),
  "-cluster",
  "--cluster-host", "127.0.0.2", "--cluster-port", Integer.toString(clusterPort),
  "--cluster-public-host", "127.0.0.4", "--cluster-public-port", Integer.toString(clusterPublicPort)
 };
 launcher.dispatch(args);
 assertWaitUntil(() -> TestVerticle.instanceCount.get() == 1);
 assertEquals("127.0.0.1", launcher.options.getClusterHost());
 assertEquals(newClusterPort, launcher.options.getClusterPort());
 assertEquals("127.0.0.3", launcher.options.getClusterPublicHost());
 assertEquals(newClusterPublicPort, launcher.options.getClusterPublicPort());
}

代码示例来源：origin: eclipse-vertx/vert.x

assertEquals(-1, options.getClusterPublicPort());
assertEquals(20000, options.getClusterPingInterval());
assertEquals(20000, options.getClusterPingReplyInterval());
);
assertEquals(clusterPort, options.getClusterPort());
assertEquals(clusterPublicPort, options.getClusterPublicPort());
assertEquals(clusterPublicHost, options.getClusterPublicHost());
assertEquals(clusterPingInterval, options.getClusterPingInterval());

代码示例来源：origin: eclipse-vertx/vert.x

@Test
public void testDefaultJsonOptions() {
 VertxOptions def = new VertxOptions();
 VertxOptions json = new VertxOptions(new JsonObject());
 assertEquals(def.getEventLoopPoolSize(), json.getEventLoopPoolSize());
 assertEquals(def.getWorkerPoolSize(), json.getWorkerPoolSize());
 assertEquals(def.isClustered(), json.isClustered());
 assertEquals(def.getClusterHost(), json.getClusterHost());
 assertEquals(def.getClusterPublicHost(), json.getClusterPublicHost());
 assertEquals(def.getClusterPublicPort(), json.getClusterPublicPort());
 assertEquals(def.getClusterPingInterval(), json.getClusterPingInterval());
 assertEquals(def.getClusterPingReplyInterval(), json.getClusterPingReplyInterval());
 assertEquals(def.getBlockedThreadCheckInterval(), json.getBlockedThreadCheckInterval());
 assertEquals(def.getMaxEventLoopExecuteTime(), json.getMaxEventLoopExecuteTime());
 assertEquals(def.getMaxWorkerExecuteTime(), json.getMaxWorkerExecuteTime());
 assertEquals(def.getInternalBlockingPoolSize(), json.getInternalBlockingPoolSize());
 assertEquals(def.isHAEnabled(), json.isHAEnabled());
 assertEquals(def.getQuorumSize(), json.getQuorumSize());
 assertEquals(def.getHAGroup(), json.getHAGroup());
 assertEquals(def.getWarningExceptionTime(), json.getWarningExceptionTime());
 assertEquals(def.isFileResolverCachingEnabled(), json.isFileResolverCachingEnabled());
 assertEquals(def.getMaxEventLoopExecuteTimeUnit(), json.getMaxEventLoopExecuteTimeUnit());
 assertEquals(def.getMaxWorkerExecuteTimeUnit(), json.getMaxWorkerExecuteTimeUnit());
 assertEquals(def.getWarningExceptionTimeUnit(), json.getWarningExceptionTimeUnit());
 assertEquals(def.getBlockedThreadCheckIntervalUnit(), json.getBlockedThreadCheckIntervalUnit());
}

代码示例来源：origin: eclipse-vertx/vert.x

assertEquals(clusterPublicPort, options.getClusterPublicPort());
assertEquals(clusterPingInterval, options.getClusterPingInterval());
assertEquals(clusterPingReplyInterval, options.getClusterPingReplyInterval());

代码示例来源：origin: io.vertx/vertx-core

json.put("clusterPublicHost", obj.getClusterPublicHost());
json.put("clusterPublicPort", obj.getClusterPublicPort());
json.put("clustered", obj.isClustered());
if (obj.getEventBusOptions() != null) {

代码示例来源：origin: io.vertx/vertx-core

@Test
public void testConfigureClusterPublicHostPortFromCommandLine() throws Exception {
 int clusterPublicPort = TestUtils.randomHighPortInt();
 MyLauncher launcher = new MyLauncher();
 String[] args = {"run", "java:" + TestVerticle.class.getCanonicalName(), "-cluster", "--cluster-public-host", "127.0.0.1", "--cluster-public-port", Integer.toString(clusterPublicPort)};
 launcher.dispatch(args);
 assertWaitUntil(() -> TestVerticle.instanceCount.get() == 1);
 assertEquals("127.0.0.1", launcher.options.getClusterPublicHost());
 assertEquals(clusterPublicPort, launcher.options.getClusterPublicPort());
}

代码示例来源：origin: io.vertx/vertx-core

clusterPublicHost = options.getClusterPublicHost();
if (options.getClusterPublicPort() != VertxOptions.DEFAULT_CLUSTER_PUBLIC_PORT) {
 clusterPublicPort = options.getClusterPublicPort();

代码示例来源：origin: io.vertx/vertx-core

@Test
public void testConfigureClusterHostPortFromProperties() throws Exception {
 int clusterPort = TestUtils.randomHighPortInt();
 System.setProperty(RunCommand.VERTX_OPTIONS_PROP_PREFIX + "clusterHost", "127.0.0.1");
 System.setProperty(RunCommand.VERTX_OPTIONS_PROP_PREFIX + "clusterPort", Integer.toString(clusterPort));
 MyLauncher launcher = new MyLauncher();
 String[] args = {"run", "java:" + TestVerticle.class.getCanonicalName(), "-cluster"};
 launcher.dispatch(args);
 assertWaitUntil(() -> TestVerticle.instanceCount.get() == 1);
 assertEquals("127.0.0.1", launcher.options.getClusterHost());
 assertEquals(clusterPort, launcher.options.getClusterPort());
 assertNull(launcher.options.getClusterPublicHost());
 assertEquals(-1, launcher.options.getClusterPublicPort());
}

代码示例来源：origin: io.vertx/vertx-core

@Test
public void testConfigureClusterHostPortFromCommandLine() throws Exception {
 int clusterPort = TestUtils.randomHighPortInt();
 MyLauncher launcher = new MyLauncher();
 String[] args = {"run", "java:" + TestVerticle.class.getCanonicalName(), "-cluster", "--cluster-host", "127.0.0.1", "--cluster-port", Integer.toString(clusterPort)};
 launcher.dispatch(args);
 assertWaitUntil(() -> TestVerticle.instanceCount.get() == 1);
 assertEquals("127.0.0.1", launcher.options.getClusterHost());
 assertEquals(clusterPort, launcher.options.getClusterPort());
 assertNull(launcher.options.getClusterPublicHost());
 assertEquals(-1, launcher.options.getClusterPublicPort());
}

代码示例来源：origin: io.vertx/vertx-core

@Test
public void testOverrideClusterHostPortFromProperties() throws Exception {
 int clusterPort = TestUtils.randomHighPortInt();
 int newClusterPort = TestUtils.randomHighPortInt();
 int newClusterPublicPort = TestUtils.randomHighPortInt();
 System.setProperty(RunCommand.VERTX_OPTIONS_PROP_PREFIX + "clusterHost", "127.0.0.2");
 System.setProperty(RunCommand.VERTX_OPTIONS_PROP_PREFIX + "clusterPort", Integer.toString(clusterPort));
 MyLauncher launcher = new MyLauncher();
 launcher.clusterHost = "127.0.0.1";
 launcher.clusterPort = newClusterPort;
 launcher.clusterPublicHost = "127.0.0.3";
 launcher.clusterPublicPort = newClusterPublicPort;
 String[] args = {"run", "java:" + TestVerticle.class.getCanonicalName(), "-cluster"};
 launcher.dispatch(args);
 assertWaitUntil(() -> TestVerticle.instanceCount.get() == 1);
 assertEquals("127.0.0.1", launcher.options.getClusterHost());
 assertEquals(newClusterPort, launcher.options.getClusterPort());
 assertEquals("127.0.0.3", launcher.options.getClusterPublicHost());
 assertEquals(newClusterPublicPort, launcher.options.getClusterPublicPort());
}

代码示例来源：origin: io.vertx/vertx-core

@Test
public void testOverrideClusterHostPortFromCommandLine() throws Exception {
 int clusterPort = TestUtils.randomHighPortInt();
 int clusterPublicPort = TestUtils.randomHighPortInt();
 int newClusterPort = TestUtils.randomHighPortInt();
 int newClusterPublicPort = TestUtils.randomHighPortInt();
 MyLauncher launcher = new MyLauncher();
 launcher.clusterHost = "127.0.0.1";
 launcher.clusterPort = newClusterPort;
 launcher.clusterPublicHost = "127.0.0.3";
 launcher.clusterPublicPort = newClusterPublicPort;
 String[] args = {
  "run", "java:" + TestVerticle.class.getCanonicalName(),
  "-cluster",
  "--cluster-host", "127.0.0.2", "--cluster-port", Integer.toString(clusterPort),
  "--cluster-public-host", "127.0.0.4", "--cluster-public-port", Integer.toString(clusterPublicPort)
 };
 launcher.dispatch(args);
 assertWaitUntil(() -> TestVerticle.instanceCount.get() == 1);
 assertEquals("127.0.0.1", launcher.options.getClusterHost());
 assertEquals(newClusterPort, launcher.options.getClusterPort());
 assertEquals("127.0.0.3", launcher.options.getClusterPublicHost());
 assertEquals(newClusterPublicPort, launcher.options.getClusterPublicPort());
}

代码示例来源：origin: eclipse-vertx/vert.x

assertEquals(-1, options.getClusterPublicPort());
assertEquals(options, options.setClusterPublicPort(1234));
assertEquals(1234, options.getClusterPublicPort());
try {
 options.setClusterPublicPort(-1);

代码示例来源：origin: io.vertx/vertx-core

@Test
public void testDefaultJsonOptions() {
 VertxOptions def = new VertxOptions();
 VertxOptions json = new VertxOptions(new JsonObject());
 assertEquals(def.getEventLoopPoolSize(), json.getEventLoopPoolSize());
 assertEquals(def.getWorkerPoolSize(), json.getWorkerPoolSize());
 assertEquals(def.isClustered(), json.isClustered());
 assertEquals(def.getClusterHost(), json.getClusterHost());
 assertEquals(def.getClusterPublicHost(), json.getClusterPublicHost());
 assertEquals(def.getClusterPublicPort(), json.getClusterPublicPort());
 assertEquals(def.getClusterPingInterval(), json.getClusterPingInterval());
 assertEquals(def.getClusterPingReplyInterval(), json.getClusterPingReplyInterval());
 assertEquals(def.getBlockedThreadCheckInterval(), json.getBlockedThreadCheckInterval());
 assertEquals(def.getMaxEventLoopExecuteTime(), json.getMaxEventLoopExecuteTime());
 assertEquals(def.getMaxWorkerExecuteTime(), json.getMaxWorkerExecuteTime());
 assertEquals(def.getInternalBlockingPoolSize(), json.getInternalBlockingPoolSize());
 assertEquals(def.isHAEnabled(), json.isHAEnabled());
 assertEquals(def.getQuorumSize(), json.getQuorumSize());
 assertEquals(def.getHAGroup(), json.getHAGroup());
 assertEquals(def.getWarningExceptionTime(), json.getWarningExceptionTime());
 assertEquals(def.isFileResolverCachingEnabled(), json.isFileResolverCachingEnabled());
 assertEquals(def.getMaxEventLoopExecuteTimeUnit(), json.getMaxEventLoopExecuteTimeUnit());
 assertEquals(def.getMaxWorkerExecuteTimeUnit(), json.getMaxWorkerExecuteTimeUnit());
 assertEquals(def.getWarningExceptionTimeUnit(), json.getWarningExceptionTimeUnit());
 assertEquals(def.getBlockedThreadCheckIntervalUnit(), json.getBlockedThreadCheckIntervalUnit());
}

代码示例来源：origin: io.vertx/vertx-core

assertEquals(clusterPublicPort, options.getClusterPublicPort());
assertEquals(clusterPingInterval, options.getClusterPingInterval());
assertEquals(clusterPingReplyInterval, options.getClusterPingReplyInterval());

内容来源于网络，如有侵权，请联系作者删除！

vertxoptions

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    VertxOptions类方法

    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com