github-forks
/
redisson
mirror of https://github.com/redisson/redisson.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Redis server now runs on a random port

Browse Source 
added one more timeout
pull/616/head
jackygurui 9 years ago
parent 780b58e429
commit 6f7f55a8ee
5 changed files with 86 additions and 31 deletions
Show Stats Download Patch File Download Diff File

10
redisson/src/test/java/org/redisson/BaseTest.java
Unescape Escape View File

@ -61,15 +61,15 @@ public abstract class BaseTest {
}
public static Config createConfig() {
String redisAddress = System.getProperty("redisAddress");
if (redisAddress == null) {
redisAddress = "127.0.0.1:6379";
}
// String redisAddress = System.getProperty("redisAddress");
// if (redisAddress == null) {
// redisAddress = "127.0.0.1:6379";
// }
Config config = new Config();
// config.setCodec(new MsgPackJacksonCodec());
// config.useSentinelServers().setMasterName("mymaster").addSentinelAddress("127.0.0.1:26379", "127.0.0.1:26389");
// config.useClusterServers().addNodeAddress("127.0.0.1:7004", "127.0.0.1:7001", "127.0.0.1:7000");
config.useSingleServer().setAddress(redisAddress);
config.useSingleServer().setAddress(RedisRunner.getDefaultRedisServerBindAddressAndPort());
// .setPassword("mypass1");
// config.useMasterSlaveConnection()
// .setMasterAddress("127.0.0.1:6379")

12
redisson/src/test/java/org/redisson/RedisClientTest.java
Unescape Escape View File

@ -75,7 +75,7 @@ public class RedisClientTest {
@Test
public void testConnectAsync() throws InterruptedException {
RedisClient c = new RedisClient("localhost", 6379);
RedisClient c = new RedisClient(RedisRunner.getDefaultRedisServerBindAddressAndPort());
RFuture<RedisConnection> f = c.connectAsync();
final CountDownLatch l = new CountDownLatch(1);
f.addListener((FutureListener<RedisConnection>) future -> {
@ -88,7 +88,7 @@ public class RedisClientTest {
@Test
public void testSubscribe() throws InterruptedException {
RedisClient c = new RedisClient("localhost", 6379);
RedisClient c = new RedisClient(RedisRunner.getDefaultRedisServerBindAddressAndPort());
RedisPubSubConnection pubSubConnection = c.connectPubSub();
final CountDownLatch latch = new CountDownLatch(2);
pubSubConnection.addListener(new RedisPubSubListener<Object>() {
@ -116,7 +116,7 @@ public class RedisClientTest {
@Test
public void test() throws InterruptedException {
RedisClient c = new RedisClient("localhost", 6379);
RedisClient c = new RedisClient(RedisRunner.getDefaultRedisServerBindAddressAndPort());
final RedisConnection conn = c.connect();
conn.sync(StringCodec.INSTANCE, RedisCommands.SET, "test", 0);
@ -138,7 +138,7 @@ public class RedisClientTest {
@Test
public void testPipeline() throws InterruptedException, ExecutionException {
RedisClient c = new RedisClient("localhost", 6379);
RedisClient c = new RedisClient(RedisRunner.getDefaultRedisServerBindAddressAndPort());
RedisConnection conn = c.connect();
conn.sync(StringCodec.INSTANCE, RedisCommands.SET, "test", 0);
@ -166,7 +166,7 @@ public class RedisClientTest {
@Test
public void testBigRequest() throws InterruptedException, ExecutionException {
RedisClient c = new RedisClient("localhost", 6379);
RedisClient c = new RedisClient(RedisRunner.getDefaultRedisServerBindAddressAndPort());
RedisConnection conn = c.connect();
for (int i = 0; i < 50; i++) {
@ -181,7 +181,7 @@ public class RedisClientTest {
@Test
public void testPipelineBigResponse() throws InterruptedException, ExecutionException {
RedisClient c = new RedisClient("localhost", 6379);
RedisClient c = new RedisClient(RedisRunner.getDefaultRedisServerBindAddressAndPort());
RedisConnection conn = c.connect();
List<CommandData<?, ?>> commands = new ArrayList<CommandData<?, ?>>();

65
redisson/src/test/java/org/redisson/RedisRunner.java
Unescape Escape View File

@ -32,7 +32,6 @@ public class RedisRunner {
DAEMONIZE,
PIDFILE,
PORT,
RANDOM_PORT,
TCP_BACKLOG,
BIND(true),
UNIXSOCKET,
@ -181,7 +180,8 @@ public class RedisRunner {
private boolean randomDir = false;
private ArrayList<String> bindAddr = new ArrayList<>();
private int port = 6379;
private boolean randomPort = true;
private int retryCount = Integer.MAX_VALUE;
private boolean randomPort = false;
{
this.options.put(REDIS_OPTIONS.BINARY_PATH, RedissonRuntimeEnvironment.redisBinaryPath);
@ -231,11 +231,31 @@ public class RedisRunner {
return new RedisProcess(p, runner);
}
public RedisProcess run() throws IOException, InterruptedException {
public RedisProcess run() throws IOException, InterruptedException, FailedToStartRedisException {
if (!options.containsKey(REDIS_OPTIONS.DIR)) {
options.put(REDIS_OPTIONS.DIR, defaultDir);
addConfigOption(REDIS_OPTIONS.DIR, defaultDir);
}
if (randomPort) {
for (int i = 0; i < retryCount; i++) {
this.port = findFreePort();
addConfigOption(REDIS_OPTIONS.PORT, this.port);
try {
return runAndCheck();
} catch (FailedToStartRedisException e) {
}
}
throw new FailedToStartRedisException();
} else {
return runAndCheck();
}
return runWithOptions(this, options.values().toArray(new String[0]));
}
public RedisProcess runAndCheck() throws IOException, InterruptedException, FailedToStartRedisException {
RedisProcess rp = runWithOptions(this, options.values().toArray(new String[0]));
if (rp.redisProcess.waitFor(1000, TimeUnit.MILLISECONDS)) {
throw new FailedToStartRedisException();
}
return rp;
}
private void addConfigOption(REDIS_OPTIONS option, Object... args) {
@ -275,7 +295,12 @@ public class RedisRunner {
}
public RedisRunner randomPort() {
return randomPort(Integer.MAX_VALUE);
}
public RedisRunner randomPort(int retryCount) {
this.randomPort = true;
this.retryCount = retryCount;
options.remove(REDIS_OPTIONS.PORT);
return this;
}
@ -753,13 +778,20 @@ public class RedisRunner {
}
return redisVersion;
}
public int getRedisServerPort() {
return runner.getPort();
}
public String getRedisServerBindAddress() {
return runner.getInitialBindAddr();
}
}
public static RedisRunner.RedisProcess startDefaultRedisServerInstance() throws IOException, InterruptedException {
public static RedisRunner.RedisProcess startDefaultRedisServerInstance() throws IOException, InterruptedException, FailedToStartRedisException {
if (defaultRedisInstance == null) {
System.out.println("REDIS RUNNER: Starting up default instance...");
defaultRedisInstance = new RedisRunner().nosave().randomDir().run();
defaultRedisInstance = new RedisRunner().nosave().randomDir().randomPort().run();
Runtime.getRuntime().addShutdownHook(new Thread(() -> {
try {
shutDownDefaultRedisServerInstance();
@ -795,8 +827,14 @@ public class RedisRunner {
public static RedisRunner.RedisProcess getDefaultRedisServerInstance() {
return defaultRedisInstance;
}
public static String getDefaultRedisServerBindAddressAndPort() {
return defaultRedisInstance.getRedisServerBindAddress()
+ ":"
+ defaultRedisInstance.getRedisServerPort();
}
private static int findFreePort() {
public static int findFreePort() {
ServerSocket socket = null;
try {
socket = new ServerSocket(0);
@ -817,6 +855,13 @@ public class RedisRunner {
}
}
}
throw new IllegalStateException("Could not find a free TCP/IP port to start embedded Jetty HTTP Server on");
throw new IllegalStateException("Could not find a free TCP/IP port.");
}
public static class FailedToStartRedisException extends RuntimeException {
private FailedToStartRedisException() {
}
}
}

8
redisson/src/test/java/org/redisson/RedissonTest.java
Unescape Escape View File

@ -117,7 +117,7 @@ public class RedissonTest {
@Test(expected = RedisException.class)
public void testSer() {
Config config = new Config();
config.useSingleServer().setAddress("127.0.0.1:6379");
config.useSingleServer().setAddress(RedisRunner.getDefaultRedisServerBindAddressAndPort());
config.setCodec(new SerializationCodec());
RedissonClient r = Redisson.create(config);
r.getMap("test").put("1", new Dummy());
@ -163,7 +163,7 @@ public class RedissonTest {
public void testConfigValidation() {
Config redissonConfig = new Config();
redissonConfig.useSingleServer()
.setAddress("127.0.0.1:6379")
.setAddress(RedisRunner.getDefaultRedisServerBindAddressAndPort())
.setConnectionPoolSize(2);
Redisson.create(redissonConfig);
}
@ -221,7 +221,7 @@ public class RedissonTest {
@Test
public void testShutdown() {
Config config = new Config();
config.useSingleServer().setAddress("127.0.0.1:6379");
config.useSingleServer().setAddress(RedisRunner.getDefaultRedisServerBindAddressAndPort());
RedissonClient r = Redisson.create(config);
Assert.assertFalse(r.isShuttingDown());
@ -349,7 +349,7 @@ public class RedissonTest {
redisConfig.useSingleServer()
.setConnectionMinimumIdleSize(10000)
.setConnectionPoolSize(10000)
.setAddress("localhost:6379");
.setAddress(RedisRunner.getDefaultRedisServerBindAddressAndPort());
RedissonClient r = Redisson.create(redisConfig);
r.shutdown();
}

22
redisson/src/test/java/org/redisson/connection/balancer/WeightedRoundRobinBalancerTest.java
Unescape Escape View File

@ -7,8 +7,11 @@ import java.io.IOException;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import org.junit.ClassRule;
import org.junit.Rule;
import org.junit.Test;
import org.junit.rules.Timeout;
import org.redisson.RedisRunner;
import org.redisson.RedisRunner.RedisProcess;
import org.redisson.Redisson;
@ -18,24 +21,31 @@ import org.redisson.config.ReadMode;
public class WeightedRoundRobinBalancerTest {
@ClassRule
public static Timeout classTimeout = new Timeout(1, TimeUnit.HOURS);
@Rule
public Timeout testTimeout = new Timeout(15, TimeUnit.MINUTES);
@Test
public void testUseMasterForReadsIfNoConnectionsToSlaves() throws IOException, InterruptedException {
RedisProcess master = null;
RedisProcess slave = null;
RedissonClient client = null;
try {
master = redisTestInstance(6379);
slave = redisTestInstance(6380);
int mPort = RedisRunner.findFreePort();
int sPort = RedisRunner.findFreePort();
master = redisTestInstance(mPort);
slave = redisTestInstance(sPort);
Map<String, Integer> weights = new HashMap<>();
weights.put("127.0.0.1:6379", 1);
weights.put("127.0.0.1:6380", 2);
weights.put("127.0.0.1:" + mPort, 1);
weights.put("127.0.0.1:" + sPort, 2);
Config config = new Config();
config.useMasterSlaveServers()
.setReadMode(ReadMode.SLAVE)
.setMasterAddress("127.0.0.1:6379")
.addSlaveAddress("127.0.0.1:6380")
.setMasterAddress("127.0.0.1:" + mPort)
.addSlaveAddress("127.0.0.1:" + sPort)
.setLoadBalancer(new WeightedRoundRobinBalancer(weights, 1));
client = Redisson.create(config);

Write Preview
Loading…
Cancel
Save