redis · ggivo · Nov 19, 2025 · Nov 10, 2025 · Nov 12, 2025 · Nov 12, 2025
diff --git a/pom.xml b/pom.xml
@@ -518,6 +518,12 @@
 						<include>src/test/java/redis/clients/jedis/commands/jedis/ClusterStreamsCommandsTest.java</include>
 						<include>src/test/java/redis/clients/jedis/commands/jedis/PooledStreamsCommandsTest.java</include>
 						<include>src/test/java/redis/clients/jedis/resps/StreamEntryDeletionResultTest.java</include>
+                        <include>src/test/java/redis/clients/jedis/commands/commandobjects/CommandObjectsStringCommandsTest.java</include>
+                        <include>src/test/java/redis/clients/jedis/commands/jedis/BinaryValuesCommandsTest.java</include>
+                        <include>src/test/java/redis/clients/jedis/commands/jedis/StringValuesCommandsTest.java</include>
+                        <include>src/test/java/redis/clients/jedis/commands/unified/BinaryValuesCommandsTestBase.java</include>
+                        <include>src/test/java/redis/clients/jedis/commands/unified/StringValuesCommandsTestBase.java</include>
+                        <include>src/test/java/redis/clients/jedis/commands/unified/cluster/ClusterStringValuesCommandsTest.java</include>
 						<include>**/VectorSet*.java</include>
 						<include>**/VectorTestUtils.java</include>
 						<include>**/VAddParams.java</include>
@@ -538,6 +544,7 @@
 						<include>**/ClientTestUtil.java</include>
 						<include>**/ReflectionTestUtil.java</include>
 						<include>**/*CommandFlags*.java</include>
+						<include>**/*MSetExParams*.java</include>
 					</includes>
 				</configuration>
 				<executions>

diff --git a/src/main/java/redis/clients/jedis/CommandObjects.java b/src/main/java/redis/clients/jedis/CommandObjects.java
@@ -49,7 +49,7 @@ protected RedisProtocol getProtocol() {
 
   protected volatile CommandKeyArgumentPreProcessor keyPreProcessor = null;
   private JedisBroadcastAndRoundRobinConfig broadcastAndRoundRobinConfig = null;
-  private Lock mapperLock = new ReentrantLock(true);    
+  private Lock mapperLock = new ReentrantLock(true);
   private volatile JsonObjectMapper jsonObjectMapper;
   private final AtomicInteger searchDialect = new AtomicInteger(SearchProtocol.DEFAULT_DIALECT);
 
@@ -588,6 +588,20 @@ public final CommandObject<Long> msetnx(String... keysvalues) {
     return new CommandObject<>(addFlatKeyValueArgs(commandArguments(MSETNX), keysvalues), BuilderFactory.LONG);
   }
 
+  public final CommandObject<Boolean> msetex(MSetExParams params, String... keysvalues) {
+    CommandArguments args = commandArguments(Command.MSETEX).add(keysvalues.length / 2);
+    addFlatKeyValueArgs(args, keysvalues);
+    args.addParams(params);
+    return new CommandObject<>(args, BuilderFactory.BOOLEAN);
+  }
+
+  public final CommandObject<Boolean> msetex(MSetExParams params, byte[]... keysvalues) {
+    CommandArguments args = commandArguments(Command.MSETEX).add(keysvalues.length / 2);
+    addFlatKeyValueArgs(args, keysvalues);
+    args.addParams(params);
+    return new CommandObject<>(args, BuilderFactory.BOOLEAN);
+  }
+
   public final CommandObject<String> mset(byte[]... keysvalues) {
     return new CommandObject<>(addFlatKeyValueArgs(commandArguments(MSET), keysvalues), BuilderFactory.STRING);
   }
@@ -2977,7 +2991,7 @@ public final CommandObject<List<Object>> xreadGroup(byte[] groupName, byte[] con
   }
 
   public final CommandObject<List<Map.Entry<byte[], List<StreamEntryBinary>>>> xreadGroupBinary(
-      byte[] groupName, byte[] consumer, XReadGroupParams xReadGroupParams, 
+      byte[] groupName, byte[] consumer, XReadGroupParams xReadGroupParams,
       Map.Entry<byte[], StreamEntryID>... streams) {
     CommandArguments args = commandArguments(XREADGROUP)
         .add(GROUP).add(groupName).add(consumer)
@@ -2992,7 +3006,7 @@ public final CommandObject<List<Map.Entry<byte[], List<StreamEntryBinary>>>> xre
   }
 
   public final CommandObject<Map<byte[], List<StreamEntryBinary>>> xreadGroupBinaryAsMap(
-      byte[] groupName, byte[] consumer, XReadGroupParams xReadGroupParams, 
+      byte[] groupName, byte[] consumer, XReadGroupParams xReadGroupParams,
       Map.Entry<byte[], StreamEntryID>... streams) {
     CommandArguments args = commandArguments(XREADGROUP)
         .add(GROUP).add(groupName).add(consumer)

diff --git a/src/main/java/redis/clients/jedis/Jedis.java b/src/main/java/redis/clients/jedis/Jedis.java
@@ -984,6 +984,12 @@ public long msetnx(final byte[]... keysvalues) {
     return connection.executeCommand(commandObjects.msetnx(keysvalues));
   }
 
+  @Override
+  public boolean msetex(final MSetExParams params, final byte[]... keysvalues) {
+    checkIsInMultiOrPipeline();
+    return connection.executeCommand(commandObjects.msetex(params, keysvalues));
+  }
+
   /**
    * DECRBY work just like {@link Jedis#decr(byte[]) DECR} but instead to decrement by 1 the
    * decrement is integer.
@@ -5597,6 +5603,12 @@ public long msetnx(final String... keysvalues) {
     return connection.executeCommand(commandObjects.msetnx(keysvalues));
   }
 
+  @Override
+  public boolean msetex(final MSetExParams params, final String... keysvalues) {
+    checkIsInMultiOrPipeline();
+    return connection.executeCommand(commandObjects.msetex(params, keysvalues));
+  }
+
   /**
    * IDECRBY work just like {@link Jedis#decr(String) INCR} but instead to decrement by 1 the
    * decrement is integer.
@@ -5805,13 +5817,13 @@ public String hget(final String key, final String field) {
   }
 
   @Override
-  public List<String> hgetex(String key, HGetExParams params, String... fields) {    
+  public List<String> hgetex(String key, HGetExParams params, String... fields) {
     checkIsInMultiOrPipeline();
     return connection.executeCommand(commandObjects.hgetex(key, params, fields));
   }
 
   @Override
-  public List<String> hgetdel(String key, String... fields) {    
+  public List<String> hgetdel(String key, String... fields) {
     checkIsInMultiOrPipeline();
     return connection.executeCommand(commandObjects.hgetdel(key, fields));
   }

diff --git a/src/main/java/redis/clients/jedis/PipeliningBase.java b/src/main/java/redis/clients/jedis/PipeliningBase.java
@@ -349,6 +349,11 @@ public Response<Long> msetnx(String... keysvalues) {
     return appendCommand(commandObjects.msetnx(keysvalues));
   }
 
+  @Override
+  public Response<Boolean> msetex(MSetExParams params, String... keysvalues) {
+    return appendCommand(commandObjects.msetex(params, keysvalues));
+  }
+
   @Override
   public Response<Long> incr(String key) {
     return appendCommand(commandObjects.incr(key));
@@ -630,13 +635,13 @@ public Response<Long> hset(String key, Map<String, String> hash) {
    * and optionally set their expiration. Use `HSetExParams` object to specify expiration parameters.
    * This command can overwrite any existing fields in the hash.
    * If key does not exist, a new key holding a hash is created.
-   * 
+   *
    * @param key the key of the hash
    * @param params additional parameters for the HSETEX command
    * @param field the field in the hash to set
    * @param value the value to set in the specified field
-   * @return 0 if no fields were set, 1 if all the fields were set 
-   * 
+   * @return 0 if no fields were set, 1 if all the fields were set
+   *
    * @see HSetExParams
    */
   @Override
@@ -649,12 +654,12 @@ public Response<Long> hsetex(String key, HSetExParams params, String field, Stri
    * and optionally set their expiration. Use `HSetExParams` object to specify expiration parameters.
    * This command can overwrite any existing fields in the hash.
    * If key does not exist, a new key holding a hash is created.
-   * 
+   *
    * @param key the key of the hash
    * @param params the parameters for the HSetEx command
    * @param hash the map containing field-value pairs to set in the hash
-   * @return 0 if no fields were set, 1 if all the fields were set 
-   * 
+   * @return 0 if no fields were set, 1 if all the fields were set
+   *
    * @see HSetExParams
    */
   @Override
@@ -668,14 +673,14 @@ public Response<String> hget(String key, String field) {
   }

   /**
-   * Retrieves the values associated with the specified fields in a hash stored at the given key 
+   * Retrieves the values associated with the specified fields in a hash stored at the given key
    * and optionally sets their expiration. Use `HGetExParams` object to specify expiration parameters.
    *
    * @param key the key of the hash
    * @param params additional parameters for the HGETEX command
    * @param fields the fields whose values are to be retrieved
    * @return a list of the value associated with each field or nil if the field doesn’t exist.
-   * 
+   *
    * @see HGetExParams
    */
   @Override
@@ -2062,13 +2067,13 @@ public Response<Long> hset(byte[] key, Map<byte[], byte[]> hash) {
    * and optionally set their expiration. Use `HSetExParams` object to specify expiration parameters.
    * This command can overwrite any existing fields in the hash.
    * If key does not exist, a new key holding a hash is created.
-   * 
+   *
    * @param key the key of the hash
    * @param params the parameters for the HSetEx command
    * @param field the field in the hash to set
    * @param value the value to set in the specified field
-   * @return 0 if no fields were set, 1 if all the fields were set 
-   * 
+   * @return 0 if no fields were set, 1 if all the fields were set
+   *
    * @see HSetExParams
    */
   @Override
@@ -2081,12 +2086,12 @@ public Response<Long> hsetex(byte[] key, HSetExParams params, byte[] field, byte
    * and optionally set their expiration. Use `HSetExParams` object to specify expiration parameters.
    * This command can overwrite any existing fields in the hash.
    * If key does not exist, a new key holding a hash is created.
-   * 
+   *
    * @param key the key of the hash
    * @param params the parameters for the HSetEx command
    * @param hash the map containing field-value pairs to set in the hash
-   * @return 0 if no fields were set, 1 if all the fields were set 
-   * 
+   * @return 0 if no fields were set, 1 if all the fields were set
+   *
    * @see HSetExParams
    */
   @Override
@@ -2098,16 +2103,16 @@ public Response<Long> hsetex(byte[] key, HSetExParams params, Map<byte[], byte[]
   public Response<byte[]> hget(byte[] key, byte[] field) {
     return appendCommand(commandObjects.hget(key, field));
   }
-  
+
   /**
-   * Retrieves the values associated with the specified fields in a hash stored at the given key 
+   * Retrieves the values associated with the specified fields in a hash stored at the given key
    * and optionally sets their expiration. Use `HGetExParams` object to specify expiration parameters.
    *
    * @param key the key of the hash
    * @param params additional parameters for the HGETEX command
    * @param fields the fields whose values are to be retrieved
    * @return a list of the value associated with each field or nil if the field doesn’t exist.
-   * 
+   *
    * @see HGetExParams
    */
   @Override
@@ -3538,6 +3543,11 @@ public Response<String> mset(byte[]... keysvalues) {
     return appendCommand(commandObjects.mset(keysvalues));
   }
 
+  @Override
+  public Response<Boolean> msetex(MSetExParams params, byte[]... keysvalues) {
+    return appendCommand(commandObjects.msetex(params, keysvalues));
+  }
+
   @Override
   public Response<Long> msetnx(byte[]... keysvalues) {
     return appendCommand(commandObjects.msetnx(keysvalues));

diff --git a/src/main/java/redis/clients/jedis/Protocol.java b/src/main/java/redis/clients/jedis/Protocol.java
@@ -287,7 +287,7 @@ public static enum Command implements ProtocolCommand {
     KEYS, RANDOMKEY, RENAME, RENAMENX, DUMP, RESTORE, DBSIZE, SELECT, SWAPDB, MIGRATE, ECHO, //
     EXPIRE, EXPIREAT, EXPIRETIME, PEXPIRE, PEXPIREAT, PEXPIRETIME, TTL, PTTL, // <-- key expiration
     MULTI, DISCARD, EXEC, WATCH, UNWATCH, SORT, SORT_RO, INFO, SHUTDOWN, MONITOR, CONFIG, LCS, //
-    GETSET, MGET, SETNX, SETEX, PSETEX, MSET, MSETNX, DECR, DECRBY, INCR, INCRBY, INCRBYFLOAT,
+    GETSET, MGET, SETNX, SETEX, PSETEX, MSETEX, MSET, MSETNX, DECR, DECRBY, INCR, INCRBY, INCRBYFLOAT,
     STRLEN, APPEND, SUBSTR, // <-- string
     SETBIT, GETBIT, BITPOS, SETRANGE, GETRANGE, BITCOUNT, BITOP, BITFIELD, BITFIELD_RO, // <-- bit (string)
     HSET, HGET, HSETNX, HMSET, HMGET, HINCRBY, HEXISTS, HDEL, HLEN, HKEYS, HVALS, HGETALL, HSTRLEN,

diff --git a/src/main/java/redis/clients/jedis/StaticCommandFlagsRegistryInitializer.java b/src/main/java/redis/clients/jedis/StaticCommandFlagsRegistryInitializer.java
@@ -299,6 +299,7 @@ static void initialize(StaticCommandFlagsRegistry.Builder builder) {
     builder.register("LSET", EnumSet.of(CommandFlag.DENYOOM, CommandFlag.WRITE));
     builder.register("MSET", EnumSet.of(CommandFlag.DENYOOM, CommandFlag.WRITE));
     builder.register("MSETNX", EnumSet.of(CommandFlag.DENYOOM, CommandFlag.WRITE));
+    builder.register("MSETEX", EnumSet.of(CommandFlag.DENYOOM, CommandFlag.WRITE));
     builder.register("PFMERGE", EnumSet.of(CommandFlag.DENYOOM, CommandFlag.WRITE));
     builder.register("PSETEX", EnumSet.of(CommandFlag.DENYOOM, CommandFlag.WRITE));
     builder.register("RESTORE", EnumSet.of(CommandFlag.DENYOOM, CommandFlag.WRITE));

diff --git a/src/main/java/redis/clients/jedis/UnifiedJedis.java b/src/main/java/redis/clients/jedis/UnifiedJedis.java
@@ -968,6 +968,11 @@ public long msetnx(String... keysvalues) {
     return executeCommand(commandObjects.msetnx(keysvalues));
   }
 
+  @Override
+  public boolean msetex(MSetExParams params, String... keysvalues) {
+    return executeCommand(commandObjects.msetex(params, keysvalues));
+  }
+
   @Override
   public List<byte[]> mget(byte[]... keys) {
     return executeCommand(commandObjects.mget(keys));
@@ -978,6 +983,11 @@ public String mset(byte[]... keysvalues) {
     return executeCommand(commandObjects.mset(keysvalues));
   }
 
+  @Override
+  public boolean msetex(MSetExParams params, byte[]... keysvalues) {
+    return executeCommand(commandObjects.msetex(params, keysvalues));
+  }
+
   @Override
   public long msetnx(byte[]... keysvalues) {
     return executeCommand(commandObjects.msetnx(keysvalues));
@@ -1446,12 +1456,12 @@ public long hsetex(String key, HSetExParams params, String field, String value)
   public long hsetex(String key, HSetExParams params, Map<String, String> hash) {
     return executeCommand(commandObjects.hsetex(key, params, hash));
   }
-  
+
   @Override
   public String hget(String key, String field) {
     return executeCommand(commandObjects.hget(key, field));
   }
-    
+
   @Override
   public List<String> hgetex(String key, HGetExParams params, String... fields) {
     return executeCommand(commandObjects.hgetex(key, params, fields));
@@ -3997,7 +4007,7 @@ public SearchResult ftSearch(String indexName, String query, FTSearchParams para
 
   /**
    * {@link FTSearchParams#limit(int, int)} will be ignored.
-   * 
+   *
    * @param batchSize batch size
    * @param indexName index name
    * @param query query

diff --git a/src/main/java/redis/clients/jedis/commands/StringBinaryCommands.java b/src/main/java/redis/clients/jedis/commands/StringBinaryCommands.java
@@ -4,6 +4,8 @@
 
 import redis.clients.jedis.params.GetExParams;
 import redis.clients.jedis.params.SetParams;
+import redis.clients.jedis.params.MSetExParams;
+
 import redis.clients.jedis.params.LCSParams;
 import redis.clients.jedis.resps.LCSMatchResult;
 
@@ -45,6 +47,28 @@ public interface StringBinaryCommands extends BitBinaryCommands {
 
   long msetnx(byte[]... keysvalues);
 
+  /**
+   * Multi-set with optional condition and expiration.
+   * <p>
+   * Sets the respective keys to the respective values, similar to {@link #mset(byte[]...) MSET},
+   * but allows conditional set (NX|XX) and expiration options via {@link MSetExParams}.
+   * If the condition is not met for any key, no key is set.
+   * <p>
+   * Both MSET and MSETEX are atomic operations. This means that if multiple keys are provided,
+   * another client will either see the changes for all keys at once, or no changes at all.
+   * <p>
+   * Options (in {@link MSetExParams}): NX or XX, and expiration: EX seconds | PX milliseconds |
+   * EXAT unix-time-seconds | PXAT unix-time-milliseconds | KEEPTTL.
+   * <p>
+   * Time complexity: O(N) where N is the number of keys to set.
+   * @param params condition and expiration parameters
+   * @param keysvalues pairs of keys and their values, e.g. {@code msetex(params, "foo".getBytes(), "foovalue".getBytes(), "bar".getBytes(), "barvalue".getBytes())}
+   * @return {@code true} if all the keys were set, {@code false} if none were set (condition not satisfied)
+   * @see #mset(byte[]...)
+   * @see #msetnx(byte[]...)
+   */
+  boolean msetex(MSetExParams params, byte[]... keysvalues);
+
   long incr(byte[] key);
 
   long incrBy(byte[] key, long increment);

diff --git a/src/main/java/redis/clients/jedis/commands/StringCommands.java b/src/main/java/redis/clients/jedis/commands/StringCommands.java
@@ -4,6 +4,8 @@
 
 import redis.clients.jedis.params.GetExParams;
 import redis.clients.jedis.params.SetParams;
+import redis.clients.jedis.params.MSetExParams;
+
 import redis.clients.jedis.params.LCSParams;
 import redis.clients.jedis.resps.LCSMatchResult;
 
@@ -210,6 +212,28 @@ public interface StringCommands extends BitCommands {
    */
   long msetnx(String... keysvalues);
 
+  /**
+   * Multi-set with optional condition and expiration.
+   * <p>
+   * Sets the respective keys to the respective values, similar to {@link #mset(String...) MSET},
+   * but allows conditional set (NX|XX) and expiration options via {@link MSetExParams}.
+   * If the condition is not met for any key, no key is set.
+   * <p>
+   * Both MSET and MSETEX are atomic operations. This means that if multiple keys are provided,
+   * another client will either see the changes for all keys at once, or no changes at all.
+   * <p>
+   * Options (in {@link MSetExParams}): NX or XX, and expiration: EX seconds | PX milliseconds |
+   * EXAT unix-time-seconds | PXAT unix-time-milliseconds | KEEPTTL.
+   * <p>
+   * Time complexity: O(N) where N is the number of keys to set.
+   * @param params condition and expiration parameters
+   * @param keysvalues pairs of keys and their values, e.g. {@code msetex(params, "foo", "foovalue", "bar", "barvalue")}
+   * @return {@code true} if all the keys were set, {@code false} if none were set (condition not satisfied)
+   * @see #mset(String...)
+   * @see #msetnx(String...)
+   */
+  boolean msetex(MSetExParams params, String... keysvalues);
+
   /**
    * <b><a href="http://redis.io/commands/incr">Incr Command</a></b>
    * Increment the number stored at key by one. If the key does not exist or contains a value of a