JedisCluster应用详解

Redis集群的搭建参考Redis Cluster安装配置

本文主要介绍JedisCluster客户端结合spring注解的使用。

1、rediscluster.properties

#redis的服务器地址
redis.host=172.18.209.168
#redis的服务端口
redis.port=6379
#密码
redis.password=×××××××
#最大空闲数
redis.maxIdle=100
#最大连接数
redis.maxActive=300
#最大建立连接等待时间
redis.maxWait=1000
#客户端超时时间单位是毫秒
redis.timeout=100000
redis.maxTotal=1000
redis.minIdle=8
#明是否在从池中取出连接前进行检验,如果检验失败,则从池中去除连接并尝试取出另一个
redis.testOnBorrow=true
#连接耗尽时是否阻塞  false报异常,ture阻塞直到超时
redis.blockWhenExhausted=false
#当设置为true,且服务开启的jmx服务时,使用jconsole等工具将看到连接池的状态
redis.jmxEnabled=true
#向连接池归还链接时,是否检测链接对象的有效性
redis.testOnReturn=false
#对象空闲多久后逐出,当空闲时间>该值 且 空闲连接>最大空闲数 时直接逐出
redis.softMinEvictableIdleTimeMillis=10000

#jediscluster
cluster1.host.port=172.18.209.168:7001
cluster2.host.port=172.18.209.168:7002
cluster3.host.port=172.18.209.168:7003
cluster4.host.port=172.18.209.169:7004
cluster5.host.port=172.18.209.169:7005
cluster6.host.port=172.18.209.169:7006

#rediscluster
spring.redis.cluster.nodes=172.18.209.168:7001,172.18.209.168:7002,172.18.209.168:7003,172.18.209.169:7004,172.18.209.169:7005,172.18.209.169:7006
spring.redis.cluster.max-redirects=3  

2、spring-redis.xml

<bean id="propertyConfigurer"
      class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
    <property name="location" value="classpath:rediscluster.properties" />
</bean>

<!-- 基础参数配置 -->
<bean id="jedisClusterPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
    <!-- 连接池最大允许连接数 -->
    <property name="maxTotal" value="${redis.maxTotal}"/>
    <!-- 对象空闲多久后逐出,当空闲时间>该值 且 空闲连接>最大空闲数 时直接逐出 -->
    <property name="softMinEvictableIdleTimeMillis" value="${redis.softMinEvictableIdleTimeMillis}"/>
    <!-- 向连接池归还链接时,是否检测链接对象的有效性 -->
    <property name="testOnReturn" value="${redis.testOnReturn}"/>
    <!-- 当设置为true,且服务开启的jmx服务时,使用jconsole等工具将看到连接池的状态 -->
    <property name="jmxEnabled" value="${redis.jmxEnabled}"/>
    <!-- 连接耗尽时是否阻塞  false报异常,ture阻塞直到超时 -->
    <property name="blockWhenExhausted" value="${redis.blockWhenExhausted}"/>
    <!--最大空闲数-->
    <property name="maxIdle" value="${redis.maxIdle}" />
    <!--最大建立连接等待时间-->
    <property name="maxWaitMillis" value="${redis.maxWait}" />
    <!--是否在从池中取出连接前进行检验,如果检验失败,则从池中去除连接并尝试取出另一个-->
    <property name="testOnBorrow" value="${redis.testOnBorrow}" />
</bean>

<bean id="resourcePropertySource" class="org.springframework.core.io.support.ResourcePropertySource">
    <constructor-arg name="name" value="rediscluster.properties"/>
    <constructor-arg name="resource" value="classpath:rediscluster.properties"/>
</bean>

<bean id="redisClusterConfiguration" class="org.springframework.data.redis.connection.RedisClusterConfiguration">
    <constructor-arg name="propertySource" ref="resourcePropertySource"/>
</bean>

<!-- JedisCluster -->
<bean id="jedisCluster" class="*.*.jedis.JedisClusterFactory">
    <property name="addressConfig" value="classpath:rediscluster.properties" />
    <property name="addressKeyPrefix" value="cluster" />
    <property name="timeout" value="300000" />
    <property name="maxRedirections" value="6" />
    <property name="genericObjectPoolConfig" ref="jedisClusterPoolConfig" />
</bean>

<!-- 配置redis connection -->
<bean id="redisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
    <constructor-arg ref="redisClusterConfiguration"/>
    <constructor-arg ref="jedisClusterPoolConfig"/>
</bean>

<!-- 数据以字符串存储  -->
<bean id="stringRedisSerializer" class="org.springframework.data.redis.serializer.StringRedisSerializer"/>

<!-- 数据以字节流存储 -->
<bean id="jdkRedisSerializer" class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer"/>

<!--  redis String类型 访问模版本 -->
<bean id="stringRedisTemplate" class="org.springframework.data.redis.core.StringRedisTemplate">
    <property name="connectionFactory" ref="redisConnectionFactory"/>
</bean>

<!-- redis 访问模版 -->
<bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">
    <property name="connectionFactory" ref="redisConnectionFactory"/>
    <!-- 在hash数据结构中,hash-key的序列化策略 -->
    <property name="hashKeySerializer" ref="stringRedisSerializer"/>
    <!-- 对于普通K-V操作时,key采取的序列化策略 -->
    <property name="keySerializer" ref="stringRedisSerializer"/>
    <!-- value采取的序列化策略 -->
    <property name="valueSerializer" ref="jdkRedisSerializer"/>
</bean>

3、JedisClusterFactory.java

public class JedisClusterFactory implements FactoryBean, InitializingBean {

    private Resource addressConfig;
    private String addressKeyPrefix;

    private JedisCluster jedisCluster;
    private Integer timeout;
    private Integer maxRedirections;
    private GenericObjectPoolConfig genericObjectPoolConfig;

    private Pattern p = Pattern.compile("^.+[:]\\d{1,5}\\s*$");

    @Override
    public JedisCluster getObject() throws Exception {
        return jedisCluster;
    }

    @Override
    public Class<? extends JedisCluster> getObjectType() {
        return (this.jedisCluster != null ? this.jedisCluster.getClass() : JedisCluster.class);
    }

    @Override
    public boolean isSingleton() {
        return true;
    }

    private Set parseHostAndPort() throws Exception {
        try {
            Properties prop = new Properties();
            prop.load(this.addressConfig.getInputStream());
            Set haps = new HashSet<>();
            for (Object key : prop.keySet()) {
                if (!((String) key).startsWith(addressKeyPrefix)) {
                    continue;
                }
                String val = (String) prop.get(key);
                boolean isIpPort = p.matcher(val).matches();
                if (!isIpPort) {
                    throw new IllegalArgumentException("ip 或 port 不合法");
                }
                String[] ipAndPort = val.split(":");
                HostAndPort hap = new HostAndPort(ipAndPort[0], Integer.parseInt(ipAndPort[1]));
                haps.add(hap);
            }

            return haps;
        } catch (IllegalArgumentException ex) {
            throw ex;
        } catch (Exception ex) {
            throw new Exception("解析jedis配置文件失败", ex);
        }
    }

    @Override
    public void afterPropertiesSet() throws Exception {
        Set haps = this.parseHostAndPort();
        jedisCluster = new JedisCluster(haps, timeout, maxRedirections, genericObjectPoolConfig);
    }

    public void setAddressConfig(Resource addressConfig) {
        this.addressConfig = addressConfig;
    }

    public void setTimeout(int timeout) {
        this.timeout = timeout;
    }

    public void setMaxRedirections(int maxRedirections) {
        this.maxRedirections = maxRedirections;
    }

    public void setAddressKeyPrefix(String addressKeyPrefix) {
        this.addressKeyPrefix = addressKeyPrefix;
    }

    public void setGenericObjectPoolConfig(GenericObjectPoolConfig genericObjectPoolConfig) {
        this.genericObjectPoolConfig = genericObjectPoolConfig;
    }
}

Retrofit Call 获取数据

关于的说明和用法可以详细查看官网

Call<List<Repo>> call = service.listRepos("octocat");

如何得到List<Repo>,请看下面的代码:

call.enqueue(new Callback<List<Repo>>() {  
    @Override
    public void onResponse(Call<List<Repo>> call, Response<List<Repo>> response) {
        
    }

    @Override
    public void onFailure(Call<List<Repo>> call, Throwable t) {
        
    }
});

 

 

git 命令说明

1、用命令进行配置
$ git config –global user.name “Your Name” $ git config –global user.email “email@example.com”
注意git config命令的–global参数,用了这个参数,表示你这台机器上所有的Git仓库都会使用这个配置,当然也可以对某个仓库指定不同的用户名和Email地址。
2、用命令git clone克隆一个本地库
3、查看当前状态
$ git status
git status命令可以让我们时刻掌握仓库当前的状态,上面的命令告诉我们,readme.txt被修改过了,但还没有准备提交的修改。
4、添加到仓库
用命令git add告诉Git,把文件添加到仓库:
$ git add readme.txt
5、提交仓库
用命令git commit告诉Git,把文件提交到仓库:
$ git commit -m “wrote a readme file”
git commit命令,-m后面输入的是本次提交的说明,可以输入任意内容,当然最好是有意义的,这样你就能从历史记录里方便地找到改动记录。
6、查看历史记录
历史记录,在Git中,我们用git log命令查看:
$ git log commit 3628164fb26d48395383f8f31179f24e0882e1e0 Author: 06peng <linlepeng@06peng.com> Date: Tue Aug 20 15:11:49 2013 +0800 append GPL commit ea34578d5496d7dd233c827ed32a8cd576c5ee85 Author: 06peng <linlepeng@06peng.com> Date: Tue Aug 20 14:53:12 2013 +0800 add distributed 或者 $ git log –pretty=oneline 3628164fb26d48395383f8f31179f24e0882e1e0 append GPL ea34578d5496d7dd233c827ed32a8cd576c5ee85 add distributed cb926e7ea50ad11b8f9e909c05226233bf755030 wrote a readme file
7、回滚
回退到上一个版本
$ git reset –hard 3628164
8、恢复
恢复到新版本怎么办?找不到新版本的commit id
$ git reflog ea34578 HEAD@{0}: reset: moving to HEAD^ 3628164 HEAD@{1}: commit: append GPL ea34578 HEAD@{2}: commit: add distributed cb926e7 HEAD@{3}: commit (initial): wrote a readme file
9、暂存代码
git stash 可用来暂存当前正在进行的工作
$ git stash save “work in progress for foo feature”
10、取出暂存区代码
$ git stash list 命令可以将当前的Git栈信息打印出来
git stash apply stash@{0} 就可以将你指定版本号为stash@{1}的工作取出来
当你将所有的栈都应用回来的时候,可以使用 git stash clear 来将栈清空。
11、分支管理
创建dev分支,然后切换到dev分支:
$ git checkout -b dev
用git branch命令查看当前分支:
$ git branch
换回master分支:
$ git checkout master
分支的工作成果合并到master分支上:
$ git merge dev
12、更新 & 提交
更新
git pull –rebase
如果有冲突,会提示你。冲突分为两种,一种是在不同地方的冲突,通常情况下,git是可以自己合并的。另外一种是因为可能是同一个文件的编辑,git没法自动合并,需要二选一,这时候打开冲突的文件,手动编辑文件到可用的版本。然后。。
git rebase –continue
git push
13、缓存密码
.gitconfig 文件中添加
[credential]
helper = store
或者
$ git config –global credential.helper store
14、.gitignore文件说明
*.iml
*.idea
*/.classpath
*/.launch
*/.project
*/.settings
/*.launch
/*.tmproj
*/ivy*
*/eclipse
!.gitignore
*/target
*/outputLocation_IS_UNDEFINED
15、客户端工具介绍
windows 的github软件
1.source tree
2.Git Extensions.
3.msysGit
4.Cmder
5.乌龟 tortoise git
6.twilight
16、
一、 提交时
假设修改ABC.java为Abc.java。
1.1 如果使用git命令进行仅涉及大小写的重命名
1.1.1 设置git库为大小写敏感(不建议)
$ git config core.ignorecase false
用这种方法进行重命名,用git status就可以识别出修改了,但是不推荐用这种方式,因为在更新这种修改的时候会有麻烦。
1.1.2 使用git mv命令(仅当core.ignorecase为true时可用)
$ git mv ABC.java Abc.java
$ git status
……
renamed: ABC.java -> Abc.java
此时的状态是renamed,git commit即可。
1.2 如果使用Eclipse进行仅涉及大小写的重命名
无论core.ignorecase设置为true还是false或者没有设置该项,修改之后均可正常提交,在进行Commit的时候,对话框中显示的修改文件列表有:
即删除ABC.java并增加Abc.java,直接commit然后push即可。
偶尔会出现在Eclipse端修改完之后右键commit为灰色的情况,这时候如果使用git status发现有renamed状态的修改的话,也可以直接在git bash上commit并push。
17、
比如我现在有两个分支,分别是master和develop
按照官方的说法,在.gitattributes文件中如下设置
database.xml merge=ours
两个分支中都有database.xml文件,但是内容不同,我不想在master合并develop分支的时候,把database.xml也合并了。
还需设置如下:
git config –global merge.ours.driver true
当我修改了develop分支中的database.xml,切换到master分支进行合并
git merge develop

React Native嵌入到原生Android问题记录

本文主要是记录ReactNative嵌入到原生Android中遇到的一些问题以及解决方法。关于配置方面在这里就不说了。可以参考FaceBook的官方文档,或者ReactNarive中文版

1、java.lang.IllegalAccessError: Method ‘void android.support.v4.net.ConnectivityManagerCompat.<init>()’ is inaccessible to class ‘com.facebook.react.modules.netinfo.NetInfoModule’ (declaration of ‘com.facebook.react.modules.netinfo.NetInfoModule’ appears in /data/app/package.name-2/base.apk

解决办法:把support相关包改成23.0.1

compile 'com.android.support:appcompat-v7:23.0.1'

2、ReferenceError: Can’t find variable: __fbBatchedBridge

解决办法:晃动手机或者点击Menu菜单就会打开相关的调试页面,前提是要在配置文件中配置RN的DevSettingsActivity,让RN项目支持调试。

<activity android:name=”com.facebook.react.devsupport.DevSettingsActivity” />

选择Dev Settings,然后选择Debug server host & port for device,输入你的ip和8081端口,例如:192.168.1.100:8081,然后重试。

3、启动RN服务器的时候报错:

Loading dependency graph… ERROR  Packager can’t listen on port 8081

解决办法:端口被占用,在命令行输入lsof -i :8081 查看占用该端口的进程,然后执行命令“kill -9 进程id” ,再重启服务器。

4、Unable to download JS bundle:

原因是在npm install的时候曾经出现过

react-native@0.43.4 requires a peer of react@16.0.0-alpha.6 but none was installed.

解决办法:

执行 npm i -S react@16.0.0-alpha.6

重启npm start。

5、出现Got JS Exception: TypeError: undefined is not a function (evaluating ‘(bridgeConfig.remoteModuleConfig || []).forEach’) 的错误,原因是被官方文档坑了,官方文档是这样描述的:

allprojects {
    repositories {
        ...
        maven {
            // All of React Native (JS, Android binaries) is installed from npm
            url "$rootDir/../node_modules/react-native/android"
        }
    }
    ...
}

然而正确应该是:

allprojects {
    repositories {
        jcenter()

        maven {
            // All of React Native (JS, Android binaries) is installed from npm
            url "$rootDir/node_modules/react-native/android"
        }
    }
}

 

微博视频url解析

微博返回的视频链接都是短链接,类似http://t.cn/RX8Po3N 这样的格式。那么我们为了能够识别该链接是普通的网络链接还是视频链接,并且支持用自定义的播放器来播放视频的话,要做的东西就是解析这个短链接,获取真实的视频地址。

首先第一步就是要先把短链接转化成长链接,这里我们可以调用新浪开放平台获取短链接的富内容信息。内容结果如下:

其中object _type就是链接的类型,stream 里面的url 就是视频的真实地址了,这里看到是mp4的格式,这种情况就最理想了,就是视频的真实地址,我们可以直接播放下载了。

但其实并没有这么简单,很多时候我们解析到的url都不是以mp4格式的,而是类似这种

http://video.weibo.com/show?fid=1034:ba4e77345c94bc39e7fba0f690b1d26c

http://weibo.com/p/2304449fd45976218a4fd9bc8f1a9af6317dec

这两种视频链接我们是无法直接播放和下载的。只有通过特殊手段才可以。先来说一下以video.weibo.com格式的视频的解析办法:

我们直接在浏览器中打开该url,然后右键查看网页源代码,就可以找到该视频的真实地址:

那么我们要拿到这个真实的mp4地址就非常简单了,先下载该网页源代码,并用正执表达式解析即可:

String result = HttpUtils.doGet(url, null);
if (StringUtil.isNotBlank(result)) {
    String p = "flashvars=\"list(.*)";
    Pattern r = Pattern.compile(p);
    Matcher m = r.matcher(result);
    if (m.find()) {
        String resultUrl = m.group();
        resultUrl = resultUrl.substring(resultUrl.indexOf("flashvars=\"list=") + 16, resultUrl.lastIndexOf("\" />"));
        resultUrl = URLDecoder.decode(resultUrl, "UTF-8");

第二种视频的解析地址需要用到著名的硕鼠解析了。它是什么大家可以自行搜索。下面说解析方法:只需要打开硕鼠的网页的时候带上要解析的url就可以了,得到的就是一个网页:

这样就可以拿到真实地址了,那我们同样通过代码解析该网页就可以了。

String requestUrl = "http://www.flvcd.com/parse.php?kw=" + url;
String result = HttpUtils.doGet(requestUrl, null);
if (StringUtil.isNotBlank(result)) {
    Pattern p = Pattern.compile("<br>.*?<a href=\".*?\"");
    Matcher m = p.matcher(result);
    if (m.find()) {
        String res = m.group(0);
        int index = res.indexOf("=");
        res = res.substring(index + 2, res.length() - 1);

这样就可以拿到微博的视频真实url了。

如有侵权,请联系我删除。