Add hazelcast-spring Sample

Fixes gh-274

samples/hazelcast-spring/src/main/java/sample/Config.java

@@ -0,0 +1,89 @@
+/*
+ * Copyright 2002-2015 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.
+ */
+
+package sample;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.ApplicationEventPublisher;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.session.MapSessionRepository;
+import org.springframework.session.config.annotation.web.http.EnableSpringHttpSession;
+import org.springframework.session.ExpiringSession;
+import org.springframework.util.SocketUtils;
+
+import com.hazelcast.config.MapConfig;
+import com.hazelcast.config.NetworkConfig;
+import com.hazelcast.config.SerializerConfig;
+import com.hazelcast.core.Hazelcast;
+import com.hazelcast.core.HazelcastInstance;
+import com.hazelcast.core.IMap;
+
+// tag::class[]
+@EnableSpringHttpSession
+@Configuration
+public class Config {
+
+	private String sessionMapName = "spring:session:sessions";
+
+	@Autowired
+	private ApplicationEventPublisher eventPublisher;
+
+	@Bean(destroyMethod = "shutdown")
+	public HazelcastInstance hazelcastInstance() {
+		com.hazelcast.config.Config cfg = new com.hazelcast.config.Config();
+		NetworkConfig netConfig = new NetworkConfig();
+		netConfig.setPort(SocketUtils.findAvailableTcpPort());
+		cfg.setNetworkConfig(netConfig);
+		SerializerConfig serializer = new SerializerConfig().setTypeClass(
+				Object.class).setImplementation(new ObjectStreamSerializer());
+		cfg.getSerializationConfig().addSerializerConfig(serializer);
+		MapConfig mc = new MapConfig();
+		mc.setName(sessionMapName);
+
+		mc.setMaxIdleSeconds(60);
+		cfg.addMapConfig(mc);
+
+		return Hazelcast.newHazelcastInstance(cfg);
+	}
+
+	@Bean
+	public SessionRemovedListener removeListener() {
+		return new SessionRemovedListener(eventPublisher);
+	}
+
+	@Bean
+	public SessionEvictedListener evictListener() {
+		return new SessionEvictedListener(eventPublisher);
+	}
+
+	@Bean
+	public SessionCreatedListener addListener() {
+		return new SessionCreatedListener(eventPublisher);
+	}
+
+	@Bean
+	public MapSessionRepository sessionRepository(HazelcastInstance instance,
+			SessionRemovedListener removeListener, SessionEvictedListener evictListener,
+			SessionCreatedListener addListener) {
+		IMap<String, ExpiringSession> sessions = instance.getMap(sessionMapName);
+		sessions.addEntryListener(removeListener, true);
+		sessions.addEntryListener(evictListener, true);
+		sessions.addEntryListener(addListener, true);
+		return new MapSessionRepository(sessions);
+	}
+}
+// end::class[]

samples/hazelcast-spring/src/main/java/sample/Initializer.java

@@ -0,0 +1,24 @@
+/*
+ * Copyright 2002-2015 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.
+ */
+package sample;
+
+import org.springframework.session.web.context.AbstractHttpSessionApplicationInitializer;
+
+// tag::class[]
+public class Initializer extends AbstractHttpSessionApplicationInitializer {
+
+}
+// end::class[]

samples/hazelcast-spring/src/main/java/sample/ObjectStreamSerializer.java

@@ -0,0 +1,59 @@
+/*
+ * Copyright 2002-2015 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.
+ */
+package sample;
+
+import java.io.*;
+
+import com.hazelcast.nio.ObjectDataInput;
+import com.hazelcast.nio.ObjectDataOutput;
+import com.hazelcast.nio.serialization.StreamSerializer;
+
+/**
+ * A {@link StreamSerializer} that uses Java serialization to persist the
+ * session. This is certainly not the most efficient way to persist sessions,
+ * but the example is intended to demonstrate using minimal dependencies. For
+ * better serialization methods try using <a
+ * href="https://github.com/EsotericSoftware/kryo">Kryo</a>.
+ *
+ * @author Rob Winch
+ *
+ */
+public class ObjectStreamSerializer implements StreamSerializer<Object> {
+	public int getTypeId() {
+		return 2;
+	}
+
+	public void write(ObjectDataOutput objectDataOutput, Object object)
+		   throws IOException {
+		ObjectOutputStream out = new ObjectOutputStream((OutputStream) objectDataOutput);
+		out.writeObject(object);
+		out.flush();
+	}
+
+	public Object read(ObjectDataInput objectDataInput)
+		   throws IOException {
+		ObjectInputStream in = new ObjectInputStream((InputStream) objectDataInput);
+		try {
+			return in.readObject();
+		} catch (ClassNotFoundException e) {
+			throw new IOException(e);
+		}
+	}
+
+	public void destroy() {
+	}
+
+}

samples/hazelcast-spring/src/main/java/sample/SecurityConfig.java

@@ -0,0 +1,34 @@
+/*
+ * Copyright 2002-2015 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.
+ */
+package sample;
+
+/**
+ * @author Rob Winch
+ */
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.security.config.annotation.authentication.builders.AuthenticationManagerBuilder;
+import org.springframework.security.config.annotation.web.configuration.EnableWebSecurity;
+
+@EnableWebSecurity
+public class SecurityConfig {
+	@Autowired
+	public void configureGlobal(AuthenticationManagerBuilder auth) throws Exception {
+		auth
+			.inMemoryAuthentication()
+				.withUser("user").password("password").roles("USER");
+	}
+}

samples/hazelcast-spring/src/main/java/sample/SecurityInitializer.java

@@ -0,0 +1,28 @@
+/*
+ * Copyright 2002-2015 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.
+ */
+package sample;
+
+import org.springframework.security.web.context.AbstractSecurityWebApplicationInitializer;
+
+// tag::class[]
+public class SecurityInitializer extends
+		AbstractSecurityWebApplicationInitializer {
+
+	public SecurityInitializer() {
+		super(SecurityConfig.class, Config.class);
+	}
+}
+// end::class[]

samples/hazelcast-spring/src/main/java/sample/SessionCreatedListener.java

@@ -0,0 +1,24 @@
+
+package sample;
+
+import org.springframework.context.ApplicationEventPublisher;
+import org.springframework.session.ExpiringSession;
+import org.springframework.session.events.SessionCreatedEvent;
+
+import com.hazelcast.core.EntryEvent;
+import com.hazelcast.map.listener.EntryAddedListener;
+
+public class SessionCreatedListener
+		implements EntryAddedListener<String, ExpiringSession> {
+
+	private ApplicationEventPublisher eventPublisher;
+
+	public SessionCreatedListener(ApplicationEventPublisher eventPublisher) {
+		this.eventPublisher = eventPublisher;
+	}
+
+	public void entryAdded(EntryEvent<String, ExpiringSession> event) {
+		System.out.println("Session added: " + event);
+		eventPublisher.publishEvent(new SessionCreatedEvent(this, event.getValue()));
+	}
+}

samples/hazelcast-spring/src/main/java/sample/SessionEvictedListener.java

@@ -0,0 +1,25 @@
+
+package sample;
+
+import org.springframework.context.ApplicationEventPublisher;
+import org.springframework.session.ExpiringSession;
+import org.springframework.session.events.SessionExpiredEvent;
+
+import com.hazelcast.core.EntryEvent;
+import com.hazelcast.map.listener.EntryEvictedListener;
+
+public class SessionEvictedListener
+		implements EntryEvictedListener<String, ExpiringSession> {
+
+	private ApplicationEventPublisher eventPublisher;
+
+	public SessionEvictedListener(ApplicationEventPublisher eventPublisher) {
+		this.eventPublisher = eventPublisher;
+	}
+
+	public void entryEvicted(EntryEvent<String, ExpiringSession> event) {
+		System.out.println("Session removed: " + event);
+		eventPublisher.publishEvent(new SessionExpiredEvent(this, event.getOldValue()));
+	}
+
+}

samples/hazelcast-spring/src/main/java/sample/SessionRemovedListener.java

@@ -0,0 +1,25 @@
+
+package sample;
+
+import org.springframework.context.ApplicationEventPublisher;
+import org.springframework.session.ExpiringSession;
+import org.springframework.session.events.SessionDeletedEvent;
+
+import com.hazelcast.core.EntryEvent;
+import com.hazelcast.map.listener.EntryRemovedListener;
+
+public class SessionRemovedListener
+		implements EntryRemovedListener<String, ExpiringSession> {
+
+	private ApplicationEventPublisher eventPublisher;
+
+	public SessionRemovedListener(ApplicationEventPublisher eventPublisher) {
+		this.eventPublisher = eventPublisher;
+	}
+
+	public void entryRemoved(EntryEvent<String, ExpiringSession> event) {
+		System.out.println("Session removed: " + event);
+		eventPublisher.publishEvent(new SessionDeletedEvent(this, event.getOldValue()));
+	}
+
+}

samples/hazelcast-spring/src/main/java/sample/SessionServlet.java

@@ -0,0 +1,37 @@
+/*
+ * Copyright 2002-2015 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.
+ */
+package sample;
+
+import javax.servlet.ServletException;
+import javax.servlet.annotation.WebServlet;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+
+@WebServlet("/session")
+public class SessionServlet extends HttpServlet {
+
+	@Override
+	protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
+		String attributeName = req.getParameter("attributeName");
+		String attributeValue = req.getParameter("attributeValue");
+		req.getSession().setAttribute(attributeName, attributeValue);
+		resp.sendRedirect(req.getContextPath() + "/");
+	}
+
+	private static final long serialVersionUID = 2878267318695777395L;
+}