本文在博客《 使用 spring 集成 dbcp 数据库连接池到 Wowza 插件》示例项目的基础上对 Memcached 进行集成，该博客代码下载地址： http://download.csdn.net/detail/defonds/7098633。
1. 导入上篇博客示例代码
将《 使用 spring 集成 dbcp 数据库连接池到 Wowza 插件》的示例代码导入 Eclipse。关于 Eclipse 的 Wowza 插件的安装、Wowza 项目的新建及其调试、spring 的集成请参阅以前博客。成功导入后 Eclipse 下的视图如下：
2. Memcached 公共接口实现
新建 CacheService 接口代码如下：
package com.defonds.wms.module.cache.service;
public interface CacheService {
void init(); // while server start up, do something
void destory(); // while server shut down, do something
void put(String key, Object object); // set new value to cache
void remove(String key); // remove from cache
Object get(String key); // get current value from cache
boolean exist(String key); // check whether the key already exist in cache or not
}
CacheService 的实现类 CacheServiceImpl 代码：
package com.defonds.wms.module.cache.service;import java.io.IOException;import java.net.InetSocketAddress;import net.spy.memcached.MemcachedClient;import com.wowza.wms.logging.WMSLogger;import com.wowza.wms.logging.WMSLoggerFactory;public class CacheServiceImpl implements CacheService {private static final WMSLogger logger = WMSLoggerFactory.getInstance().getLoggerObj(CacheServiceImpl.class.getName());private MemcachedClient memcachedClient = null;private String memcachedIpAddress; // memcached server ip addressprivate Integer memcachedServerPort; // memcached server portprivate Integer memcachedObjectExpiration; // objects set to memcached will be expired after 86400 (86400 = 60 * 60 * 24) seconds@Overridepublic void init() {logger.debug("CacheServiceImpl--init--debug--memcachedIpAddress=" + this.memcachedIpAddress + ";memcachedServerPort=" + this.memcachedServerPort+ ";memcachedObjectExpiration=" + this.memcachedObjectExpiration);try {logger.debug("CacheServiceImpl--init--debug--MemcachedClient will init now");this.memcachedClient = new MemcachedClient(new InetSocketAddress(this.memcachedIpAddress, this.memcachedServerPort));} catch (IOException e) {logger.error(e.getMessage(), e);}}@Overridepublic void destory() {this.memcachedClient.shutdown();}@Overridepublic void put(String key, Object object) {try {this.memcachedClient.set(key, this.memcachedObjectExpiration, object);} catch (Exception e) {logger.error("CacheServiceImpl--put-- insert object into memcached failed!");}}@Overridepublic void remove(String key) {try {this.memcachedClient.delete(key);} catch (Exception e) {logger.error("CacheServiceImpl--remove-- delete object from memcached failed!");}}@Overridepublic Object get(String key) {Object object = null;try {object = this.memcachedClient.get(key);} catch (Exception e) {logger.error("CacheServiceImpl--get-- select object from memcached failed!");}return object;}@Overridepublic boolean exist(String key) {Object object = null;try {object = this.memcachedClient.get(key);} catch (Exception e) {logger.error("CacheServiceImpl--exist-- select object from memcached failed!");}if (object == null) {return false;} else {return true;}}public void setMemcachedIpAddress(String memcachedIpAddress) {this.memcachedIpAddress = memcachedIpAddress;}public void setMemcachedServerPort(Integer memcachedServerPort) {this.memcachedServerPort = memcachedServerPort;}public void setMemcachedObjectExpiration(Integer memcachedObjectExpiration) {this.memcachedObjectExpiration = memcachedObjectExpiration;}}
3. 加入 spymemcached 支持
将 spymemcached-2.8.4.jar 添加到 defonds-server-module 的编译环境和运行环境(运行环境就是 %wowza%/lib)。
4. 配置 Memcached
就是 Memcached 服务器地址、端口号以及数据保鲜期的配置。config.properties 中加入以下：
memcached.ip.address=172.21.0.117memcached.server.port=12111#objects set to memcached will be expired after 86400 (86400 = 60 * 60 * 24) secondsmemcached.object.expiration=86400
5. 使用 spring 对 CacheService 进行管理
我们把 CacheService 对象的生命周期全权交给 spring 进行管理。spring-context.xml 中的 beans 标签下加入以下配置：
<!-- cache related --><bean id="cacheService" class="com.defonds.wms.module.cache.service.CacheServiceImpl" init-method="init"><property name="memcachedIpAddress" value="${memcached.ip.address}"></property><property name="memcachedServerPort" value="${memcached.server.port}"></property><property name="memcachedObjectExpiration" value="${memcached.object.expiration}"></property></bean>
6. 部署并调试
使用文本编辑器打开 Wowza 安装目录下的 conf 文件夹中的 Server.xml，在 ServerListeners 标签下添加以下内容：
<ServerListener> <BaseClass>com.defonds.wms.module.server.DefondsWowzaServerListener</BaseClass> </ServerListener>
在任何插件类中加入如下代码：
ApplicationContext appCtx = ApplicationContextUtils.getApplicationContext(); // test cacheString testFlag = "now" + System.currentTimeMillis();CacheService cacheService = (CacheService) appCtx.getBean("cacheService");if (!cacheService.exist("somekey")) {cacheService.put("somekey", testFlag);} logger.debug("DefondsWowzaServerListener-onServerInit-memcached-somekey=" + cacheService.get("somekey"));
执行该插件类后打印接过如下：
DEBUG server comment - DefondsWowzaServerListener-onServerInit-memcached-somekey=now1398324763217
测试成功。
注意：关于 Wowza 插件的 log
Wowza 的 logging 实现采用的是 Apache 的 log4j logging 工具，log4j 的配置文件在 %wowza%/conf/log4j.properties，默认配置如下：
log4j.rootCategory=INFO, stdout, serverAccess, serverError
如果我们想在开发时对插件项目中的一些自定义类中修改日志级别，只能在 %wowza%/conf/log4j.properties 进行修改，在其他地方另加自定义 log4j.properties Wowza 是不认的。比如我们要将 CacheServiceImpl 的日志级别修改为 DEBUG，那么应该在 %wowza%/conf/log4j.properties 文件末尾添加一行：
log4j.logger.com.defonds.wms.module.cache.service=DEBUG
然后重启 Wowza 即可。
另外，CacheServiceImpl 里获取 WMSLogger 一定要用这种写法：
WMSLogger logger = WMSLoggerFactory.getInstance().getLoggerObj(CacheServiceImpl.class.getName());
其他的诸如 WMSLoggerFactory.getLogger(CacheServiceImpl.class) 或者 WMSLoggerFactory.getLogger(null) 虽然也能输出日志，但 log4j.logger.com.defonds.wms.module.cache.service=DEBUG 对其日志级别的修改无效。
后记
本资源源码已上传 csdn 资源，有兴趣的朋友可以去下载一下，链接地址： http://download.csdn.net/detail/defonds/7245973。