Java中使用Jedis操作Redis的实现代码

一. redis的安装

1.下载源码，解压缩后编译源码。

[root@cwt123 ~]# tar xzf redis-2.8.3.tar.gz

[root@cwt123 ~]# cd redis-2.8.3

[root@cwt123 ~]# make

2.启动Redis服务。(src在redis-2.8.3下)

1 2	`[root@cwt123 ~]# cd src` `[root@cwt123 ~] ./redis-server`

3.连接redis客户端

1	`[root@cwt123 ~]# ./redis-cli`

4.测试,redis的ip即为机器的ip,端口默认为6379

127.0.0.1:6379> set 'hello' 'test'

OK

127.0.0.1:6379> get hello

"test"

二. java操作redis

1.直接连接redis,并操作redis

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

200

201

202

203

204

205

206

207

208

209

210

211

212

213

214

215

216

217

218

219

220

221

222

223

224

225

226

227

228

229

230

231

232

233

234

235

236

237

238

239

240

241

242

243

244

245

246

247

248

249

250

251

252

253

254

255

256

257

258

259

260

261

262

263

264

265

266

267

268

269

270

271

272

273

274

275

276

277

278

279

280

281

282

283

284

285

package com.sinovatech.mactivity.web.controller;

import java.util.HashMap;

import java.util.Iterator;

import java.util.List;

import java.util.Map;

import org.junit.Before;

import org.junit.Test;

import redis.clients.jedis.Jedis;

public class TestredisOwn {

private Jedis jedis;

@Before

public void setup() {

//连接redis服务器，192.168.0.100:6379

jedis = new Jedis("10.143.131.63", 6378);

//权限认证

//jedis.auth("admin");

}

/**

* redis存储字符串

*/

@Test

public void testString() {

//-----添加数据----------

jedis.set("name","xinxin");//向key-->name中放入了value-->xinxin

System.out.println(jedis.get("name"));//执行结果：xinxin

jedis.append("name", " is my lover"); //拼接

System.out.println(jedis.get("name"));

jedis.del("name"); //删除某个键

System.out.println(jedis.get("name"));

//设置多个键值对

jedis.mset("name","liuling","age","23","qq","476777XXX");

jedis.incr("age"); //进行加1操作

System.out.println(jedis.get("name") + "-" + jedis.get("age") + "-" + jedis.get("qq"));

}

/**

* redis操作Map

*/

@Test

public void testMap() {

//-----添加数据----------

Map<String, String> map = new HashMap<String, String>();

map.put("name", "xinxin");

map.put("age", "22");

map.put("qq", "123456");

jedis.hmset("user",map);

//取出user中的name，执行结果:[minxr]-->注意结果是一个泛型的List

//第一个参数是存入redis中map对象的key，后面跟的是放入map中的对象的key，后面的key可以跟多个，是可变参数

List<String> rsmap = jedis.hmget("user", "name", "age", "qq");

System.out.println(rsmap);

//删除map中的某个键值

jedis.hdel("user","age");

System.out.println(jedis.hmget("user", "age")); //因为删除了，所以返回的是null

System.out.println(jedis.hlen("user")); //返回key为user的键中存放的值的个数2

System.out.println(jedis.exists("user"));//是否存在key为user的记录返回true

System.out.println(jedis.hkeys("user"));//返回map对象中的所有key

System.out.println(jedis.hvals("user"));//返回map对象中的所有value

Iterator<String> iter=jedis.hkeys("user").iterator();

while (iter.hasNext()){

String key = iter.next();

System.out.println(key+":"+jedis.hmget("user",key));

}

/**

* jedis操作List

*/

@Test

public void testList(){

//lpush将数据从链表的头部插入,如果没有该key,在插入之前创建与key关联的空链表

jedis.lpush("java framework","spring");

jedis.lpush("java framework","struts");

jedis.lpush("java framework","hibernate");

//rpush将数据从链表的尾部插入元素,如果没有该key,在插入前穿件与该key关联的空链表

jedis.rpush("java frameworkr", "spring");

jedis.rpush("java frameworkr", "struts");

jedis.rpush("java frameworkr", "hibernate");

//lpop,取出链表的头部元素,没有返回null

jedis.lpop("java framework");

//rpop取出链表的尾部元素,key不存在返回null

jedis.rpop("java framework");

//再取出所有数据jedis.lrange是按范围取出，

// 第一个是key，第二个是起始位置，第三个是结束位置，jedis.llen获取长度 -1表示取得所有

System.out.println(jedis.lrange("java framework",0,-1));

}

/**

* jedis操作Set

*/

@Test

public void testSet(){

//添加

jedis.sadd("user","liuling");

jedis.sadd("user","xinxin");

jedis.sadd("user","ling");

jedis.sadd("user","zhangxinxin");

jedis.sadd("user","who");

//移除noname

jedis.srem("user","who");

System.out.println(jedis.smembers("user"));//获取所有加入的value

System.out.println(jedis.sismember("user", "who"));//判断 who 是否是user集合的元素

System.out.println(jedis.srandmember("user"));

System.out.println(jedis.scard("user"));//返回集合的元素个数

}

@Test

public void test() throws InterruptedException {

//jedis 排序

//注意，此处的rpush和lpush是List的操作。是一个双向链表（但从表现来看的）

jedis.del("a");//先清除数据，再加入数据进行测试

jedis.rpush("a", "1");

jedis.lpush("a","6");

jedis.lpush("a","3");

jedis.lpush("a","9");

System.out.println(jedis.lrange("a",0,-1));// [9, 3, 6, 1]

System.out.println(jedis.sort("a")); //[1, 3, 6, 9] //输入排序后结果

System.out.println(jedis.lrange("a",0,-1));

}

//下面方法调用redis中的连接池

@Test

public void testRedisPool() {

TestRedisUtil.getJedis().set("newname", "中文测试");

System.out.println(TestRedisUtil.getJedis().get("newname"));

}

public static void main(){

Jedis jedis=TestRedisUtil.getJedis();

jedis.set("testrediskey001", "testrediskey001");

String getvalue=jedis.get("testrediskey001");

System.out.println(getvalue);

}

2.创建redis连接池,并操作使用redis

①Redis连接池的创建

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

package com.sinovatech.mactivity.web.controller;

import redis.clients.jedis.Jedis;

import redis.clients.jedis.JedisPool;

import redis.clients.jedis.JedisPoolConfig;

public final class TestRedisUtil {

//Redis服务器IP

private static String ADDR = "10.143.131.63";

//Redis的端口号

private static int PORT = 6378;

//访问密码

private static String AUTH = "admin";

//可用连接实例的最大数目，默认值为8；

//如果赋值为-1，则表示不限制；如果pool已经分配了maxActive个jedis实例，则此时pool的状态为exhausted(耗尽)。

private static int MAX_ACTIVE = 1024;

//控制一个pool最多有多少个状态为idle(空闲的)的jedis实例，默认值也是8。

private static int MAX_IDLE = 200;

//等待可用连接的最大时间，单位毫秒，默认值为-1，表示永不超时。如果超过等待时间，则直接抛出JedisConnectionException；

private static int MAX_WAIT = 10000;

private static int TIMEOUT = 10000;

//在borrow一个jedis实例时，是否提前进行validate操作；如果为true，则得到的jedis实例均是可用的；

private static boolean TEST_ON_BORROW = true;

private static JedisPool jedisPool = null;

/**

* 初始化Redis连接池

*/

static {

try {

JedisPoolConfig config = new JedisPoolConfig();

config.setMaxIdle(MAX_ACTIVE);

config.setMaxIdle(MAX_IDLE);

config.setMaxWaitMillis(MAX_WAIT);

config.setTestOnBorrow(TEST_ON_BORROW);

jedisPool = new JedisPool(config, ADDR, PORT);

} catch (Exception e) {

e.printStackTrace();

}

/**

* 获取Jedis实例

* @return

*/

public synchronized static Jedis getJedis() {

try {

if (jedisPool != null) {

Jedis resource = jedisPool.getResource();

return resource;

} else {

return null;

}

} catch (Exception e) {

e.printStackTrace();

return null;

}

/**

* 释放jedis资源

* @param jedis

*/

public static void returnResource(final Jedis jedis) {

if (jedis != null) {

jedisPool.returnResource(jedis);

}

②使用创建好的redis连接池操作redis

package com.sinovatech.mactivity.web.controller;

import redis.clients.jedis.Jedis;

public class TestRedisOwnNew {

public static void main(String[] args) {

// TODO Auto-generated method stub

Jedis jedis=TestRedisUtil.getJedis();

jedis.set("testrediskey001", "testrediskey001");

String getvalue=jedis.get("testrediskey001");

System.out.println(getvalue);

jedis.del("testrediskey001");

}

三.Redis常用方法

1.redis存储字符串:

//① -----添加数据---------- 调用set方法

jedis.set("name","xinxin");//向key-->name中放入了value-->xinxin

System.out.println(jedis.get("name"));//执行结果：xinxin

jedis.append("name", " is my lover"); //拼接

System.out.println(jedis.get("name"));

//②删除数据,调用del方法

jedis.del("name"); //删除某个键

System.out.println(jedis.get("name"));

//③设置多个键值对,调用mset方法参数格式为(key,value,key,value)

jedis.mset("name","liuling","age","23","qq","476777XXX");

//④incr方法,对某个key的value值进行加1操作,如果没有该key会自动创建,并加1

jedis.incr("age"); //进行加1操作

System.out.println(jedis.get("name") + "-" + jedis.get("age") + "-" + jedis.get("qq"));

2. redis操作Map

//①-----添加数据---------- 调 hmset方法,放入一个map

Map<String, String> map = new HashMap<String, String>();

map.put("name", "xinxin");

map.put("age", "22");

map.put("qq", "123456");

jedis.hmset("user",map);

//取出user中的name，执行结果:[minxr]-->注意结果是一个泛型的List

//第一个参数是存入redis中map对象的key，后面跟的是放入map中的对象的key，后面的key可以跟多个，是可变参数

//②取数据,调用hmget方法,参数是之前放入的map的key,返回的是一个list

List<String> rsmap = jedis.hmget("user", "name", "age", "qq");

System.out.println(rsmap);

//③ 删除map中的某个键值 ,调用hdel方法,可是删除多个键

jedis.hdel("user","age");

System.out.println(jedis.hmget("user", "age")); //因为删除了，所以返回的是null

System.out.println(jedis.hlen("user")); //返回key为user的键中存放的值的个数2

System.out.println(jedis.exists("user"));//是否存在key为user的记录返回true

System.out.println(jedis.hkeys("user"));//返回map对象中的所有key

System.out.println(jedis.hvals("user"));//返回map对象中的所有value

Iterator<String> iter=jedis.hkeys("user").iterator();

while (iter.hasNext()){

String key = iter.next();

System.out.println(key+":"+jedis.hmget("user",key));

}

3.jedis操作List

Java中使用Jedis操作Redis的实现代码

相关文章

快网idc优惠网

相关文章

微信

快网idc优惠网

QQ交流群