commonrpc 0.1 发布，高性能分布式 RPC 框架

posted @ 2015-03-12 19:02 paulwong 阅读(664) | 评论 (0) | 编辑 收藏

NETTY资源

nginx+tomcat与netty优缺点

posted @ 2015-02-26 09:49 paulwong 阅读(474) | 评论 (0) | 编辑 收藏

SPRING CACHE之ConcurrentMapCacheManager改造

1. pom.xml中加入依赖包
   
           <dependency>
               <groupId>com.google.guava</groupId>
               <artifactId>guava</artifactId>
               <version>18.0</version>
           </dependency>
   
   
2. 改造CacheManager，MyConcurrentMapCacheManager
   
   package com.paul.common.cache;
   /*
    * Copyright 2002-2014 the original author or authors.
    *
    * Licensed under the Apache License, Version 2.0 (the "License");
    * you may not use this file except in compliance with the License.
    * You may obtain a copy of the License at
    *
    *      http://www.apache.org/licenses/LICENSE-2.0
    *
    * Unless required by applicable law or agreed to in writing, software
    * distributed under the License is distributed on an "AS IS" BASIS,
    * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    * See the License for the specific language governing permissions and
    * limitations under the License.
    */
   
   import java.util.Collection;
   import java.util.Collections;
   import java.util.Map;
   import java.util.concurrent.ConcurrentHashMap;
   import java.util.concurrent.ConcurrentMap;
   import java.util.concurrent.TimeUnit;
   
   import org.springframework.cache.Cache;
   import org.springframework.cache.CacheManager;
   import org.springframework.cache.concurrent.ConcurrentMapCache;
   
   import com.google.common.cache.CacheBuilder;
   
   /**
    * {@link CacheManager} implementation that lazily builds {@link ConcurrentMapCache}
    * instances for each {@link #getCache} request. Also supports a 'static' mode where
    * the set of cache names is pre-defined through {@link #setCacheNames}, with no
    * dynamic creation of further cache regions at runtime.
    *
    * <p>Note: This is by no means a sophisticated CacheManager; it comes with no
    * cache configuration options. However, it may be useful for testing or simple
    * caching scenarios. For advanced local caching needs, consider
    * {@link org.springframework.cache.guava.GuavaCacheManager} or
    * {@link org.springframework.cache.ehcache.EhCacheCacheManager}.
    *
    * @author Juergen Hoeller
    * @since 3.1
    * @see ConcurrentMapCache
    */
   public class MyConcurrentMapCacheManager implements CacheManager {
   
       private final ConcurrentMap<String, Cache> cacheMap = new ConcurrentHashMap<String, Cache>(16);
   
       private boolean dynamic = true;
   
       private boolean allowNullValues = true;
       
       private long expireTime = 30;
       
       private long maximumSize = 100;
   
   
       /**
        * Construct a dynamic ConcurrentMapCacheManager,
        * lazily creating cache instances as they are being requested.
        */
       public MyConcurrentMapCacheManager() {
       }
   
       /**
        * Construct a static ConcurrentMapCacheManager,
        * managing caches for the specified cache names only.
        */
       public MyConcurrentMapCacheManager(long expireTime, long maximumSize) {
           if(expireTime > 0)
               this.expireTime = expireTime;
           if(maximumSize > 0)
               this.maximumSize = maximumSize;
       }
   
   
       /**
        * Specify the set of cache names for this CacheManager's 'static' mode.
        * <p>The number of caches and their names will be fixed after a call to this method,
        * with no creation of further cache regions at runtime.
        * <p>Calling this with a {@code null} collection argument resets the
        * mode to 'dynamic', allowing for further creation of caches again.
        */
       public void setCacheNames(Collection<String> cacheNames) {
           if (cacheNames != null) {
               for (String name : cacheNames) {
                   this.cacheMap.put(name, createConcurrentMapCache(name));
               }
               this.dynamic = false;
           }
           else {
               this.dynamic = true;
           }
       }
   
       /**
        * Specify whether to accept and convert {@code null} values for all caches
        * in this cache manager.
        * <p>Default is "true", despite ConcurrentHashMap itself not supporting {@code null}
        * values. An internal holder object will be used to store user-level {@code null}s.
        * <p>Note: A change of the null-value setting will reset all existing caches,
        * if any, to reconfigure them with the new null-value requirement.
        */
       public void setAllowNullValues(boolean allowNullValues) {
           if (allowNullValues != this.allowNullValues) {
               this.allowNullValues = allowNullValues;
               // Need to recreate all Cache instances with the new null-value configuration
               for (Map.Entry<String, Cache> entry : this.cacheMap.entrySet()) {
                   entry.setValue(createConcurrentMapCache(entry.getKey()));
               }
           }
       }
   
       /**
        * Return whether this cache manager accepts and converts {@code null} values
        * for all of its caches.
        */
       public boolean isAllowNullValues() {
           return this.allowNullValues;
       }
   
   
       @Override
       public Collection<String> getCacheNames() {
           return Collections.unmodifiableSet(this.cacheMap.keySet());
       }
   
       @Override
       public Cache getCache(String name) {
           Cache cache = this.cacheMap.get(name);
           if (cache == null && this.dynamic) {
               synchronized (this.cacheMap) {
                   cache = this.cacheMap.get(name);
                   if (cache == null) {
                       cache = createConcurrentMapCache(name);
                       this.cacheMap.put(name, cache);
                   }
               }
           }
           return cache;
       }
   
       /**
        * Create a new ConcurrentMapCache instance for the specified cache name.
        * @param name the name of the cache
        * @return the ConcurrentMapCache (or a decorator thereof)
        */
       protected Cache createConcurrentMapCache(String name) {
           //return new ConcurrentMapCache(name, isAllowNullValues());
           //此处改用GOOGLE GUAVA的构造MANAGER方式
           return new ConcurrentMapCache(name,
                                           CacheBuilder.newBuilder()
                                                       .expireAfterWrite(this.expireTime, TimeUnit.MINUTES)
                                                       .maximumSize(this.maximumSize)
                                                       .build()
                                                       .asMap(), 
                                           isAllowNullValues());
       }
   
   }
   
   
   
3. 配置想着bean, cache-concurrentmap-applicationcontext.xml
   
   <?xml version="1.0" encoding="UTF-8"?>
   <beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
       xmlns:cache="http://www.springframework.org/schema/cache"
       xmlns:p="http://www.springframework.org/schema/p"
       xmlns:c="http://www.springframework.org/schema/c"
       xmlns:jee="http://www.springframework.org/schema/jee"
       xmlns:util="http://www.springframework.org/schema/util"
       xsi:schemaLocation="http://www.springframework.org/schema/context
             http://www.springframework.org/schema/context/spring-context-3.0.xsd
             http://www.springframework.org/schema/beans
             http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
             http://www.springframework.org/schema/cache
             http://www.springframework.org/schema/cache/spring-cache.xsd
             http://www.springframework.org/schema/jee 
             http://www.springframework.org/schema/jee/spring-jee.xsd
             http://www.springframework.org/schema/util
             http://www.springframework.org/schema/util/spring-util.xsd">
   
       <cache:annotation-driven />
   
       <!-- <bean id="cacheManager"
           class="org.springframework.cache.concurrent.ConcurrentMapCacheManager" >
           <property name="cacheNames">
               <list>
                   <value>my-local-cache</value>
               </list>
           </property>
       </bean> -->
       
       <bean id="cacheManager"
           class="com.paul.common.cache.MyConcurrentMapCacheManager">
           <constructor-arg index="0" value="1" />
           <constructor-arg index="1" value="5000" />
       </bean>    
       
   </beans>
   
   
   
4. 通过注释进行使用
   
   /*
    * JBoss, Home of Professional Open Source
    * Copyright 2014, Red Hat, Inc. and/or its affiliates, and individual
    * contributors by the @authors tag. See the copyright.txt in the
    * distribution for a full listing of individual contributors.
    *
    * Licensed under the Apache License, Version 2.0 (the "License");
    * you may not use this file except in compliance with the License.
    * You may obtain a copy of the License at
    * http://www.apache.org/licenses/LICENSE-2.0
    * Unless required by applicable law or agreed to in writing, software
    * distributed under the License is distributed on an "AS IS" BASIS,
    * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    * See the License for the specific language governing permissions and
    * limitations under the License.
    */
   package com.paul.springmvc.data;
   
   import java.util.List;
   
   import javax.persistence.EntityManager;
   import javax.persistence.criteria.CriteriaBuilder;
   import javax.persistence.criteria.CriteriaQuery;
   import javax.persistence.criteria.Root;
   
   import org.springframework.beans.factory.annotation.Autowired;
   import org.springframework.cache.annotation.CacheEvict;
   import org.springframework.cache.annotation.Cacheable;
   import org.springframework.stereotype.Repository;
   import org.springframework.transaction.annotation.Transactional;
   
   import com.paul.springmvc.model.Member;
   
   @Repository
   @Transactional
   public class MemberDaoImpl implements MemberDao {
       @Autowired
       private EntityManager em;
   
       @Cacheable(value = "my-local-cache", key = "#id")
       public Member findById(Long id) {
           System.out.println("MemberDaoImpl NO CACHE");
           return em.find(Member.class, id);
       }
   
       public Member findByEmail(String email) {
           CriteriaBuilder cb = em.getCriteriaBuilder();
           CriteriaQuery<Member> criteria = cb.createQuery(Member.class);
           Root<Member> member = criteria.from(Member.class);
   
           /*
            * Swap criteria statements if you would like to try out type-safe criteria queries, a new
            * feature in JPA 2.0 criteria.select(member).orderBy(cb.asc(member.get(Member_.name)));
            */
   
           criteria.select(member).where(cb.equal(member.get("email"), email));
           return em.createQuery(criteria).getSingleResult();
       }
   
       public List<Member> findAllOrderedByName() {
           CriteriaBuilder cb = em.getCriteriaBuilder();
           CriteriaQuery<Member> criteria = cb.createQuery(Member.class);
           Root<Member> member = criteria.from(Member.class);
   
           /*
            * Swap criteria statements if you would like to try out type-safe criteria queries, a new
            * feature in JPA 2.0 criteria.select(member).orderBy(cb.asc(member.get(Member_.name)));
            */
   
           criteria.select(member).orderBy(cb.asc(member.get("name")));
           return em.createQuery(criteria).getResultList();
       }
   
       @CacheEvict(value="my-local-cache",allEntries=true,beforeInvocation=true)//清空所有缓存
       public void register(Member member) {
           em.persist(member);
           return;
       }
   }

posted @ 2015-02-25 16:34 paulwong 阅读(2699) | 评论 (0) | 编辑 收藏

SPRING CACHE资源

Spring Cache抽象详解

posted @ 2015-02-25 16:04 paulwong 阅读(506) | 评论 (0) | 编辑 收藏

Spring Boot使用redis做数据缓存

1 添加redis支持

在pom.xml中添加

Xml代码  

1. <dependency>  
2.           <groupId>org.springframework.boot</groupId>  
3.           <artifactId>spring-boot-starter-redis</artifactId>  
4.       </dependency>  

 

2 redis配置

Java代码  

1. @Configuration  
2. @EnableCaching  
3. public class RedisCacheConfig {  
4.     @Bean  
5.     public CacheManager cacheManager(  
6.             @SuppressWarnings("rawtypes") RedisTemplate redisTemplate) {  
7.         return new RedisCacheManager(redisTemplate);  
8.     }  
9.   
10.     @Bean  
11.     public RedisTemplate<String, String> redisTemplate(  
12.             RedisConnectionFactory factory) {  
13.         final StringRedisTemplate template = new StringRedisTemplate(factory);  
14.         template.setValueSerializer(new Jackson2JsonRedisSerializer<SysUser>(  
15.                 SysUser.class)); //请注意这里  
16.   
17.         return template;  
18.     }  
19. }  

 

3 redis服务器配置

Properties代码  

1. # REDIS (RedisProperties)  
2. spring.redis.database= # database name  
3. spring.redis.host=localhost # server host  
4. spring.redis.password= # server password  
5. spring.redis.port=6379 # connection port  
6. spring.redis.pool.max-idle=8 # pool settings ...  
7. spring.redis.pool.min-idle=0  
8. spring.redis.pool.max-active=8  
9. spring.redis.pool.max-wait=-1  
10. spring.redis.sentinel.master= # name of Redis server  
11. spring.redis.sentinel.nodes= # comma-separated list of host:port pairs  

 

4 应用

Java代码  

1. /** 
2. *此处的dao操作使用的是spring data jpa,使用@Cacheable可以在任意方法上，*比如@Service或者@Controller的方法上 
3. */  
4. public interface SysUserRepo1 extends CustomRepository<SysUser, Long> {  
5.     @Cacheable(value = "usercache")  
6.     public SysUser findByUsername(String username);  
7. }  

 

5 检验

Java代码  

1. @Controller  
2. public class TestController {  
3.       
4.       
5.     @Autowired   
6.     SysUserRepo1 sysUserRepo1;  
7.     @RequestMapping("/test")  
8.     public @ResponseBody String test(){  
9.   
10.         final SysUser loaded = sysUserRepo1.findByUsername("wyf");  
11.         final SysUser cached = sysUserRepo1.findByUsername("wyf");  
12.           
13.         return "ok";  
14.     }   
15. }  

 

效果如图：

 

posted @ 2015-02-25 10:02 paulwong 阅读(5281) | 评论 (3) | 编辑 收藏

2015年2月份最佳的免费 UI 工具包

posted @ 2015-02-24 18:25 paulwong 阅读(481) | 评论 (0) | 编辑 收藏

使用WILDFLY中的分布式缓存INFISHPAN

1. 通过http://127.0.0.1:9991/console/App.html#infinispan添加CACHE
   
   <cache-container name="tickets" default-cache="default" jndi-name="java:jboss/infinispan/tickets">
          <local-cache name="default" batching="true">
                 <locking isolation="REPEATABLE_READ"/>
          </local-cache>
   </cache-container>
   
   
2. pom.xml添加依赖包
   
           <dependency>
               <groupId>org.infinispan</groupId>
               <artifactId>infinispan-core</artifactId>
               <scope>provided</scope>
           </dependency>
           
           <dependency>
               <groupId>org.infinispan</groupId>
               <artifactId>infinispan-client-hotrod</artifactId>
               <scope>provided</scope>
           </dependency>
   
       <dependency>
           <groupId>org.jgroups</groupId>
           <artifactId>jgroups</artifactId>
           <scope>provided</scope>
       </dependency>
   
           <dependency>
               <groupId>org.infinispan</groupId>
               <artifactId>infinispan-spring</artifactId>
               <version>6.0.2.Final</version>
           </dependency>
           
           <dependency>
               <groupId>org.infinispan</groupId>
               <artifactId>infinispan-jcache</artifactId>
               <version>6.0.2.Final</version>
           </dependency>
   
   
3. 添加拦截器，WEB-INF/beans.xml
   
   <?xml version="1.0"?>
   <beans xmlns="http://java.sun.com/xml/ns/javaee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://jboss.org/schema/cdi/beans_1_0.xsd">
       <interceptors>
           <class>org.infinispan.jcache.annotation.CacheResultInterceptor</class>
           <class>org.infinispan.jcache.annotation.CachePutInterceptor</class>
           <class>org.infinispan.jcache.annotation.CacheRemoveEntryInterceptor</class>
           <class>org.infinispan.jcache.annotation.CacheRemoveAllInterceptor</class>
       </interceptors>
   </beans>
   
   
4. 添加项目的全局依赖，WEB-INF/jboss-deployment-structure.xml
   
   <?xml version="1.0" encoding="UTF-8"?>
   <jboss-deployment-structure>
       <deployment>
           <dependencies>
               <module name="org.jboss.xnio" />
               <module name="org.infinispan" export="true"/>
               <module name="org.infinispan.commons" export="true"/>
               <module name="org.infinispan.client.hotrod" export="true"/>
           </dependencies>
       </deployment>
   </jboss-deployment-structure>
   
   
5. 在CDI BEAN中使用CACHE
   
   package com.paul.myejb;
   
   import javax.annotation.Resource;
   import javax.cache.annotation.CacheResult;
   import javax.ejb.Remote;
   import javax.ejb.Stateless;
   import javax.interceptor.Interceptors;
   
   import org.infinispan.Cache;
   import org.infinispan.manager.EmbeddedCacheManager;
   //import org.springframework.cache.annotation.Cacheable;
   import org.springframework.ejb.interceptor.SpringBeanAutowiringInterceptor;
   
   /**
    * Session Bean implementation class HelloWorldBean
    */
   @Stateless
   //@Local(HelloWorld.class)
   @Remote(HelloWorld.class)
   @Interceptors(SpringBeanAutowiringInterceptor.class)
   //@RolesAllowed({Roles.ADMIN})
   public class HelloWorldBean implements HelloWorld {
       
       @Resource(lookup = "java:jboss/infinispan/tickets")
       private EmbeddedCacheManager container;
       
       
       /**
        * Default constructor. 
        */
       public HelloWorldBean() {
       }
   
   //    @Transactional
   //    @Cacheable(value = "books", key = "#name")
       @CacheResult
       public String sayHello(String name) {
           System.out.println("NO CACHE");
           String result = "Hello " + name + ", I am HelloWorldBean.";
           Cache<String, String> cache = this.container.getCache();
           cache.put(name, result);
           return result;
       }
   
   }
   
   
   
6. 修改modules/system/layers/base/org/infinispan/client/hotrod/main/modules.xml
   
   <?xml version="1.0" encoding="UTF-8"?>
   <!--
     ~ JBoss, Home of Professional Open Source.
     ~ Copyright 2010, Red Hat, Inc., and individual contributors
     ~ as indicated by the @author tags. See the copyright.txt file in the
     ~ distribution for a full listing of individual contributors.
     ~
     ~ This is free software; you can redistribute it and/or modify it
     ~ under the terms of the GNU Lesser General Public License as
     ~ published by the Free Software Foundation; either version 2.1 of
     ~ the License, or (at your option) any later version.
     ~
     ~ This software is distributed in the hope that it will be useful,
     ~ but WITHOUT ANY WARRANTY; without even the implied warranty of
     ~ MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
     ~ Lesser General Public License for more details.
     ~
     ~ You should have received a copy of the GNU Lesser General Public
     ~ License along with this software; if not, write to the Free
     ~ Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
     ~ 02110-1301 USA, or see the FSF site: http://www.fsf.org.
     -->
   <module xmlns="urn:jboss:module:1.3" name="org.infinispan.client.hotrod">
       <properties>
           <property name="jboss.api" value="private"/>
       </properties>
   
       <resources>
           <resource-root path="infinispan-client-hotrod-6.0.2.Final.jar"/>
       </resources>
   
       <dependencies>
           <module name="javax.api"/>
           <!--下面这一行注释掉-->
           <!--<module name="com.google.protobuf"/>-->
           <module name="org.apache.commons.pool"/>
           <module name="org.infinispan.commons"/>
           <module name="org.infinispan.query.dsl"/>
           <module name="org.jboss.logging"/>
       </dependencies>
   </module>
   
   

1. 添加依赖的SPRING BEAN
   
   <?xml version="1.0" encoding="UTF-8"?>
   <beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
       xmlns:cache="http://www.springframework.org/schema/cache"
       xmlns:p="http://www.springframework.org/schema/p"
       xmlns:jee="http://www.springframework.org/schema/jee"
       xsi:schemaLocation="http://www.springframework.org/schema/context
             http://www.springframework.org/schema/context/spring-context-3.0.xsd
             http://www.springframework.org/schema/beans
             http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
             http://www.springframework.org/schema/cache
             http://www.springframework.org/schema/cache/spring-cache.xsd
             http://www.springframework.org/schema/jee 
             http://www.springframework.org/schema/jee/spring-jee.xsd">
   
       <cache:annotation-driven />
       
       <bean id="cacheManager"
             class="org.infinispan.spring.provider.ContainerCacheManagerFactoryBean">
             <constructor-arg ref="cacheContainer"  />
       </bean>
       
       <jee:jndi-lookup id="cacheContainer" jndi-name="java:jboss/infinispan/tickets" > 
       </jee:jndi-lookup>
       
       <!-- <bean id="cacheContainer"
             class="com.paul.myejb.common.util.cache.JndiSpringCacheManagerFactoryBean"
             p:infinispanJNDI="java:jboss/infinispan/tickets" /> -->
       
   </beans>
   
   
2. 使用CACHE
   
   package com.paul.myejb.spring;
   
   import org.springframework.beans.factory.annotation.Autowired;
   import org.springframework.cache.CacheManager;
   import org.springframework.cache.annotation.Cacheable;
   import org.springframework.stereotype.Component;
   
   @Component
   public class MySpringBean {
       
       @Autowired
       private CacheManager cacheManager;
       
       @Cacheable(value = "my-local-cache", key = "#name")
       public String sayHello(String name)
       {
           System.out.println("MySpringBean NO CACHE");
           String result = "Hi " + name + ", I am Spring!";
           org.springframework.cache.Cache springCache = this.cacheManager.getCache("my-local-cache");
           System.out.println(springCache.get(name) == null ? "null" : springCache.get(name).get());
           springCache.put(name, result);
           return result;
       }
   
   }
   
   
3. 
   

posted @ 2015-02-23 13:40 paulwong 阅读(1005) | 评论 (0) | 编辑 收藏

Infinispan资源

infinispan-quickstart

posted @ 2015-02-22 14:03 paulwong 阅读(519) | 评论 (0) | 编辑 收藏

Add Apache Camel and Spring as jboss modules in WildFly

posted @ 2015-02-21 20:13 paulwong 阅读(685) | 评论 (0) | 编辑 收藏

JBoss AS7的classloader机制

posted @ 2015-02-21 19:35 paulwong 阅读(1300) | 评论 (0) | 编辑 收藏