Spring/spring-data-gemfire
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

+ finished first draft of the sample

Browse Source 
SGF-3
This commit is contained in:
costin
2010-07-15 21:34:04 +03:00
parent 9eb72b51b2
commit 436853bf35
3 changed files with 86 additions and 65 deletions
Download Patch File Download Diff File Expand all files Collapse all files

137
samples/hello-world/src/main/java/org/springframework/data/gemfire/samples/helloworld/CommandProcessor.java
View File

@@ -23,14 +23,22 @@ import java.io.InputStream;
import java.io.InputStreamReader;
import java.util.Scanner;
import javax.annotation.Resource;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.data.gemfire.GemfireCallback;
import org.springframework.data.gemfire.GemfireTemplate;
import org.springframework.stereotype.Component;
import com.gemstone.gemfire.GemFireCheckedException;
import com.gemstone.gemfire.GemFireException;
import com.gemstone.gemfire.cache.Region;
/**
* @author Costin Leau
*/
@Component
public class CommandProcessor {
private static final Log log = LogFactory.getLog(CommandProcessor.class);
@@ -41,11 +49,8 @@ public class CommandProcessor {
boolean threadActive;
private Thread thread;
private Region<String, String> region;
public CommandProcessor(Region<String, String> region) {
this.region = region;
}
@Resource
private GemfireTemplate template;
void start() {
if (thread == null) {
@@ -57,7 +62,7 @@ public class CommandProcessor {
void stop() throws Exception {
threadActive = false;
thread.join();
thread.join(3 * 100);
}
void awaitCommands() throws Exception {
@@ -70,12 +75,16 @@ public class CommandProcessor {
System.out.println("Hello World!");
System.out.println("Want to interact with the world ? ...");
System.out.println(help);
System.out.print("-> ");
System.out.flush();
try {
BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
while (threadActive) {
if (br.ready()) {
process(br.readLine());
System.out.println(process(br.readLine()));
System.out.print("-> ");
System.out.flush();
}
}
} catch (IOException ioe) {
@@ -98,60 +107,78 @@ public class CommandProcessor {
}
}
String process(String line) throws Exception {
Scanner sc = new Scanner(line);
String command = sc.next();
String process(String line) {
final Scanner sc = new Scanner(line);
// parse commands w/o arguments
if ("exit".equalsIgnoreCase(command)) {
threadActive = false;
return EMPTY;
}
if ("help".equalsIgnoreCase(command)) {
return help;
}
if ("size".equalsIgnoreCase(command)) {
return EMPTY + region.size();
}
if ("clear".equalsIgnoreCase(command)) {
region.clear();
return EMPTY;
}
if ("keys".equalsIgnoreCase(command)) {
return region.keySet().toString();
}
if ("values".equalsIgnoreCase(command)) {
return region.values().toString();
}
return template.execute(new GemfireCallback<String>() {
public String doInGemfire(Region reg) throws GemFireCheckedException, GemFireException {
Region<String, String> region = reg;
String arg = sc.next();
if (!sc.hasNext()) {
return "Invalid command";
}
String command = sc.next();
// commands w/ 1 arg
if ("containsKey".equalsIgnoreCase(command)) {
return EMPTY + region.containsKey(arg);
}
if ("containsValue".equalsIgnoreCase(command)) {
return EMPTY + region.containsValue(arg);
}
if ("query".equalsIgnoreCase(command)) {
return region.query(command).toString();
}
if ("get".equalsIgnoreCase(command)) {
return region.get(arg);
}
if ("remove".equalsIgnoreCase(command)) {
return region.remove(arg);
}
// parse commands w/o arguments
if ("exit".equalsIgnoreCase(command)) {
threadActive = false;
return EMPTY;
}
if ("help".equalsIgnoreCase(command)) {
return help;
}
if ("size".equalsIgnoreCase(command)) {
return EMPTY + region.size();
}
if ("clear".equalsIgnoreCase(command)) {
region.clear();
return EMPTY;
}
if ("keys".equalsIgnoreCase(command)) {
return region.keySet().toString();
}
if ("values".equalsIgnoreCase(command)) {
return region.values().toString();
}
// commands w/ 2 args
if (!sc.hasNext()) {
return "Argument(s) needed";
}
String arg2 = sc.next();
String arg = sc.next();
if ("put".equalsIgnoreCase(command)) {
return region.put(arg, arg2);
}
// commands w/ 1 arg
if ("containsKey".equalsIgnoreCase(command)) {
return EMPTY + region.containsKey(arg);
}
if ("containsValue".equalsIgnoreCase(command)) {
return EMPTY + region.containsValue(arg);
}
if ("query".equalsIgnoreCase(command)) {
return region.query(command).toString();
}
if ("get".equalsIgnoreCase(command)) {
return region.get(arg);
}
if ("remove".equalsIgnoreCase(command)) {
return region.remove(arg);
}
sc.close();
return "unknown command - run 'help' for available commands";
// commands w/ 2 args
if (!sc.hasNext()) {
return "2 Argument needed";
}
String arg2 = sc.next();
if ("put".equalsIgnoreCase(command)) {
return region.put(arg, arg2);
}
sc.close();
return "unknown command - run 'help' for available commands";
}
});
}
}

10
samples/hello-world/src/main/java/org/springframework/data/gemfire/samples/helloworld/HelloWorld.java
View File

@@ -16,8 +16,6 @@
package org.springframework.data.gemfire.samples.helloworld;
import java.util.Map;
import javax.annotation.PostConstruct;
import javax.annotation.PreDestroy;
import javax.annotation.Resource;
@@ -42,19 +40,13 @@ public class HelloWorld {
@Resource(name = "hw-region")
private Region<String, String> region;
// re-inject the region (as a Map)
// the name is required since by default Spring
// injects the beans
@Resource(name = "hw-region")
private Map<String, String> map;
@Resource
private CommandProcessor processor;
@PostConstruct
void start() {
log.info("Member " + region.getCache().getDistributedSystem().getDistributedMember().getId()
+ " connecting to region [" + region.getName() + "]");
processor = new CommandProcessor(region);
processor.start();
}

4
samples/hello-world/src/main/resources/app-context.xml
View File

@@ -9,5 +9,7 @@
<import resource="cache-context.xml"/>
<!-- find beans by scanning the classpath -->
<context:component-scan base-package="org.springframework.data.gemfire.samples.helloworld"/>
<context:component-scan base-package="org.springframework.data.gemfire.samples.helloworld"/>
<bean id="gemfireTemplate" class="org.springframework.data.gemfire.GemfireTemplate" p:region-ref="hw-region"/>
</beans>