shibin_1109
- 浏览: 81348 次
- 性别:
- 来自: 北京
-
文章分类
最新评论
-
尹超5200：
你TM写点文字能死啊
java图片上传回显(火狐待测) -
shibin_1109：
如果冲突没更新下来的话也可以使用git同步来解决.
Eclips GIT冲突解决
服务器端安装,部署,启动:
java客户端使用:
memcached jar包:
1.下载libevent,安装libevent
cd /tmp
wget https://github.com/downloads/libevent/libevent/libevent-2.0.21-stable.tar.gz
tar -zxvf libevent-2.0.21-stable.tar.gz
cd libevent-2.0.21-stable
./configure --prefix=/usr/local/libevent
make && make install
2.下载memcached,安装memcached
wget http://memcached.org/latest
tar -zxvf memcached-1.4.17.tar.gz
cd memcached-1.4.17
./configure --prefix=/usr/local/memcache --with-libevent=/usr/local/libevent/
make && make install
cd /usr/local/memcached/bin
./memcached -d -m 64 -u root -p 55001 -c 2048
查看memcached的状态
ps -ax|grep memcache
链接到memcache
telnet cache.expai.com 55001
查看状态
stats
查看缓存占了多少空间
cat /proc/id/statm
启动参数
./memcached -d -m 1024 -u root -p 55001 -c 2048
memcached启动参数
-p 指定端口号（默认11211）
-U <num> UDP监听端口 (默认: 11211, 0 时关闭)
-s <file> 用于监听的UNIX套接字路径（禁用网络支持）
-a <mask> UNIX套接字访问掩码，八进制数字（默认：0700）
-m 指定最大使用内存大小（默认64MB）
-t 线程数（默认4）
-l <ip_addr> 绑定地址 (默认:所有都允许,无论内外网或者本机更换IP，有安全隐患，若设置为127.0.0.1就只能本机访问)
-d start 启动memcached服务
-d restart 重起memcached服务
-d stop|shutdown 关闭正在运行的memcached服务
-u <username> 绑定使用指定用于运行进程 <username> （只有root用户可以使用这个参数）
-P <file> 将PID写入文件<file>，这样可以使得后边进行快速进程终止, 需要与 -d 一起使用
-m 最大内存使用，单位MB。默认64MB www.2cto.com
-M 内存耗尽时返回错误，而不是删除项
-c 最大同时连接数，默认是1024
-f 块大小增长因子，默认是1.25
-n <bytes>最小分配空间，key+value+flags默认是48
-k锁定所有内存页。注意你可以锁定的内存上限。
试图分配更多内存会失败的，所以留意启动守护进程时所用的用户可分配的内存上限。
（不是前面的 -u <username> 参数；在sh下，使用命令"ulimit -S -l NUM_KB"来设置。）
-v 提示信息（在事件循环中打印错误/警告信息。）
-vv 详细信息（还打印客户端命令/响应）
-vvv 超详细信息（还打印内部状态的变化）
-h 打印这个帮助信息并退出。
-i 打印memcached和libevent的许可。
-L 尝试使用大内存页（如果可用的话）。提高内存页尺寸可以减少"页表缓冲（TLB）"丢失次数，提高运行效率。 www.2cto.com
为了从操作系统获得大内存页，memcached会把全部数据项分配到一个大区块。
-D <char> 使用 <char> 作为前缀和ID的分隔符。
这个用于按前缀获得状态报告。默认是":"（冒号）。
如果指定了这个参数，则状态收集会自动开启；如果没指定，则需要用命令"stats detail on"来开启。
-t <num> 使用的线程数（默认：4）
-R 每个连接可处理的最大请求数。
-C 禁用CAS。
-b 设置后台日志队列的长度（默认：1024）
-B 绑定协议 - 可能值：ascii,binary,auto（默认）
-I 重写每个数据页尺寸。调整数据项最大尺寸。
默认memcache会监听11221端口，如果想清空服务器上memecache的缓存，大家一般使用的是：
telnet localhost 11211
flush_all
同样也可以使用：
echo "flush_all" | nc localhost 11211
使用flush_all 后并不是删除memcache上的key，而是置为过期
java客户端使用:
package com.expai.utils;
import java.io.UnsupportedEncodingException;
import java.util.Date;
import java.util.List;
import org.apache.ibatis.session.SqlSession;
import org.apache.log4j.Logger;
import org.springframework.data.domain.Sort;
import org.springframework.data.mongodb.core.MongoOperations;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import com.danga.MemCached.MemCachedClient;
import com.danga.MemCached.SockIOPool;
import com.expai.mapper.advertise.AdverTiseMapper;
import com.expai.mapper.user.UserMapper;
import com.expai.model.hotimage.HotImage;
import com.expai.model.ir.Advertise;
import com.expai.model.user.User;
import com.mongodb.BasicDBList;
import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.DBObject;
/**
*
* Description:
* DateTime 2014年1月21日 下午4:19:28
* @author louyj
* @company expai
* @version 1.0
*
*/
public class MemCachedUtil {
private static final Logger logger = Logger.getLogger(MemCachedUtil.class);
//构建缓存客户端
private static MemCachedClient cachedClient;
// 单例模式实现客户端管理类
private static MemCachedUtil INSTANCE = new MemCachedUtil();
private MemCachedUtil() {
cachedClient = new MemCachedClient();
cachedClient.setPrimitiveAsString(true);
// cachedClient.setSanitizeKeys(arg0)
//获取连接池实例
SockIOPool pool = SockIOPool.getInstance();
// http://:/
//设置缓存服务器地址，可以设置多个实现分布式缓存 服务器列表和其权重
// pool.setServers(new String[]{"115.29.251.56:55001,115.29.251.56:55002,115.29.251.56:55003"});
//pool.setServers(new String[]{"10.162.57.11:55001"});
pool.setServers(new String[]{"s4.expai.com:55001"});
// pool.setServers(new String[]{"192.168.81.137:55001"});
Integer[] weights = {3};
//,"10.162.57.11:55001","10.162.57.11:55002","10.162.57.11:55003"
pool.setWeights( weights );
//pool.setServers(new String[]{"192.168.4.39:55001"});
//设置初始连接5
pool.setInitConn(5);
//设置最小连接5
pool.setMinConn(5);
//设置最大连接2048
pool.setMaxConn(2048);
//设置每个连接最大空闲时间3个小时
pool.setMaxIdle(1000 * 60 * 60 * 3);
pool.setMaintSleep(30);
pool.setNagle(false);
pool.setSocketTO(3000);
pool.setSocketConnectTO(0);
pool.initialize();
}
/**
* 获取缓存管理器唯一实例
* @return
*/
public static MemCachedUtil getInstance() {
return INSTANCE;
}
public void add(String key, Object value) {
cachedClient.add(key, value);
}
//int设置缓存失效时间,相对时间毫秒
public void add(String key, Object value, int milliseconds) {
cachedClient.add(key, value, milliseconds);
}
public void set(String key, Object value) {
cachedClient.set(key, value);
}
//int设置缓存失效时间,相对时间毫秒
public void set(String key, Object value, int milliseconds) {
cachedClient.set(key, value, milliseconds);
}
public void remove(String key) {
cachedClient.delete(key);
cachedClient.flushAll();
}
@SuppressWarnings("deprecation")
public void remove(String key, int milliseconds) {
cachedClient.delete(key, milliseconds, new Date());
cachedClient.flushAll();
}
public void update(String key, Object value, int milliseconds) {
cachedClient.replace(key, value, milliseconds);
}
public void update(String key, Object value) {
cachedClient.replace(key, value);
}
public Object get(String key) {
return cachedClient.get(key);
}
public void getAll(){
logger.debug(cachedClient);
}
/**
* 初始化识别信息缓存
*/
public static void initMemcachedIdenData(){
SqlSession session = null;
session = SessionFactory.getSession();
AdverTiseMapper adMap = null;
adMap = session.getMapper(AdverTiseMapper.class);
List<Advertise> advertiseList = adMap.getAdvertises();
if(advertiseList!=null&&advertiseList.size()>0){
for(Advertise advertise:advertiseList){
if(null!=advertise.getUrl()&&!advertise.getUrl().equals("")){
logger.debug("Advertise"+advertise.getId()+"的识别结果为:"+advertise.getUrl());
MemCachedUtil.getInstance().set("adveriden"+advertise.getId(), advertise.getUrl());
}else{
logger.debug("Advertise"+advertise.getId()+"的识别结果为:"+advertise.getUrl());
MemCachedUtil.getInstance().set("adveriden"+advertise.getId(), "url is null");
}
if(null!=advertise.getKeyword()&&!advertise.getKeyword().equals("")){
logger.debug("Advertise"+advertise.getId()+"的关键字为:"+advertise.getKeyword());
MemCachedUtil.getInstance().set("adverkey"+advertise.getId(), advertise.getKeyword());
}else{
logger.debug("Advertise"+advertise.getId()+"的关键字为:"+advertise.getKeyword());
MemCachedUtil.getInstance().set("adverkey"+advertise.getId(), "key is null");
}
if(null!=advertise.getImage()&&!advertise.getImage().equals("")){
logger.debug("Advertise"+advertise.getId()+"的图片地址为:"+advertise.getImage());
MemCachedUtil.getInstance().set("adverimage"+advertise.getId(), advertise.getImage());
}else{
logger.debug("Advertise"+advertise.getId()+"的图片地址为:"+advertise.getImage());
MemCachedUtil.getInstance().set("adverimage"+advertise.getId(), "image is null");
}
}
}
//初始化tb_newspaper里的识别信息
List<Advertise> newspaperList = adMap.getNewspapers();
if(newspaperList!=null&&newspaperList.size()>0){
for(Advertise advertise:newspaperList){
if(null!=advertise.getUrl()&&!advertise.getUrl().equals("")){
logger.debug("Advertise"+advertise.getId()+"的识别结果为:"+advertise.getUrl());
MemCachedUtil.getInstance().set("newsiden"+advertise.getId(), advertise.getUrl());
}else{
logger.debug("Advertise"+advertise.getId()+"的识别结果为:"+advertise.getUrl());
MemCachedUtil.getInstance().set("newsiden"+advertise.getId(), "url is null");
}
if(null!=advertise.getKeyword()&&!advertise.getKeyword().equals("")){
logger.debug("Advertise"+advertise.getId()+"的关键字为:"+advertise.getKeyword());
MemCachedUtil.getInstance().set("newskey"+advertise.getId(), advertise.getKeyword());
}else{
logger.debug("Advertise"+advertise.getId()+"的关键字为:"+advertise.getKeyword());
MemCachedUtil.getInstance().set("newskey"+advertise.getId(), "key is null");
}
if(null!=advertise.getImage()&&!advertise.getImage().equals("")){
logger.debug("Advertise"+advertise.getId()+"的图片地址为:"+advertise.getImage());
MemCachedUtil.getInstance().set("newsimage"+advertise.getId(), advertise.getImage());
}else{
logger.debug("Advertise"+advertise.getId()+"的图片地址为:"+advertise.getImage());
MemCachedUtil.getInstance().set("newsimage"+advertise.getId(), "image is null");
}
}
}
}
*/
/**
* 初始化广告信息tb_embedAdvertise
* @throws UnsupportedEncodingException
*/
public static void initMemcachedEmbedDate() throws UnsupportedEncodingException{
long st = System.currentTimeMillis();
DB db = MongdbUtil.startMongoDBConn();
DBCollection inputCollection =db.getCollection("tb_embedAdvertise");
DBObject ref = new BasicDBObject();
DBCursor cursor = inputCollection.find(ref);
List<DBObject> list = cursor.toArray();
long et = System.currentTimeMillis();
long diff = et-st;
logger.info("query all advertise expand time : " + diff);
MemCachedUtil instance = MemCachedUtil.getInstance();
if(list!=null&&list.size()>0){
logger.info("all advertise total number : " + list.size());
for(int i =0, n = list.size(); i < n; i++){
DBObject object = list.get(i);
Object url = object.get("url");
Object loc = object.get("loc");
String str = new String(object.toString().getBytes("UTF-8"));
if(null!=url && !url.toString().equals("")){
logger.debug("The is cache Advertise url======"+"em" + new MD5().getMD5ofStr(url.toString()));
instance.add("em" + new MD5().getMD5ofStr(url.toString()), str);
}
if(null != loc && !loc.toString().equals("")){
logger.debug("The is cache Advertise loc======"+"em" + new MD5().getMD5ofStr(loc.toString()));
instance.add("em" + new MD5().getMD5ofStr(loc.toString()), str);
}
Utils.writeText(str, "/data/memcached.txt");
}
logger.info("memcached add complete");
}
MongdbUtil.stopMondoDBConn();
}
public static void initMemcachedImageAll(){
DB db = MongdbUtil.startMongoDBConn();
DBCollection inputCollection =db.getCollection("tb_hotimage_failure");
DBCursor cursor = inputCollection.find();
List<DBObject> list = cursor.toArray();
for(int i =0, n = list.size(); i < n; i++){
DBObject object = list.get(i);
Object shortlocation = object.get("shortlocation");
if(null!=shortlocation && !shortlocation.toString().equals("")){
logger.debug("add tb_hotimage_failure======================"+shortlocation);
MemCachedUtil.getInstance().set(new MD5().getMD5ofStr(String.valueOf(shortlocation)),"failure");
}
}
DBCollection inputCollection1 =db.getCollection("tb_hotimage");
BasicDBObject obj = new BasicDBObject();
BasicDBObject query = new BasicDBObject();
BasicDBList values = new BasicDBList();
values.add("sdchina.com");
values.add("gywb.cn");
values.add("nen.com");
values.add("yunying");
values.add("shangdu.com");
values.add("voc.com");
values.add("0554news.com");
query.append("$in", values);
obj.append("categoryId", query);
DBCursor cursor1 = inputCollection1.find(obj);
List<DBObject> list1 = cursor1.toArray();
for(int i =0, n = list1.size(); i < n; i++){
DBObject object1 = list1.get(i);
Object shortlocation = object1.get("shortlocation");
if(null!=shortlocation && !shortlocation.toString().equals("")){
logger.debug("add tb_hotimage======================"+shortlocation);
MemCachedUtil.getInstance().set(new MD5().getMD5ofStr(String.valueOf(shortlocation)),"success");
}
}
MongdbUtil.stopMondoDBConn();
}
public static void main(String[] args) {
initMemcachedImageAll();
}
}
memcached jar包:
<dependency>
<groupId>memcached</groupId>
<artifactId>java_memcached-release</artifactId>
<version>2.6.6</version>
</dependency>
分享到：
发表评论
相关推荐
**Memcached缓存系统详解与应用实践** Memcached是一款高性能、分布式内存对象缓存系统，广泛应用于Web应用中，用于减轻数据库的负载，提高数据访问速度。它通过将数据存储在内存中，使得数据的读取速度大大提高，...
// 使用Memcached缓存数据 Map, Serializable> cacheData = new HashMap(); cacheData.put("key", "value"); memcachedServiceImpl.setCache("testKey", cacheData); // 从Memcached获取数据 Map, ...
**memcached缓存处理** **一、什么是memcached** `memcached`是一个高性能、分布式内存对象缓存系统，用于在动态系统中减少数据库负载。它通过将数据存储在内存中来加速读取操作，而不是每次请求都去查询数据库。...
Java Memcached是一个流行的Java客户端库，用于与Memcached缓存系统进行交互。Memcached是一种分布式内存对象缓存系统，常用于减轻数据库负载，提高Web应用的性能。在本例中，我们关注的是`java_memcached-release_...
### Java使用Memcached简单教程 #### 一、简介 Memcached是一个高性能的分布式内存对象缓存系统，通过减轻数据库负载来加速动态Web应用，提高网站的浏览速度。它通过在内存中缓存数据和对象来减少读取数据库的次数...
通过以上步骤，你可以在Java项目中成功集成并使用Memcached，实现高效的数据缓存。这不仅有助于提升应用性能，还能降低数据库的压力。在实际开发中，可以根据项目需求调整缓存策略，优化缓存效果。
这暗示我们将探讨如何在Java应用程序中集成和使用Memcached作为缓存解决方案。 **Memcached简介** Memcached是一款高性能、分布式的内存对象缓存系统，用于减少数据库负载，提高Web应用的响应速度。它通过将数据...
memcached 缓存 jar包，tomcat共享缓存可用，java开发数据库缓存也可用。
Java Memcached是一个基于Java的Memcached客户端库，用于在Java应用程序中与Memcached缓存系统进行交互。在标题和描述中提到的`java_memcached-release_2.6.6.jar`是这个库的特定版本，它包含了实现Memcached协议并...
java_memcached-release_2.6.2.jar java缓存工具 memcached
为了在Java项目中使用Java Memcached客户端，开发者需要按照以下步骤操作： 1. 解压下载的zip文件，找到并添加jar包到项目类路径。 2. 引入必要的库依赖，例如net.spy.memcached包。 3. 创建Memcached客户端实例，...
“memcached安装及java应用使用memcached”这一标题暗示了我们要讨论的是一个关于分布式内存缓存系统——memcached的安装过程以及如何在Java应用程序中使用它。Memcached是一个高性能、轻量级的分布式内存对象缓存...
Java与Memcached结合使用可以构建高性能的分布式缓存系统，以提高Web应用程序的响应速度和数据处理能力。这里提供的文件包含在Windows环境下运行Memcached以及Java应用中集成Memcached所需的必要组件。 首先，我们...
总之，Java环境下Memcached的应用主要在于提供一个高效、分布式的缓存解决方案，它能有效提升应用程序的响应速度，减轻数据库压力，特别是在集群环境中，通过合理配置和使用，可以极大地优化系统的整体性能。
Java Memcached是一个基于Java语言的Memcached客户端库，它允许Java开发者轻松地与Memcached缓存服务器进行交互。Memcached是一种高性能的分布式内存对象缓存系统，常用于减轻数据库的负载，提高应用的响应速度。在...
这里需要解释说明一下，很多开发者觉得Memcached是一种分布式缓存系统，但是其实Memcached服务端本身是单实例的，只是在客户端实现过程中可以根据存储的主键做分区存储，而这个区就是Memcached服务端的一个或者多个...
Java Memcached 客户端是Java开发者用于与Memcached分布式内存缓存系统交互的一个库。在版本2.6.3中，它提供了高效且可靠的连接管理，以及对Memcached服务器的全面支持。这个压缩包“java_memcached-release_2.6.3....
总之，这个解决方案展示了如何巧妙地利用Java作为桥梁，使Oracle数据库能够与Memcached缓存服务协同工作，优化数据访问效率。这种集成技术是现代企业级应用中常见的实践，有助于构建更加高效和可扩展的系统。
Java Memcached客户端是Java开发者用来与Memcached分布式内存缓存系统进行交互的工具。这个`java_memcached-release_2.6.3.rar`压缩包包含了用于Java客户端开发所需的全部依赖库，使得开发者能够轻松地在Java应用中...
5. **分布式一致性哈希**：当有多个Memcached服务器时，Java客户端通常使用分布式一致性哈希算法来决定数据应存储在哪个服务器上，以确保在服务器添加、删除时尽可能少地打乱现有的键值分布。 6. **并发控制**：在...