Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import redis.clients.jedis.*;
- import redis.clients.jedis.exceptions.JedisException;
- import java.util.HashMap;
- import java.util.Map;
- import java.util.Set;
- import redis.clients.jedis.exceptions.JedisException;
- public class Test {
- //address of your redis server
- private static final String redisHost = "10.0.0.10";
- private static final Integer redisPort = 11211;
- //remember to increase sensder queue size
- public void addSets() {
- JedisPoolConfig poolConfig = new JedisPoolConfig();
- poolConfig.setMaxIdle(50);
- poolConfig.setMaxTotal(1000);
- poolConfig.setTestOnBorrow(true);
- poolConfig.setTestOnReturn(true);
- JedisPool pool = new JedisPool(poolConfig,redisHost, redisPort,10000000);
- Jedis jedis= null;
- String key = "shivd";
- long [] bits = {1464236631,12373513,1488983657,1329373495,147236649,1623846793,1194510359,282099785,1758709929,1059647223,416962921,1893573065,924784087,551826057,2028436201};
- //get a jedis connection jedis connection pool
- try {
- jedis = pool.getResource();
- Pipeline pipeline = jedis.pipelined();
- for (long b : bits) {
- pipeline.setbit(key, b, true);
- }
- pipeline.multi();
- pipeline.exec();
- } finally {
- if (jedis != null) {
- jedis.close();
- }
- }
- pool.destroy();
- }
- public static void main(String[] args){
- Test main = new Test();
- main.addSets();
- //main.cal();
- //main.addHash();
- }
- }
Add Comment
Please, Sign In to add comment