diff --git a/src/main/java/com/moilioncircle/redis/replicator/RedisSocketReplicator.java b/src/main/java/com/moilioncircle/redis/replicator/RedisSocketReplicator.java index 740dd003..2cc56610 100644 --- a/src/main/java/com/moilioncircle/redis/replicator/RedisSocketReplicator.java +++ b/src/main/java/com/moilioncircle/redis/replicator/RedisSocketReplicator.java @@ -198,7 +198,7 @@ private void auth(String password) throws IOException { } private void sendSlavePort() throws IOException { - //REPLCONF listening-prot 6380 + //REPLCONF listening-prot ${port} logger.info("REPLCONF listening-port " + socket.getLocalPort()); send("REPLCONF".getBytes(), "listening-port".getBytes(), String.valueOf(socket.getLocalPort()).getBytes()); final String reply = (String) reply(); @@ -208,7 +208,7 @@ private void sendSlavePort() throws IOException { } private void sendSlaveIp() throws IOException { - //REPLCONF capa eof + //REPLCONF ip-address ${address} logger.info("REPLCONF ip-address " + socket.getLocalAddress().getHostAddress()); send("REPLCONF".getBytes(), "ip-address".getBytes(), socket.getLocalAddress().getHostAddress().getBytes()); final String reply = (String) reply();