commit

.gitignore

@@ -0,0 +1,3 @@
+/.project
+/.settings
+/src

pom.xml

@@ -0,0 +1,15 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+  <groupId>net.aimeizi</groupId>
+  <artifactId>maven-framework-project</artifactId>
+  <version>1.0.0</version>
+  <packaging>pom</packaging>
+  <modules>
+  	<module>spring3-javaconfig-example</module>
+  	<module>spring3-helloworld-example</module>
+  	<module>spring3-javaconfig-import-example</module>
+  	<module>spring3-mvc-simple</module>
+  	<module>spring3-jmx-example</module>
+  	<module>spring3-rmi-example</module>
+  </modules>
+</project>

spring3-helloworld-example/.gitignore

@@ -0,0 +1,4 @@
+/.project
+/.settings
+/target
+/.classpath

spring3-helloworld-example/pom.xml

@@ -0,0 +1,28 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+	<parent>
+		<groupId>net.aimeizi</groupId>
+		<artifactId>maven-framework-project</artifactId>
+		<version>1.0.0</version>
+	</parent>
+	<artifactId>spring3-helloworld-example</artifactId>
+
+	<dependencies>
+		<dependency>
+			<groupId>org.springframework</groupId>
+			<artifactId>spring-core</artifactId>
+			<version>${spring.version}</version>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework</groupId>
+			<artifactId>spring-context</artifactId>
+			<version>${spring.version}</version>
+		</dependency>
+	</dependencies>
+
+	<properties>
+		<spring.version>3.2.3.RELEASE</spring.version>
+	</properties>
+
+</project>

spring3-helloworld-example/src/main/java/net/aimeizi/helloworld/example/App.java

@@ -0,0 +1,26 @@
+package net.aimeizi.helloworld.example;
+
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.support.ClassPathXmlApplicationContext;
+
+public class App {
+
+	@SuppressWarnings("resource")
+	public static void main(String[] args) {
+
+	/**
+	 * Create a new ApplicationContext, loading the 
+	 * definitions from the given XML file 
+	 */
+	ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
+	/**
+	 * Return an instance, which may be shared or 
+	 * independent, of the specified bean.
+	 */
+	HelloWorldService obj = (HelloWorldService) context.getBean("helloWorldService");
+	obj.setName("Spring 3.2.3");
+	String message =obj.sayHello();
+	System.out.println(message);
+	}
+	
+}

spring3-helloworld-example/src/main/java/net/aimeizi/helloworld/example/HelloWorldService.java

@@ -0,0 +1,18 @@
+package net.aimeizi.helloworld.example;
+
+import org.springframework.stereotype.Service;
+
+@Service("helloWorldService")
+public class HelloWorldService {
+	
+	private String name;
+
+	public void setName(String name) {
+		this.name = name;
+	}
+
+	public String sayHello() {
+		return "Hello from HelloWorld Service! " + name;
+	}
+	
+}

spring3-helloworld-example/src/main/resources/applicationContext.xml

@@ -0,0 +1,15 @@
+<?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:p="http://www.springframework.org/schema/p"
+	xmlns:aop="http://www.springframework.org/schema/aop" xmlns:context="http://www.springframework.org/schema/context"
+	xmlns:jee="http://www.springframework.org/schema/jee" xmlns:tx="http://www.springframework.org/schema/tx"
+	xmlns:task="http://www.springframework.org/schema/task"
+	xsi:schemaLocation="http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.2.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-3.2.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.2.xsd http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.2.xsd">
+
+	<context:component-scan base-package="net.aimeizi.helloworld.example" />
+	
+	<bean id="helloWorldService" class="net.aimeizi.helloworld.example.HelloWorldService">
+		<property name="name" value="Spring 3.2.3" />
+	</bean>
+
+</beans>

spring3-javaconfig-example/.gitignore

@@ -0,0 +1,4 @@
+/.project
+/.settings
+/target
+/.classpath

spring3-javaconfig-example/pom.xml

@@ -0,0 +1,34 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+	<parent>
+		<groupId>net.aimeizi</groupId>
+		<artifactId>maven-framework-project</artifactId>
+		<version>1.0.0</version>
+	</parent>
+	<artifactId>spring3-javaconfig-example</artifactId>
+
+
+	<dependencies>
+		<dependency>
+			<groupId>org.springframework</groupId>
+			<artifactId>spring-core</artifactId>
+			<version>${spring.version}</version>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework</groupId>
+			<artifactId>spring-context</artifactId>
+			<version>${spring.version}</version>
+		</dependency>
+		<dependency>
+			<groupId>cglib</groupId>
+			<artifactId>cglib</artifactId>
+			<version>3.0</version>
+		</dependency>
+	</dependencies>
+
+	<properties>
+		<spring.version>3.2.3.RELEASE</spring.version>
+	</properties>
+
+</project>

spring3-javaconfig-example/src/main/java/net/aimeizi/javaconfig/example/App.java

@@ -0,0 +1,26 @@
+package net.aimeizi.javaconfig.example;
+
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.annotation.AnnotationConfigApplicationContext;
+
+public class App {
+
+	@SuppressWarnings("resource")
+	public static void main(String[] args) {
+
+		/**
+		 * Create a new ApplicationContext, deriving bean definition from the
+		 * given annotated class and automatically refreshing the context.
+		 */
+		ApplicationContext context = new AnnotationConfigApplicationContext(AppConfig.class);
+		/**
+		 * Return an instance, which may be shared or independent, of the
+		 * specified bean.
+		 */
+		HelloWorldService obj = (HelloWorldService) context.getBean("helloWorldBean");
+		obj.setName("Spring 3.2.3");
+		obj.sayHello();
+
+	}
+
+}

spring3-javaconfig-example/src/main/java/net/aimeizi/javaconfig/example/AppConfig.java

@@ -0,0 +1,14 @@
+package net.aimeizi.javaconfig.example;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class AppConfig {
+
+	@Bean(name="helloWorldBean")
+    public HelloWorldService helloWorldService() {
+        return new HelloWorldService();
+    }
+	
+}

spring3-javaconfig-example/src/main/java/net/aimeizi/javaconfig/example/HelloWorldService.java

@@ -0,0 +1,19 @@
+package net.aimeizi.javaconfig.example;
+
+public class HelloWorldService {
+
+	private String name;
+	
+	public String getName() {
+		return name;
+	}
+
+	public void setName(String name) {
+		this.name = name;
+	}
+
+	public void sayHello() {
+		System.out.println("Hello from Java Configuration. " + this.getName());
+	}
+	
+}

spring3-javaconfig-example/src/main/resources/applicationContext.xml

@@ -0,0 +1,16 @@
+<?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:p="http://www.springframework.org/schema/p"
+	xmlns:aop="http://www.springframework.org/schema/aop" xmlns:context="http://www.springframework.org/schema/context"
+	xmlns:jee="http://www.springframework.org/schema/jee" xmlns:tx="http://www.springframework.org/schema/tx"
+	xmlns:task="http://www.springframework.org/schema/task"
+	xsi:schemaLocation=" http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.2.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-3.2.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.2.xsd http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.2.xsd">
+	
+	<!--  
+	<bean id="helloWorldBean"
+		class="net.aimeizi.javaconfig.example.HelloWorldService">
+		<property name="name" value="Spring 3.2.3" />
+	</bean>
+	-->
+	
+</beans>

spring3-javaconfig-import-example/.gitignore

@@ -0,0 +1,4 @@
+/.project
+/.settings
+/target
+/.classpath

spring3-javaconfig-import-example/pom.xml

@@ -0,0 +1,33 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+	<parent>
+		<groupId>net.aimeizi</groupId>
+		<artifactId>maven-framework-project</artifactId>
+		<version>1.0.0</version>
+	</parent>
+	<artifactId>spring3-javaconfig-import-example</artifactId>
+
+	<dependencies>
+		<dependency>
+			<groupId>org.springframework</groupId>
+			<artifactId>spring-core</artifactId>
+			<version>${spring.version}</version>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework</groupId>
+			<artifactId>spring-context</artifactId>
+			<version>${spring.version}</version>
+		</dependency>
+		<dependency>
+			<groupId>cglib</groupId>
+			<artifactId>cglib</artifactId>
+			<version>3.0</version>
+		</dependency>
+	</dependencies>
+
+	<properties>
+		<spring.version>3.2.3.RELEASE</spring.version>
+	</properties>
+
+</project>

spring3-javaconfig-import-example/src/main/java/net/aimeizi/javaconfig/example/App.java

@@ -0,0 +1,21 @@
+package net.aimeizi.javaconfig.example;
+
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.annotation.AnnotationConfigApplicationContext;
+
+public class App {
+	
+	@SuppressWarnings("resource")
+	public static void main(String[] args) {
+
+	ApplicationContext context = new AnnotationConfigApplicationContext(AppConfig.class);
+
+	HelloWorldService hello = (HelloWorldService) context.getBean("helloWorldBean");
+	hello.sayHello("Spring 3.2.3");
+	
+	GoodbyeService bye = (GoodbyeService) context.getBean("goodbyeBean");
+	bye.sayGoodbye("Spring 3.2.3");
+
+	}
+	
+}

spring3-javaconfig-import-example/src/main/java/net/aimeizi/javaconfig/example/AppConfig.java

@@ -0,0 +1,10 @@
+package net.aimeizi.javaconfig.example;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Import;
+
+@Configuration
+@Import(value={HelloConfig.class,GoodbyeConfig.class})
+public class AppConfig {
+
+}

spring3-javaconfig-import-example/src/main/java/net/aimeizi/javaconfig/example/AppXml.java

@@ -0,0 +1,21 @@
+package net.aimeizi.javaconfig.example;
+
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.support.ClassPathXmlApplicationContext;
+
+public class AppXml {
+
+	@SuppressWarnings("resource")
+	public static void main(String[] args) {
+
+		ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
+
+		HelloWorldService hello = (HelloWorldService) context.getBean("helloWorldBean");
+		hello.sayHello("Spring 3.2.3");
+
+		GoodbyeService bye = (GoodbyeService) context.getBean("goodbyeBean");
+		bye.sayGoodbye("Spring 3.2.3");
+
+	}
+
+}

spring3-javaconfig-import-example/src/main/java/net/aimeizi/javaconfig/example/GoodbyeConfig.java

@@ -0,0 +1,14 @@
+package net.aimeizi.javaconfig.example;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class GoodbyeConfig {
+
+	@Bean(name="goodbyeBean")
+    public GoodbyeService goodByeService() {
+        return new GoodbyeService();
+    }
+	
+}

spring3-javaconfig-import-example/src/main/java/net/aimeizi/javaconfig/example/GoodbyeService.java

@@ -0,0 +1,9 @@
+package net.aimeizi.javaconfig.example;
+
+public class GoodbyeService {
+
+	public void sayGoodbye(String name){
+		System.out.println("Goodbye from Java Configuration. "+ name);
+	}
+	
+}

spring3-javaconfig-import-example/src/main/java/net/aimeizi/javaconfig/example/HelloConfig.java

@@ -0,0 +1,14 @@
+package net.aimeizi.javaconfig.example;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class HelloConfig {
+	
+	@Bean(name="helloWorldBean")
+    public HelloWorldService helloWorldService() {
+        return new HelloWorldService();
+    }
+	
+}

spring3-javaconfig-import-example/src/main/java/net/aimeizi/javaconfig/example/HelloWorldService.java

@@ -0,0 +1,9 @@
+package net.aimeizi.javaconfig.example;
+
+public class HelloWorldService {
+
+	public void sayHello(String name) {
+		System.out.println("Hello from Java Configuration. " + name);
+	}
+	
+}

spring3-javaconfig-import-example/src/main/resources/applicationContext.xml

@@ -0,0 +1,12 @@
+<?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:p="http://www.springframework.org/schema/p"
+	xmlns:aop="http://www.springframework.org/schema/aop" xmlns:context="http://www.springframework.org/schema/context"
+	xmlns:jee="http://www.springframework.org/schema/jee" xmlns:tx="http://www.springframework.org/schema/tx"
+	xmlns:task="http://www.springframework.org/schema/task"
+	xsi:schemaLocation="http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.2.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-3.2.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.2.xsd http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.2.xsd">
+
+	<import resource="classpath*:hello.xml" />
+	<import resource="classpath*:goodbye.xml" />
+
+</beans>

spring3-javaconfig-import-example/src/main/resources/goodbye.xml

@@ -0,0 +1,13 @@
+<?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:p="http://www.springframework.org/schema/p"
+	xmlns:aop="http://www.springframework.org/schema/aop" xmlns:context="http://www.springframework.org/schema/context"
+	xmlns:jee="http://www.springframework.org/schema/jee" xmlns:tx="http://www.springframework.org/schema/tx"
+	xmlns:task="http://www.springframework.org/schema/task"
+	xsi:schemaLocation="http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.2.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-3.2.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.2.xsd http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.2.xsd">
+
+	<bean id="goodbyeBean"
+		class="net.aimeizi.javaconfig.example.GoodbyeService">
+	</bean>
+
+</beans>

spring3-javaconfig-import-example/src/main/resources/hello.xml

@@ -0,0 +1,13 @@
+<?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:p="http://www.springframework.org/schema/p"
+	xmlns:aop="http://www.springframework.org/schema/aop" xmlns:context="http://www.springframework.org/schema/context"
+	xmlns:jee="http://www.springframework.org/schema/jee" xmlns:tx="http://www.springframework.org/schema/tx"
+	xmlns:task="http://www.springframework.org/schema/task"
+	xsi:schemaLocation="http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.2.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-3.2.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.2.xsd http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.2.xsd">
+
+	<bean id="helloWorldBean"
+		class="net.aimeizi.javaconfig.example.HelloWorldService">
+	</bean>
+
+</beans>

spring3-jmx-example/.gitignore

@@ -0,0 +1,4 @@
+/target
+/.classpath
+/.project
+/.settings

spring3-jmx-example/README.md

@@ -0,0 +1,20 @@
+# spring3-jmx-example
+
+copy jmxremote.access jmxremote.password
+
+service:jmx:rmi://localhost/jndi/rmi://localhost:8888/jemosJmxConnector
+
+jemosAdmin / secure
+
+![](src/main/resources/jmx-1.jpg)
+
+![](src/main/resources/jmx-2.jpg)
+
+![](src/main/resources/jmx-3.jpg)
+
+
+* [http://www.javacodegeeks.com/2012/07/jmx-and-spring-part-1.html](http://www.javacodegeeks.com/2012/07/jmx-and-spring-part-1.html)
+
+* [http://www.javacodegeeks.com/2012/07/jmx-and-spring-part-2.html](http://www.javacodegeeks.com/2012/07/jmx-and-spring-part-2.html)
+
+* [http://www.javacodegeeks.com/2012/07/jmx-and-spring-part-3.html](http://www.javacodegeeks.com/2012/07/jmx-and-spring-part-3.html)

spring3-jmx-example/pom.xml

@@ -0,0 +1,95 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+	<parent>
+		<groupId>net.aimeizi</groupId>
+		<artifactId>maven-framework-project</artifactId>
+		<version>1.0.0</version>
+	</parent>
+	<groupId>net.aimeizi.jmx.example</groupId>
+	<artifactId>spring3-jmx-example</artifactId>
+
+	<dependencies>
+		<dependency>
+			<groupId>junit</groupId>
+			<artifactId>junit</artifactId>
+			<version>4.8.2</version>
+			<scope>test</scope>
+		</dependency>
+		<dependency>
+			<groupId>log4j</groupId>
+			<artifactId>log4j</artifactId>
+			<version>1.2.16</version>
+			<scope>compile</scope>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework</groupId>
+			<artifactId>spring-context</artifactId>
+			<version>3.0.5.RELEASE</version>
+			<scope>compile</scope>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework</groupId>
+			<artifactId>spring-core</artifactId>
+			<version>3.0.5.RELEASE</version>
+			<scope>compile</scope>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework</groupId>
+			<artifactId>spring-jmx</artifactId>
+			<version>2.0.8</version>
+			<scope>compile</scope>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework</groupId>
+			<artifactId>spring-test</artifactId>
+			<version>3.0.5.RELEASE</version>
+			<type>jar</type>
+			<scope>test</scope>
+		</dependency>
+		<dependency>
+			<groupId>javax.annotation</groupId>
+			<artifactId>jsr250-api</artifactId>
+			<version>1.0</version>
+		</dependency>
+		<dependency>
+			<groupId>commons-io</groupId>
+			<artifactId>commons-io</artifactId>
+			<version>2.0.1</version>
+		</dependency>
+	</dependencies>
+
+	<build>
+		<plugins>
+			<plugin>
+				<groupId>org.apache.maven.plugins</groupId>
+				<artifactId>maven-compiler-plugin</artifactId>
+				<version>2.3.2</version>
+				<configuration>
+					<source>1.7</source>
+					<target>1.7</target>
+				</configuration>
+			</plugin>
+			<plugin>
+				<groupId>org.apache.maven.plugins</groupId>
+				<artifactId>maven-assembly-plugin</artifactId>
+				<version>2.2.1</version>
+				<executions>
+					<execution>
+						<id>buildable-project</id>
+						<phase>install</phase>
+						<goals>
+							<goal>assembly</goal>
+						</goals>
+					</execution>
+				</executions>
+				<configuration>
+					<descriptorRefs>
+						<descriptorRef>project</descriptorRef>
+					</descriptorRefs>
+				</configuration>
+			</plugin>
+		</plugins>
+	</build>
+
+</project>

spring3-jmx-example/src/main/java/net/aimeizi/jmx/example/SystemConfig.java

@@ -0,0 +1,41 @@
+package net.aimeizi.jmx.example;
+
+public class SystemConfig implements SystemConfigMBean {
+	 
+    private int threadCount;
+    private String schemaName;
+     
+    public SystemConfig(int numThreads, String schema){
+        this.threadCount=numThreads;
+        this.schemaName=schema;
+    }
+     
+    @Override
+    public void setThreadCount(int noOfThreads) {
+        this.threadCount=noOfThreads;
+    }
+ 
+ 
+    @Override
+    public int getThreadCount() {
+        return this.threadCount;
+    }
+ 
+ 
+    @Override
+    public void setSchemaName(String schemaName) {
+        this.schemaName=schemaName;
+    }
+ 
+ 
+    @Override
+    public String getSchemaName() {
+        return this.schemaName;
+    }
+     
+    @Override
+    public String doConfig(){
+        return "No of Threads="+this.threadCount+" and DB Schema Name="+this.schemaName;
+    }
+ 
+}

spring3-jmx-example/src/main/java/net/aimeizi/jmx/example/SystemConfigMBean.java

@@ -0,0 +1,15 @@
+package net.aimeizi.jmx.example;
+
+public interface SystemConfigMBean {
+
+	public void setThreadCount(int noOfThreads);
+
+	public int getThreadCount();
+
+	public void setSchemaName(String schemaName);
+
+	public String getSchemaName();
+
+	public String doConfig();
+
+}

spring3-jmx-example/src/main/java/net/aimeizi/jmx/example/SystemConfigManagement.java

@@ -0,0 +1,30 @@
+package net.aimeizi.jmx.example;
+
+import java.lang.management.ManagementFactory;
+
+import javax.management.InstanceAlreadyExistsException;
+import javax.management.MBeanRegistrationException;
+import javax.management.MBeanServer;
+import javax.management.MalformedObjectNameException;
+import javax.management.NotCompliantMBeanException;
+import javax.management.ObjectName;
+ 
+public class SystemConfigManagement {
+    private static final int DEFAULT_NO_THREADS=10;
+    private static final String DEFAULT_SCHEMA="default";
+ 
+    public static void main(String[] args) throws MalformedObjectNameException, InterruptedException, InstanceAlreadyExistsException, MBeanRegistrationException, NotCompliantMBeanException {
+        //Get the MBean server
+        MBeanServer mbs = ManagementFactory.getPlatformMBeanServer();
+        //register the MBean
+        SystemConfig mBean = new SystemConfig(DEFAULT_NO_THREADS, DEFAULT_SCHEMA);
+        ObjectName name = new ObjectName("net.aimeizi.jmx.example:type=SystemConfig");
+        mbs.registerMBean(mBean, name);
+        do{
+            Thread.sleep(3000);
+            System.out.println("Thread Count="+mBean.getThreadCount()+":::Schema Name="+mBean.getSchemaName());
+        }while(mBean.getThreadCount() !=0);
+         
+    }
+ 
+}

spring3-jmx-example/src/main/java/net/aimeizi/jmx/example/TomcatJMX.java

@@ -0,0 +1,171 @@
+package net.aimeizi.jmx.example;
+
+import java.lang.management.MemoryUsage;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.Formatter;
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.Map;
+import java.util.Set;
+
+import javax.management.MBeanAttributeInfo;
+import javax.management.MBeanInfo;
+import javax.management.MBeanServerConnection;
+import javax.management.ObjectInstance;
+import javax.management.ObjectName;
+import javax.management.openmbean.CompositeDataSupport;
+import javax.management.remote.JMXConnector;
+import javax.management.remote.JMXConnectorFactory;
+import javax.management.remote.JMXServiceURL;
+
+/**
+ * 使用JMX监控Tomcat
+ * @author welcome
+ *
+ */
+public class TomcatJMX {
+
+	@SuppressWarnings({ "rawtypes", "unused" })
+	public static void main(String[] args) {
+		try {
+
+			String jmxURL = "service:jmx:rmi:///jndi/rmi://127.0.0.1:8999/jmxrmi";
+
+			JMXServiceURL serviceURL = new JMXServiceURL(jmxURL);
+
+			Map<String,String[]> map = new HashMap<String,String[]>();
+			String[] credentials = new String[] { "monitorRole", "admin" };
+			map.put("jmx.remote.credentials", credentials);
+			JMXConnector connector = JMXConnectorFactory.connect(serviceURL,map);
+			MBeanServerConnection mbsc = connector.getMBeanServerConnection();
+
+			// 端口最好是动态取得
+			ObjectName threadObjName = new ObjectName(
+					"Catalina:type=ThreadPool,name=http-8080");
+			MBeanInfo mbInfo = mbsc.getMBeanInfo(threadObjName);
+
+			String attrName = "currentThreadCount";// tomcat的线程数对应的属性值
+			MBeanAttributeInfo[] mbAttributes = mbInfo.getAttributes();
+			System.out.println("currentThreadCount:"+ mbsc.getAttribute(threadObjName, attrName));
+
+			// heap
+			for (int j = 0; j < mbsc.getDomains().length; j++) {
+				System.out.println("###########" + mbsc.getDomains()[j]);
+			}
+			Set MBeanset = mbsc.queryMBeans(null, null);
+			System.out.println("MBeanset.size() : " + MBeanset.size());
+			Iterator MBeansetIterator = MBeanset.iterator();
+			while (MBeansetIterator.hasNext()) {
+				ObjectInstance objectInstance = (ObjectInstance) MBeansetIterator.next();
+				ObjectName objectName = objectInstance.getObjectName();
+				String canonicalName = objectName.getCanonicalName();
+				System.out.println("canonicalName : " + canonicalName);
+				if (canonicalName
+						.equals("Catalina:host=localhost,type=Cluster")) {
+					// Get details of cluster MBeans
+					System.out.println("Cluster MBeans Details:");
+					System.out
+							.println("=========================================");
+					// getMBeansDetails(canonicalName);
+					String canonicalKeyPropList = objectName.getCanonicalKeyPropertyListString();
+				}
+			}
+			// ------------------------- system ----------------------
+			ObjectName runtimeObjName = new ObjectName("java.lang:type=Runtime");
+			System.out.println("厂商:"
+					+ (String) mbsc.getAttribute(runtimeObjName, "VmVendor"));
+			System.out.println("程序:"
+					+ (String) mbsc.getAttribute(runtimeObjName, "VmName"));
+			System.out.println("版本:"
+					+ (String) mbsc.getAttribute(runtimeObjName, "VmVersion"));
+			Date starttime = new Date((Long) mbsc.getAttribute(runtimeObjName,
+					"StartTime"));
+			SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+			System.out.println("启动时间:" + df.format(starttime));
+
+			Long timespan = (Long) mbsc.getAttribute(runtimeObjName, "Uptime");
+			System.out.println("连续工作时间:" + TomcatJMX.formatTimeSpan(timespan));
+			// ------------------------ JVM -------------------------
+			// 堆使用率
+			ObjectName heapObjName = new ObjectName("java.lang:type=Memory");
+			MemoryUsage heapMemoryUsage = MemoryUsage
+					.from((CompositeDataSupport) mbsc.getAttribute(heapObjName,
+							"HeapMemoryUsage"));
+			long maxMemory = heapMemoryUsage.getMax();// 堆最大
+			long commitMemory = heapMemoryUsage.getCommitted();// 堆当前分配
+			long usedMemory = heapMemoryUsage.getUsed();
+			System.out.println("heap:" + (double) usedMemory * 100
+					/ commitMemory + "%");// 堆使用率
+
+			MemoryUsage nonheapMemoryUsage = MemoryUsage
+					.from((CompositeDataSupport) mbsc.getAttribute(heapObjName,
+							"NonHeapMemoryUsage"));
+			long noncommitMemory = nonheapMemoryUsage.getCommitted();
+			long nonusedMemory = heapMemoryUsage.getUsed();
+			System.out.println("nonheap:" + (double) nonusedMemory * 100
+					/ noncommitMemory + "%");
+
+			ObjectName permObjName = new ObjectName(
+					"java.lang:type=MemoryPool,name=Perm Gen");
+			MemoryUsage permGenUsage = MemoryUsage
+					.from((CompositeDataSupport) mbsc.getAttribute(permObjName,
+							"Usage"));
+			long committed = permGenUsage.getCommitted();// 持久堆大小
+			long used = heapMemoryUsage.getUsed();//
+			System.out.println("perm gen:" + (double) used * 100 / committed
+					+ "%");// 持久堆使用率
+
+			// -------------------- Session ---------------
+			ObjectName managerObjName = new ObjectName(
+					"Catalina:type=Manager,*");
+			Set<ObjectName> s = mbsc.queryNames(managerObjName, null);
+			for (ObjectName obj : s) {
+				System.out.println("应用名:" + obj.getKeyProperty("path"));
+				ObjectName objname = new ObjectName(obj.getCanonicalName());
+				System.out.println("最大会话数:"
+						+ mbsc.getAttribute(objname, "maxActiveSessions"));
+				System.out.println("会话数:"
+						+ mbsc.getAttribute(objname, "activeSessions"));
+				System.out.println("活动会话数:"
+						+ mbsc.getAttribute(objname, "sessionCounter"));
+			}
+
+			// ----------------- Thread Pool ----------------
+			ObjectName threadpoolObjName = new ObjectName(
+					"Catalina:type=ThreadPool,*");
+			Set<ObjectName> s2 = mbsc.queryNames(threadpoolObjName, null);
+			for (ObjectName obj : s2) {
+				System.out.println("端口名:" + obj.getKeyProperty("name"));
+				ObjectName objname = new ObjectName(obj.getCanonicalName());
+				System.out.println("最大线程数:"
+						+ mbsc.getAttribute(objname, "maxThreads"));
+				System.out.println("当前线程数:"
+						+ mbsc.getAttribute(objname, "currentThreadCount"));
+				System.out.println("繁忙线程数:"
+						+ mbsc.getAttribute(objname, "currentThreadsBusy"));
+			}
+
+		} catch (Exception e) {
+			e.printStackTrace();
+		}
+	}
+
+	@SuppressWarnings({"resource" })
+	public static String formatTimeSpan(long span) {
+		long minseconds = span % 1000;
+
+		span = span / 1000;
+		long seconds = span % 60;
+
+		span = span / 60;
+		long mins = span % 60;
+
+		span = span / 60;
+		long hours = span % 24;
+
+		span = span / 24;
+		long days = span;
+		return (new Formatter()).format("%1$d天 %2$02d:%3$02d:%4$02d.%5$03d",days, hours, mins, seconds, minseconds).toString();
+	}
+}

spring3-jmx-example/src/main/java/uk/co/jemos/experiments/jmx/MemTest.java

@@ -0,0 +1,11 @@
+package uk.co.jemos.experiments.jmx;
+
+import org.springframework.context.support.ClassPathXmlApplicationContext;
+
+public class MemTest {
+	public static void main(String[] args) {
+
+		new ClassPathXmlApplicationContext("classpath:jemos-jmx-appCtx.xml");
+
+	}
+}

spring3-jmx-example/src/main/java/uk/co/jemos/experiments/jmx/MemoryHeapFiller.java

@@ -0,0 +1,22 @@
+package uk.co.jemos.experiments.jmx;
+
+import java.util.ArrayList;
+import java.util.Collection;
+
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+@Component
+public class MemoryHeapFiller {
+
+	private static final Collection<Double> GARBAGE = new ArrayList<Double>();
+
+	@Scheduled(fixedDelay = 2000)
+	public void addGarbage() {
+		System.out.println("Adding data...");
+		for (int i = 0; i < 1000000; i++) {
+			GARBAGE.add(Math.random());
+		}
+	}
+
+}

spring3-jmx-example/src/main/java/uk/co/jemos/experiments/jmx/MemoryThreadDumper.java

@@ -0,0 +1,119 @@
+package uk.co.jemos.experiments.jmx;
+
+import java.io.BufferedWriter;
+import java.io.File;
+import java.io.FileWriter;
+import java.io.IOException;
+import java.io.Writer;
+import java.lang.management.ManagementFactory;
+import java.lang.management.ThreadInfo;
+import java.lang.management.ThreadMXBean;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.Map;
+
+import org.apache.commons.io.IOUtils;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author mtedone
+ * 
+ */
+@Component
+public class MemoryThreadDumper {
+
+	// ------------------->> Constants
+
+	/** The application logger */
+	private static final org.apache.log4j.Logger LOG = org.apache.log4j.Logger
+			.getLogger(MemoryThreadDumper.class);
+
+	// ------------------->> Instance / Static variables
+
+	// ------------------->> Constructors
+
+	// ------------------->> Public methods
+
+	/**
+	 * It dumps the Thread stacks
+	 * 
+	 * @throws IOException
+	 */
+	public void dumpStacks() {
+
+		// choose our dump-file
+		String stackFileName = "C:/tmp/stacks.dump";
+
+		ThreadMXBean mxBean = ManagementFactory.getThreadMXBean();
+		ThreadInfo[] threadInfos = mxBean.getThreadInfo(
+				mxBean.getAllThreadIds(), 0);
+		Map<Long, ThreadInfo> threadInfoMap = new HashMap<Long, ThreadInfo>();
+		for (ThreadInfo threadInfo : threadInfos) {
+			threadInfoMap.put(threadInfo.getThreadId(), threadInfo);
+		}
+
+		File dumpFile = new File(stackFileName);
+		BufferedWriter writer = null;
+		try {
+			writer = new BufferedWriter(new FileWriter(dumpFile));
+			this.dumpTraces(mxBean, threadInfoMap, writer);
+
+			LOG.warn("Stacks dumped to: " + stackFileName);
+
+		} catch (IOException e) {
+			throw new IllegalStateException(
+					"An exception occurred while writing the thread dump");
+		} finally {
+			IOUtils.closeQuietly(writer);
+		}
+
+	}
+
+	// ------------------->> Getters / Setters
+
+	// ------------------->> Private methods
+
+	private void dumpTraces(ThreadMXBean mxBean,
+			Map<Long, ThreadInfo> threadInfoMap, Writer writer)
+			throws IOException {
+		Map<Thread, StackTraceElement[]> stacks = Thread.getAllStackTraces();
+		writer.write("Dump of "
+				+ stacks.size()
+				+ " thread at "
+				+ new SimpleDateFormat("yyyy/MM/dd HH:mm:ss z")
+						.format(new Date(System.currentTimeMillis())) + "\n\n");
+		for (Map.Entry<Thread, StackTraceElement[]> entry : stacks.entrySet()) {
+			Thread thread = entry.getKey();
+			writer.write("\"" + thread.getName() + "\" prio="
+					+ thread.getPriority() + " tid=" + thread.getId() + " "
+					+ thread.getState() + " "
+					+ (thread.isDaemon() ? "deamon" : "worker") + "\n");
+			ThreadInfo threadInfo = threadInfoMap.get(thread.getId());
+			if (threadInfo != null) {
+				writer.write("    native=" + threadInfo.isInNative()
+						+ ", suspended=" + threadInfo.isSuspended()
+						+ ", block=" + threadInfo.getBlockedCount() + ", wait="
+						+ threadInfo.getWaitedCount() + "\n");
+				writer.write("    lock=" + threadInfo.getLockName()
+						+ " owned by " + threadInfo.getLockOwnerName() + " ("
+						+ threadInfo.getLockOwnerId() + "), cpu="
+						+ mxBean.getThreadCpuTime(threadInfo.getThreadId())
+						/ 1000000L + ", user="
+						+ mxBean.getThreadUserTime(threadInfo.getThreadId())
+						/ 1000000L + "\n");
+			}
+			for (StackTraceElement element : entry.getValue()) {
+				writer.write("        ");
+				writer.write(element.toString());
+				writer.write("\n");
+			}
+			writer.write("\n");
+		}
+	}
+
+	// ------------------->> equals() / hashcode() / toString()
+
+	// ------------------->> Inner classes
+
+}

spring3-jmx-example/src/main/java/uk/co/jemos/experiments/jmx/MemoryWarningService.java

@@ -0,0 +1,116 @@
+package uk.co.jemos.experiments.jmx;
+
+import java.lang.management.ManagementFactory;
+import java.lang.management.MemoryNotificationInfo;
+import java.lang.management.MemoryPoolMXBean;
+import java.lang.management.MemoryType;
+
+import javax.annotation.PostConstruct;
+import javax.management.Notification;
+import javax.management.NotificationEmitter;
+import javax.management.NotificationListener;
+
+import org.springframework.beans.factory.annotation.Autowired;
+
+/**
+ * A component which sends notifications when the HEAP memory is above a certain
+ * threshold.
+ * 
+ * @author mtedone
+ * 
+ */
+public class MemoryWarningService implements NotificationListener {
+
+	// ------------------->> Constants
+
+	/** This bean's name */
+	public static final String MBEAN_NAME = "jemos.mbeans:type=monitoring,name=MemoryWarningService";
+
+	/** The application logger */
+	private static final org.apache.log4j.Logger LOG = org.apache.log4j.Logger
+			.getLogger(MemoryWarningService.class);
+
+	@Autowired
+	private NotificationEmitter memoryMxBean;
+
+	@Autowired
+	private MemoryThreadDumper threadDumper;
+
+	// ------------------->> Instance / Static variables
+
+	/** A pool of Memory MX Beans specialised in HEAP management */
+	private static final MemoryPoolMXBean tenuredGenPool = findTenuredGenPool();
+
+	// ------------------->> Constructors
+
+	// ------------------->> Public methods
+
+	/**
+	 * {@inheritDoc}
+	 */
+	@Override
+	public void handleNotification(Notification notification, Object handback) {
+
+		if (notification.getType().equals(
+				MemoryNotificationInfo.MEMORY_THRESHOLD_EXCEEDED)) {
+			long maxMemory = tenuredGenPool.getUsage().getMax();
+			long usedMemory = tenuredGenPool.getUsage().getUsed();
+			LOG.warn("Memory usage low!!!");
+			double percentageUsed = (double) usedMemory / maxMemory;
+			LOG.warn("percentageUsed = " + percentageUsed);
+			threadDumper.dumpStacks();
+
+		} else {
+			LOG.info("Other notification received..."
+					+ notification.getMessage());
+		}
+
+	}
+
+	// ------------------->> Getters / Setters
+
+	/**
+	 * It sets the threshold percentage.
+	 * 
+	 * @param percentage
+	 */
+	public void setPercentageUsageThreshold(double percentage) {
+		if (percentage <= 0.0 || percentage > 1.0) {
+			throw new IllegalArgumentException("Percentage not in range");
+		} else {
+			LOG.info("Percentage is: " + percentage);
+		}
+		long maxMemory = tenuredGenPool.getUsage().getMax();
+		long warningThreshold = (long) (maxMemory * percentage);
+		tenuredGenPool.setUsageThreshold(warningThreshold);
+	}
+
+	@PostConstruct
+	public void completeSetup() {
+		memoryMxBean.addNotificationListener(this, null, null);
+		LOG.info("Listener added to JMX bean");
+	}
+
+	// ------------------->> Private methods
+
+	/**
+	 * Tenured Space Pool can be determined by it being of type HEAP and by it
+	 * being possible to set the usage threshold.
+	 */
+	private static MemoryPoolMXBean findTenuredGenPool() {
+		for (MemoryPoolMXBean pool : ManagementFactory.getMemoryPoolMXBeans()) {
+			// I don't know whether this approach is better, or whether
+			// we should rather check for the pool name "Tenured Gen"?
+			if (pool.getType() == MemoryType.HEAP
+					&& pool.isUsageThresholdSupported()) {
+				return pool;
+			}
+		}
+		throw new AssertionError("Could not find tenured space");
+	}
+
+	// ------------------->> equals() / hashcode() / toString()
+
+	// ------------------->> Inner classes
+
+}

spring3-jmx-example/src/main/java/uk/co/jemos/experiments/jmx/mbeans/LoggerConfigurator.java

@@ -0,0 +1,71 @@
+package uk.co.jemos.experiments.jmx.mbeans;
+
+import org.apache.log4j.Level;
+import org.apache.log4j.Logger;
+import org.springframework.jmx.export.annotation.ManagedOperation;
+import org.springframework.jmx.export.annotation.ManagedOperationParameter;
+import org.springframework.jmx.export.annotation.ManagedOperationParameters;
+import org.springframework.jmx.export.annotation.ManagedResource;
+import org.springframework.stereotype.Component;
+
+/**
+ * MBean which allows clients to change or retrieve the logging level for a
+ * Log4j Logger at runtime.
+ * 
+ * @author mtedone
+ * 
+ */
+@Component
+@ManagedResource(objectName = LoggerConfigurator.MBEAN_NAME, //
+description = "Allows clients to set the Log4j Logger level at runtime")
+public class LoggerConfigurator {
+
+	// ------------------->> Constants
+
+	public static final String MBEAN_NAME = "jemos.mbeans:type=config,name=LoggingConfiguration";
+
+	// ------------------->> Instance / Static variables
+
+	// ------------------->> Constructors
+
+	// ------------------->> Public methods
+
+	@ManagedOperation(description = "Returns the Logger LEVEL for the given logger name")
+	@ManagedOperationParameters({ @ManagedOperationParameter(description = "The Logger Name", name = "loggerName"), })
+	public String getLoggerLevel(String loggerName) {
+
+		Logger logger = Logger.getLogger(loggerName);
+		Level loggerLevel = logger.getLevel();
+
+		return loggerLevel == null ? "The logger " + loggerName
+				+ " has not level" : loggerLevel.toString();
+
+	}
+
+	@ManagedOperation(description = "Set Logger Level")
+	@ManagedOperationParameters({
+			@ManagedOperationParameter(description = "The Logger Name", name = "loggerName"),
+			@ManagedOperationParameter(description = "The Level to which the Logger must be set", name = "loggerLevel") })
+	public void setLoggerLevel(String loggerName, String loggerLevel) {
+
+		Logger thisLogger = Logger.getLogger(this.getClass());
+		thisLogger.setLevel(Level.INFO);
+
+		Logger logger = Logger.getLogger(loggerName);
+
+		logger.setLevel(Level.toLevel(loggerLevel, Level.INFO));
+
+		thisLogger.info("Set logger " + loggerName + " to level "
+				+ logger.getLevel());
+
+	}
+
+	// ------------------->> Getters / Setters
+
+	// ------------------->> Private methods
+
+	// ------------------->> equals() / hashcode() / toString()
+
+	// ------------------->> Inner classes
+
+}

spring3-jmx-example/src/main/java/uk/co/jemos/experiments/jmx/mbeans/MemoryWarningServiceConfigurator.java

@@ -0,0 +1,62 @@
+package uk.co.jemos.experiments.jmx.mbeans;
+
+import org.springframework.beans.BeansException;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
+import org.springframework.jmx.export.annotation.ManagedOperation;
+import org.springframework.jmx.export.annotation.ManagedOperationParameter;
+import org.springframework.jmx.export.annotation.ManagedOperationParameters;
+import org.springframework.jmx.export.annotation.ManagedResource;
+import org.springframework.stereotype.Component;
+
+import uk.co.jemos.experiments.jmx.MemoryWarningService;
+
+@Component
+@ManagedResource(objectName = MemoryWarningServiceConfigurator.MBEAN_NAME, //
+description = "Allows clients to set the memory threshold")
+public class MemoryWarningServiceConfigurator implements
+		ApplicationContextAware {
+
+	// ------------------->> Constants
+
+	/** The application logger */
+	private static final org.apache.log4j.Logger LOG = org.apache.log4j.Logger
+			.getLogger(MemoryWarningServiceConfigurator.class);
+
+	public static final String MBEAN_NAME = "jemos.mbeans:type=config,name=MemoryWarningServiceConfiguration";
+
+	private ApplicationContext ctx;
+
+	// ------------------->> Instance / Static variables
+
+	// ------------------->> Constructors
+
+	// ------------------->> Public methods
+
+	@ManagedOperation(description = "Sets the memory threshold for the memory warning system")
+	@ManagedOperationParameters({ @ManagedOperationParameter(description = "The memory threshold", name = "memoryThreshold"), })
+	public void setMemoryThreshold(double memoryThreshold) {
+
+		MemoryWarningService memoryWarningService = (MemoryWarningService) ctx
+				.getBean("memoryWarningService");
+		memoryWarningService.setPercentageUsageThreshold(memoryThreshold);
+
+		LOG.info("Memory threshold set to " + memoryThreshold);
+	}
+
+	@Override
+	public void setApplicationContext(ApplicationContext applicationContext)
+			throws BeansException {
+		ctx = applicationContext;
+
+	}
+
+	// ------------------->> Getters / Setters
+
+	// ------------------->> Private methods
+
+	// ------------------->> equals() / hashcode() / toString()
+
+	// ------------------->> Inner classes
+
+}

spring3-jmx-example/src/main/resources/jemos-jmx-appCtx.xml

@@ -0,0 +1,78 @@
+<?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:util="http://www.springframework.org/schema/util"
+	xmlns:task="http://www.springframework.org/schema/task"
+	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
+		http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd
+		http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.0.xsd
+		http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.0.xsd">
+
+
+	<bean id="propertyConfigurer"
+		class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
+		<property name="locations">
+			<list>
+				<value>classpath:jemos-jmx.properties</value>
+				<value>classpath:jmxconnector-credentials.properties
+				</value>
+			</list>
+		</property>
+	</bean>
+
+	<context:component-scan base-package="uk.co.jemos.experiments.jmx" />
+
+	<context:mbean-export default-domain="jemos.mbeans" />
+
+	<bean id="jemosJmxServer"
+		class="org.springframework.jmx.support.ConnectorServerFactoryBean"
+		depends-on="rmiRegistry">
+		<property name="objectName" value="connector:name=rmi" />
+		<property name="serviceUrl"
+			value="service:jmx:rmi://localhost/jndi/rmi://localhost:${jemos.jmx.rmi.port}/jemosJmxConnector" />
+		<property name="environment">
+			<!-- the following is only valid when the sun jmx implementation is used -->
+			<map>
+				<entry key="jmx.remote.x.password.file" value="C:/jmxremote.password" />
+				<entry key="jmx.remote.x.access.file" value="C:/jmxremote.access" />
+			</map>
+		</property>
+	</bean>
+
+	<bean id="rmiRegistry" class="org.springframework.remoting.rmi.RmiRegistryFactoryBean">
+		<property name="port" value="${jemos.jmx.rmi.port}" />
+	</bean>
+
+	<bean id="clientConnector"
+		class="org.springframework.jmx.support.MBeanServerConnectionFactoryBean"
+		depends-on="jemosJmxServer">
+		<property name="serviceUrl"
+			value="service:jmx:rmi://localhost/jndi/rmi://localhost:${jemos.jmx.rmi.port}/jemosJmxConnector" />
+		<property name="environment">
+			<map>
+				<entry key="jmx.remote.credentials">
+					<bean class=" org.springframework.util.StringUtils"
+						factory-method="commaDelimitedListToStringArray">
+						<constructor-arg value="${jmx.username},${jmx.password}" />
+					</bean>
+				</entry>
+			</map>
+		</property>
+	</bean>
+
+
+	<bean id="memoryMxBean" class="java.lang.management.ManagementFactory"
+		factory-method="getMemoryMXBean" />
+		
+    <bean id="memoryWarningService" class="uk.co.jemos.experiments.jmx.MemoryWarningService">
+      <property name="percentageUsageThreshold" value="0.5" />
+    </bean>
+		
+
+	<task:annotation-driven scheduler="myScheduler" />   
+
+    <task:scheduler id="myScheduler" pool-size="10" />    
+		
+
+
+</beans>

spring3-jmx-example/src/main/resources/jemos-jmx-appCtxImpl.xml

@@ -0,0 +1,12 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<beans xmlns="http://www.springframework.org/schema/beans"
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
+
+
+	<import resource="classpath:jemos-jmx-appCtx.xml" />
+	
+	
+
+
+</beans>

spring3-jmx-example/src/main/resources/jemos-jmx.properties

@@ -0,0 +1 @@
+jemos.jmx.rmi.port=8888

spring3-jmx-example/src/main/resources/jmxconnector-credentials.properties

@@ -0,0 +1,2 @@
+jmx.username=jemosAdmin
+jmx.password=secure

spring3-jmx-example/src/main/resources/jmxremote.access

@@ -0,0 +1 @@
+jemosAdmin readwrite

spring3-jmx-example/src/main/resources/jmxremote.password

@@ -0,0 +1 @@
+jemosAdmin secure

spring3-jmx-example/src/main/resources/log4j.properties

@@ -0,0 +1,7 @@
+log4j.rootCategory=INFO, S
+
+log4j.logger.uk.co.jemos.experiments=INFO
+
+log4j.appender.S = org.apache.log4j.ConsoleAppender
+log4j.appender.S.layout = org.apache.log4j.PatternLayout
+log4j.appender.S.layout.ConversionPattern = %d{yyyy-MM-dd HH:mm:ss} %c{1} [%p] %m%n

spring3-jmx-example/src/test/java/uk/co/jemos/experiments/jmx/test/system/JmxStartupSystemTest.java

@@ -0,0 +1,59 @@
+package uk.co.jemos.experiments.jmx.test.system;
+
+import javax.management.MBeanServerConnection;
+import javax.management.ObjectName;
+
+import junit.framework.Assert;
+
+import org.junit.Before;
+import org.junit.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.junit4.AbstractJUnit4SpringContextTests;
+
+import uk.co.jemos.experiments.jmx.mbeans.LoggerConfigurator;
+
+/**
+ * System test to test the JMX server startup
+ * 
+ * @author mtedone
+ * 
+ */
+@ContextConfiguration(locations = { "classpath:jemos-jmx-test-appCtxImpl.xml" })
+public class JmxStartupSystemTest extends AbstractJUnit4SpringContextTests {
+
+	// ------------------->> Constants
+
+	// ------------------->> Instance / Static variables
+
+	@Autowired
+	private MBeanServerConnection mbeanClient;
+
+	// ------------------->> Constructors
+
+	// ------------------->> Public methods
+
+	@Before
+	public void init() {
+		Assert.assertNotNull("The MBean Server client cannot be null!");
+		Assert.assertNotNull("The Memory MX Bean cannot be null!");
+	}
+
+	@Test
+	public void helloWorld() throws Exception {
+
+		ObjectName objectName = new ObjectName(LoggerConfigurator.MBEAN_NAME);
+		mbeanClient.invoke(objectName, "setLoggerLevel", new Object[] {
+				"uk.co.jemos.experiments", "TRACE" }, new String[] {
+				String.class.getName(), String.class.getName() });
+
+	}
+	// ------------------->> Getters / Setters
+
+	// ------------------->> Private methods
+
+	// ------------------->> equals() / hashcode() / toString()
+
+	// ------------------->> Inner classes
+
+}

spring3-jmx-example/src/test/resources/jemos-jmx-test-appCtxImpl.xml

@@ -0,0 +1,9 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<beans xmlns="http://www.springframework.org/schema/beans"
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
+
+
+	<import resource="classpath:jemos-jmx-appCtx.xml"/>
+
+</beans>

spring3-jmx-example/使用JMX监控Tomcat.md

@@ -0,0 +1,84 @@
+# 使用JMX监控Tomcat
+
+## 1. 激活Tomcat的JMX远程配置
+
+要通过JMX远程监控Tomcat，首先需要激活Tomcat的JMX远程配置。
+
+① 先修改Tomcat的启动脚本，windows下为bin/catalina.bat（linux下为catalina.sh），添加以下内容，8999是jmxremote使用的端口号，第二个false表示不需要鉴权：
+
+```bash
+set JMX_REMOTE_CONFIG=-Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.port=8999 -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.authenticate=false
+set CATALINA_OPTS=%CATALINA_OPTS% %JMX_REMOTE_CONFIG%
+```
+
+*要注意以上语句的位置不能太后面，可以加在【if "%OS%" == "Windows_NT" setlocal】一句后的大段的注释后面。*
+
+参考官方说明： 
+
+[http://tomcat.apache.org/tomcat-6.0-doc/monitoring.html#Enabling_JMX_Remote](http://tomcat.apache.org/tomcat-6.0-doc/monitoring.html#Enabling_JMX_Remote)
+
+② 上面的配置是不需要鉴权的，如果需要鉴权则添加的内容为：
+
+```bash
+set JMX_REMOTE_CONFIG=-Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.port=8999 -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.authenticate=true -Dcom.sun.management.jmxremote.password.file=../conf/jmxremote.password -Dcom.sun.management.jmxremote.access.file=../conf/jmxremote.access
+set CATALINA_OPTS=%CATALINA_OPTS% %JMX_REMOTE_CONFIG%
+```
+
+③ 然后复制并修改授权文件 
+
+$JAVA_HOME/jre/lib/management下有jmxremote.access和jmxremote.password的模板文件，将两个文件复制到$CATALINA_BASE/conf目录下
+
+◆ 修改$CATALINA_BASE/conf/jmxremote.access 添加内容：
+     monitorRole readonly
+     controlRole readwrite
+     
+◆ 修改$CATALINA_BASE/conf/jmxremote.password 添加内容：
+     monitorRole admin
+     controlRole admin
+
+注意： 如果进行了以上步骤导致Tomcat启动不了，那么很可能是密码文件的权限问题 
+
+需要修改jmxremote.password文件的访问权限，只有运行Tomcat的用户才能拥有访问权限 ： 
+      Windows的NTFS文件系统下，选中文件，点右键 -->“属性”-->“安全”--> 点“高级”--> 点“更改权限”--> 去掉“从父项继承....”--> 弹出窗口中选“删除”，这样就删除了所有访问权限。再选“添加”--> “高级”--> “立即查找”，选中你的用户（或用户组，如果选用户不行那就选用户组），例administrator，点“确定"，“确定"。来到权限项目窗口，勾选“完全控制”，点“确定”，OK了。
+
+官方的提示： 
+      The password file should be read-only and only accessible by the operating system user Tomcat is running as.
+
+④ 重新启动Tomcat，在Windows命令行输入“netstat -a”查看配置的端口号是否已打开，如果打开，说明上面的配置成功了。
+ 
+⑤ 使用jconsole测试JMX。
+
+运行$JAVA_HOME/bin目录下的jconsole.exe，打开J2SE监视和管理控制台，然后建立连接，如果是本地的Tomcat则直接选择然后点击连接，如果是远程的，则进入远程选项卡，填写地址、端口号、用户名、口令即可连接。。Mbean属性页中给出了相应的数据，Catalina中是tomcat的，java.lang是jvm的。对于加粗的黑体属性值，需双击一下才可看内容。     
+
+![](src/main/resources/jmx-tomcat-1.jpg)
+
+![](src/main/resources/jmx-tomcat-2.jpg)
+
+使用远程连接查看tomcat
+
+![](src/main/resources/jmx-tomcat-3.jpg)
+
+![](src/main/resources/jmx-tomcat-4.jpg)
+
+## 2. 使用JMX监控Tomcat示例代码
+
+```java
+String jmxURL = "service:jmx:rmi:///jndi/rmi://192.168.10.93:8999/jmxrmi";
+JMXServiceURL serviceURL = new JMXServiceURL(jmxURL);
+
+Map map = new HashMap();
+// 用户名密码，在jmxremote.password文件中查看
+String[] credentials = new String[] { "monitorRole", "admin" };
+map.put("jmx.remote.credentials", credentials);
+JMXConnector connector = JMXConnectorFactory.connect(serviceURL, map);
+MBeanServerConnection mbsc = connector.getMBeanServerConnection();
+
+// 端口最好是动态取得
+ObjectName threadObjName = new ObjectName("Catalina:type=ThreadPool,name=http-8080");
+MBeanInfo mbInfo = mbsc.getMBeanInfo(threadObjName);
+
+// tomcat的线程数对应的属性值
+String attrName = "currentThreadCount";
+MBeanAttributeInfo[] mbAttributes = mbInfo.getAttributes();
+System.out.println("currentThreadCount:" + mbsc.getAttribute(threadObjName, attrName));
+```

spring3-mvc-simple/.gitignore

@@ -0,0 +1,6 @@
+/target
+/.classpath
+/.project
+/.gradle
+/.settings
+/build

spring3-mvc-simple/build.gradle

@@ -0,0 +1,16 @@
+apply plugin: 'war'
+apply plugin: 'jetty'
+apply plugin: 'eclipse-wtp'
+ 
+repositories {
+   mavenCentral()
+}
+ 
+dependencies {
+   providedCompile 'javax.servlet:servlet-api:2.5'
+   compile 'org.springframework:spring-webmvc:3.2.2.RELEASE'
+   runtime 'javax.servlet:jstl:1.1.2'
+}
+ 
+/* Change context path (base url). otherwise defaults to name of project */
+jettyRunWar.contextPath = ''

spring3-mvc-simple/pom.xml

@@ -0,0 +1,65 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+	<parent>
+		<artifactId>maven-framework-project</artifactId>
+		<groupId>net.aimeizi</groupId>
+		<version>1.0.0</version>
+	</parent>
+
+	<groupId>net.aimeizi.springmvc.example</groupId>
+	<artifactId>spring3-mvc-simple</artifactId>
+	<packaging>war</packaging>
+
+	<name>spring3-mvc-simple</name>
+	<url>http://maven.apache.org</url>
+
+	<dependencies>
+		<dependency>
+			<artifactId>servlet-api</artifactId>
+			<groupId>javax.servlet</groupId>
+			<version>2.5</version>
+			<scope>provided</scope>
+		</dependency>
+
+		<dependency>
+			<artifactId>spring-webmvc</artifactId>
+			<groupId>org.springframework</groupId>
+			<version>3.2.2.RELEASE</version>
+		</dependency>
+
+		<dependency>
+			<artifactId>jstl</artifactId>
+			<groupId>javax.servlet</groupId>
+			<version>1.1.2</version>
+		</dependency>
+	</dependencies>
+
+	<build>
+		<finalName>spring3-mvc-simple</finalName>
+		<plugins>
+			<plugin>
+				<groupId>org.eclipse.jetty</groupId>
+				<artifactId>jetty-maven-plugin</artifactId>
+				<version>9.2.1.v20140609</version>
+			</plugin>
+
+			<plugin>
+				<groupId>org.apache.tomcat.maven</groupId>
+				<artifactId>tomcat7-maven-plugin</artifactId>
+				<version>2.2</version>
+			</plugin>
+
+			<plugin>
+				<groupId>org.apache.tomcat.maven</groupId>
+				<artifactId>tomcat6-maven-plugin</artifactId>
+				<version>2.2</version>
+			</plugin>
+
+		</plugins>
+
+
+	</build>
+
+</project>

spring3-mvc-simple/src/main/java/org/spring3/mvc/simple/controller/SampleController.java

@@ -0,0 +1,15 @@
+package org.spring3.mvc.simple.controller;
+
+import org.springframework.stereotype.Controller;
+import org.springframework.ui.Model;
+import org.springframework.web.bind.annotation.RequestMapping;
+
+@Controller
+public class SampleController {
+ 
+    @RequestMapping("home")
+    public String loadHomePage(Model m) {
+        m.addAttribute("name", "SpringMVC");
+        return "home";
+    }
+}

spring3-mvc-simple/src/main/java/org/spring3/mvc/simple/springconfig/WebConfig.java

@@ -0,0 +1,22 @@
+package org.spring3.mvc.simple.springconfig;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.web.servlet.config.annotation.EnableWebMvc;
+import org.springframework.web.servlet.view.InternalResourceViewResolver;
+
+@Configuration
+@EnableWebMvc
+@ComponentScan(basePackages = "org.spring3.mvc.simple.controller")
+public class WebConfig {
+
+	@Bean
+	public InternalResourceViewResolver viewResolver() {
+		InternalResourceViewResolver resolver = new InternalResourceViewResolver();
+		resolver.setPrefix("/WEB-INF/view/");
+		resolver.setSuffix(".jsp");
+		return resolver;
+	}
+
+}

spring3-mvc-simple/src/main/resources/sample-servlet.xml

@@ -0,0 +1,22 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<beans xmlns="http://www.springframework.org/schema/beans"
+	xmlns:mvc="http://www.springframework.org/schema/mvc" 
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xmlns:context="http://www.springframework.org/schema/context"
+	xsi:schemaLocation="http://www.springframework.org/schema/beans    
+		http://www.springframework.org/schema/beans/spring-beans-3.2.xsd
+  		http://www.springframework.org/schema/mvc    
+  		http://www.springframework.org/schema/mvc/spring-mvc-3.2.xsd
+  		http://www.springframework.org/schema/context    
+  		http://www.springframework.org/schema/context/spring-context-3.2.xsd">
+
+	<context:component-scan base-package="org.spring3.mvc.simple.controller" />
+	<mvc:annotation-driven />
+
+	<bean id="viewResolver"
+		class="org.springframework.web.servlet.view.InternalResourceViewResolver">
+		<property name="prefix" value="/WEB-INF/view/" />
+		<property name="suffix" value=".jsp" />
+	</bean>
+
+</beans>

spring3-mvc-simple/src/main/webapp/WEB-INF/view/home.jsp

@@ -0,0 +1,9 @@
+<!DOCTYPE HTML>
+<html>
+  <head>
+    <title>Sample Application</title>
+  </head>
+  <body>
+	<h1>Hello, ${name}!</h1>
+  </body>
+</html>

spring3-mvc-simple/src/main/webapp/WEB-INF/web.xml

@@ -0,0 +1,26 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<web-app version="2.5" 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://java.sun.com/xml/ns/javaee/web-app_2_5.xsd">
+ 
+  <servlet>
+    <servlet-name>sample</servlet-name>
+    <servlet-class>
+        org.springframework.web.servlet.DispatcherServlet
+    </servlet-class>
+    <init-param>
+      <param-name>contextClass</param-name>
+      <param-value>org.springframework.web.context.support.AnnotationConfigWebApplicationContext</param-value>
+    </init-param>
+    <init-param>
+      <param-name>contextConfigLocation</param-name>
+      <param-value>org.spring3.mvc.simple.springconfig</param-value>
+    </init-param>
+  </servlet>
+ 
+  <servlet-mapping>
+    <servlet-name>sample</servlet-name>
+    <url-pattern>/</url-pattern>
+  </servlet-mapping>
+ 
+</web-app>

spring3-mvc-simple/src/main/webapp/WEB-INF/webxml.xml

@@ -0,0 +1,22 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<web-app version="2.5" 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://java.sun.com/xml/ns/javaee/web-app_2_5.xsd">
+ 
+  <servlet>
+    <servlet-name>sample</servlet-name>
+    <servlet-class>
+        org.springframework.web.servlet.DispatcherServlet
+    </servlet-class>
+    <init-param>
+      <param-name>contextConfigLocation</param-name>
+      <param-value>/WEB-INF/sample-servlet.xml</param-value>
+    </init-param>
+  </servlet>
+ 
+  <servlet-mapping>
+    <servlet-name>sample</servlet-name>
+    <url-pattern>/</url-pattern>
+  </servlet-mapping>
+ 
+</web-app>

spring3-rmi-example/.gitignore

@@ -0,0 +1,4 @@
+/.project
+/.settings
+/target
+/.classpath

spring3-rmi-example/pom.xml

@@ -0,0 +1,35 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+	<parent>
+		<groupId>net.aimeizi</groupId>
+		<artifactId>maven-framework-project</artifactId>
+		<version>1.0.0</version>
+	</parent>
+	<artifactId>spring3-rmi-example</artifactId>
+
+	<!-- Spring 3.1.x dependencies -->
+	<properties>
+		<spring.version>3.1.1.RELEASE</spring.version>
+	</properties>
+
+	<dependencies>
+		<dependency>
+			<groupId>org.springframework</groupId>
+			<artifactId>spring-core</artifactId>
+			<version>${spring.version}</version>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework</groupId>
+			<artifactId>spring-context</artifactId>
+			<version>${spring.version}</version>
+		</dependency>
+		<!-- Log4j library -->
+		<dependency>
+			<groupId>log4j</groupId>
+			<artifactId>log4j</artifactId>
+			<version>1.2.16</version>
+		</dependency>
+	</dependencies>
+
+</project>

spring3-rmi-example/src/main/java/net/aimeizi/rmi/cache/service/CacheService.java

@@ -0,0 +1,29 @@
+package net.aimeizi.rmi.cache.service;
+
+import java.util.concurrent.ConcurrentHashMap;
+
+import net.aimeizi.rmi.model.User;
+
+public class CacheService implements ICacheService {
+
+    ConcurrentHashMap<Long, User> userMap;
+ 
+    /**
+     * Get User Map
+     *
+     * @return ConcurrentHashMap User Map
+     */
+    public ConcurrentHashMap<Long, User> getUserMap() {
+        return userMap;
+    }
+ 
+    /**
+     * Set User Map
+     *
+     * @param ConcurrentHashMap User Map
+     */
+    public void setUserMap(ConcurrentHashMap<Long, User> userMap) {
+        this.userMap = userMap;
+    }
+
+}

spring3-rmi-example/src/main/java/net/aimeizi/rmi/cache/service/ICacheService.java

@@ -0,0 +1,16 @@
+package net.aimeizi.rmi.cache.service;
+
+import java.util.concurrent.ConcurrentHashMap;
+
+import net.aimeizi.rmi.model.User;
+
+public interface ICacheService {
+ 
+    /**
+     * Get User Map
+     *
+     * @return ConcurrentHashMap User Map
+     */
+    public ConcurrentHashMap<Long, User> getUserMap();
+ 
+}

spring3-rmi-example/src/main/java/net/aimeizi/rmi/client/RMIServiceClient.java

@@ -0,0 +1,46 @@
+package net.aimeizi.rmi.client;
+
+import net.aimeizi.rmi.model.User;
+import net.aimeizi.rmi.server.IRMIUserService;
+import net.aimeizi.rmi.server.RMIUserService;
+
+import org.apache.log4j.Logger;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.support.ClassPathXmlApplicationContext;
+
+public class RMIServiceClient {
+	
+	private static Logger logger = Logger.getLogger(RMIUserService.class);
+	
+	/**
+	 * Main method of the RMI Service Client
+	 * 
+	 */
+	public static void main(String[] args) {
+		
+		logger.debug("RMI Service Client is starting...");
+		
+		//RMI Client Application Context is started... 
+		ApplicationContext context = new ClassPathXmlApplicationContext("rmiClientAppContext.xml");
+		
+		//Remote User Service is called via RMI Client Application Context...
+		IRMIUserService rmiClient = (IRMIUserService) context.getBean("RMIUserService");
+
+		//New User is created...
+		User user = new User();
+		user.setId(1);
+		user.setName("Bruce");
+		user.setSurname("Willis");
+		
+		//The user is added to the remote cache...
+		rmiClient.addUser(user);
+		
+		//The users are gotten via remote cache...
+		rmiClient.getUserList();
+		
+		//The user is deleted from remote cache...
+		rmiClient.deleteUser(user);
+		
+		logger.debug("RMI Service Client is stopped...");
+	}
+}

spring3-rmi-example/src/main/java/net/aimeizi/rmi/model/User.java

@@ -0,0 +1,77 @@
+package net.aimeizi.rmi.model;
+
+import java.io.Serializable;
+
+@SuppressWarnings("serial")
+public class User implements Serializable {
+
+	private long id;
+	private String name;
+	private String surname;
+
+	/**
+	 * Get User Id
+	 *
+	 * @return long id
+	 */
+	public long getId() {
+		return id;
+	}
+
+	/**
+	 * Set User Id
+	 *
+	 * @param long id
+	 */
+	public void setId(long id) {
+		this.id = id;
+	}
+
+	/**
+	 * Get User Name
+	 *
+	 * @return long id
+	 */
+	public String getName() {
+		return name;
+	}
+
+	/**
+	 * Set User Name
+	 *
+	 * @param String
+	 *            name
+	 */
+	public void setName(String name) {
+		this.name = name;
+	}
+
+	/**
+	 * Get User Surname
+	 *
+	 * @return long id
+	 */
+	public String getSurname() {
+		return surname;
+	}
+
+	/**
+	 * Set User Surname
+	 *
+	 * @param String
+	 *            surname
+	 */
+	public void setSurname(String surname) {
+		this.surname = surname;
+	}
+
+	@Override
+	public String toString() {
+		StringBuilder strBuilder = new StringBuilder();
+		strBuilder.append("Id : ").append(getId());
+		strBuilder.append(", Name : ").append(getName());
+		strBuilder.append(", Surname : ").append(getSurname());
+		return strBuilder.toString();
+	}
+
+}

spring3-rmi-example/src/main/java/net/aimeizi/rmi/server/IRMIUserService.java

@@ -0,0 +1,32 @@
+package net.aimeizi.rmi.server;
+
+import java.util.List;
+
+import net.aimeizi.rmi.model.User;
+
+public interface IRMIUserService {
+	
+	/**
+     * Add User
+     *
+     * @param  User user
+     * @return boolean response of the method
+     */
+    public boolean addUser(User user);
+ 
+    /**
+     * Delete User
+     *
+     * @param  User user
+     * @return boolean response of the method
+     */
+    public boolean deleteUser(User user);
+ 
+    /**
+     * Get User List
+     *
+     * @return List user list
+     */
+    public List<User> getUserList();
+	
+}

spring3-rmi-example/src/main/java/net/aimeizi/rmi/server/RMIUserService.java

@@ -0,0 +1,72 @@
+package net.aimeizi.rmi.server;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import net.aimeizi.rmi.cache.service.ICacheService;
+import net.aimeizi.rmi.model.User;
+
+import org.apache.log4j.Logger;
+
+public class RMIUserService implements IRMIUserService {
+
+	private static Logger logger = Logger.getLogger(RMIUserService.class);
+	 
+    //Remote Cache Service is injected...
+    ICacheService cacheService;
+ 
+    /**
+     * Add User
+     *
+     * @param  User user
+     * @return boolean response of the method
+     */
+    public boolean addUser(User user) {
+        getCacheService().getUserMap().put(user.getId(), user);
+        logger.debug("User has been added to cache. User : "+getCacheService().getUserMap().get(user.getId()));
+        return true;
+    }
+ 
+    /**
+     * Delete User
+     *
+     * @param  User user
+     * @return boolean response of the method
+     */
+    public boolean deleteUser(User user) {
+        getCacheService().getUserMap().put(user.getId(), user);
+        logger.debug("User has been deleted from cache. User : "+user);
+        return true;
+    }
+ 
+    /**
+     * Get User List
+     *
+     * @return List user list
+     */
+    public List<User> getUserList() {
+        List<User> list = new ArrayList<User>();
+        list.addAll(getCacheService().getUserMap().values());
+        logger.debug("User List : "+list);
+        return list;
+    }
+ 
+    /**
+     * Get RMI User Service
+     *
+     * @return IRMIUserService RMI User Service
+     */
+    public ICacheService getCacheService() {
+        return cacheService;
+    }
+ 
+    /**
+     * Set RMI User Service
+     *
+     * @param IRMIUserService RMI User Service
+     */
+    public void setCacheService(ICacheService cacheService) {
+        this.cacheService = cacheService;
+    }
+
+}

spring3-rmi-example/src/main/java/net/aimeizi/rmi/server/starter/RMIServerStarter.java

@@ -0,0 +1,11 @@
+package net.aimeizi.rmi.server.starter;
+
+import org.springframework.context.support.ClassPathXmlApplicationContext;
+
+public class RMIServerStarter {
+
+	public static void main(String[] args) {
+		new ClassPathXmlApplicationContext("rmiServerAppContext.xml");
+	}
+
+}

spring3-rmi-example/src/main/resources/log4j.xml

@@ -0,0 +1,14 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE log4j:configuration SYSTEM "log4j.dtd">
+<log4j:configuration xmlns:log4j='http://jakarta.apache.org/log4j/'>
+	<appender name="CA" class="org.apache.log4j.ConsoleAppender">
+		<layout class="org.apache.log4j.PatternLayout">
+			<param name="ConversionPattern" value="%d{dd.MM.yyyy HH:mm:ss} %5p (%F:%L) - %m%n" />
+		</layout>
+	</appender>
+
+	<root>
+		<level value="debug" />
+		<appender-ref ref="CA" />
+	</root>
+</log4j:configuration>

spring3-rmi-example/src/main/resources/rmiClientAppContext.xml

@@ -0,0 +1,21 @@
+<beans xmlns="http://www.springframework.org/schema/beans"
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://www.springframework.org/schema/beans
+		http://www.springframework.org/schema/beans/spring-beans-3.0.xsd">
+
+	<!-- RMI Client Declaration -->
+    <bean id="RMIUserService" class="org.springframework.remoting.rmi.RmiProxyFactoryBean">
+        
+        <!-- serviceUrl represents RMI Service Url called-->
+	    <property name="serviceUrl" value="rmi://127.0.0.1:1099/RMIUserService"/>
+	    
+	    <!-- serviceInterface represents RMI Service Interface called -->
+	    <property name="serviceInterface" value="net.aimeizi.rmi.server.IRMIUserService"/>
+		
+		<!-- refreshStubOnConnectFailure enforces automatic re-lookup of the stub if a 
+							call fails with a connect exception -->
+	    <property name="refreshStubOnConnectFailure" value="true"/>
+	    
+	</bean>
+	 
+</beans>

spring3-rmi-example/src/main/resources/rmiServerAppContext.xml

@@ -0,0 +1,34 @@
+<beans xmlns="http://www.springframework.org/schema/beans"
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://www.springframework.org/schema/beans
+		http://www.springframework.org/schema/beans/spring-beans-3.0.xsd">
+
+	<!-- Beans Declaration -->	
+	<bean id="UserMap" class="java.util.concurrent.ConcurrentHashMap" />
+	
+	<bean id="CacheService" class="net.aimeizi.rmi.cache.service.CacheService">
+		<property name="userMap" ref="UserMap"/>
+	</bean>	
+	
+	<bean id="RMIUserService" class="net.aimeizi.rmi.server.RMIUserService" >
+ 		<property name="cacheService" ref="CacheService"/>
+	</bean>
+	
+	<!-- RMI Server Declaration -->
+    <bean class="org.springframework.remoting.rmi.RmiServiceExporter">
+    	
+    	<!-- serviceName represents RMI Service Name -->
+        <property name="serviceName" value="RMIUserService"/>
+        
+        <!-- service represents RMI Object(RMI Service Impl) -->
+        <property name="service" ref="RMIUserService"/>
+        
+        <!-- serviceInterface represents RMI Service Interface exposed -->
+        <property name="serviceInterface" value="net.aimeizi.rmi.server.IRMIUserService"/>
+        
+        <!-- defaults to 1099 -->
+    	<property name="registryPort" value="1099"/>
+    
+    </bean>
+	
+</beans>