Mercurial > hg > Members > tatsuki > bbs

comparison src/main/java/jp/ac/u_ryukyu/ie/cr/bbs/local/bbs/App.java @ 8:766f7668521f

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
commit
author tatsuki
date Thu, 02 Feb 2017 23:05:59 +0900
parents src/main/java/jp/ac/u_ryukyu/ie/cr/bbs/local/App.java@6c584862fe93
children
comparison
equal deleted inserted replaced
7:6c584862fe93 8:766f7668521f
1 package jp.ac.u_ryukyu.ie.cr.bbs.local.bbs;
2
3 import me.prettyprint.hector.api.HConsistencyLevel;
4 import org.eclipse.jetty.server.Server;
5 import org.eclipse.jetty.servlet.ServletHandler;
6 import org.eclipse.jetty.servlet.ServletHolder;
7
8 import javax.servlet.Servlet;
9
10
11 /**
12 * Hello world!
13 *
14 */
15 public class App
16 {
17 public static void main( String[] args ) throws Exception
18 {
19 BulletinBoard cassaBBS = null;
20 if(args.length == 0){
21 cassaBBS = new JungleBulletinBoard();
22 }else{
23 HConsistencyLevel cLevel = HConsistencyLevel.QUORUM;
24 int rep_factor = 1;
25 int i=0;
26 while(i<args.length) {
27 if(args[i].equals("-all")) {
28 cLevel = HConsistencyLevel.ALL;
29 }else if(args[i].equals("-one")){
30 cLevel = HConsistencyLevel.ONE;
31 }else if(args[i].equals("-quorum")){
32 cLevel = HConsistencyLevel.QUORUM;
33 }else if(args[i].equals("-any")){
34 cLevel = HConsistencyLevel.ANY;
35 }else if(args[i].equals("-rep")){
36 i++;
37 rep_factor = Integer.parseInt(args[i]);
38 }
39 i++;
40 }
41 System.out.println("ConsistencyLevel "+cLevel.toString());
42 System.out.println("Replication factor "+rep_factor);
43 cassaBBS = new CassandraBulletinBoard("test-cluster","localhost:9160","cassaBBS2", cLevel, rep_factor);
44 }
45
46 String createBoardMessagePath = "/createBoardMessage";
47 String createBoardPath = "/createBoard";
48 String editMessagePath = "/editMessage";
49 String showBoardMessagePath = "/showBoardMessage";
50
51 Servlet createBoardMessage = new CreateBoardMessageServlet(cassaBBS);
52 Servlet createBoard = new CreateBoardServlet(cassaBBS);
53 Servlet editBoardMessage = new EditMessageServlet(cassaBBS);
54 Servlet index = new ShowBoardsServlet(cassaBBS,createBoardPath,showBoardMessagePath);
55 Servlet board = new ShowBoardMessageServlet(cassaBBS,createBoardMessagePath,editMessagePath);
56
57 Server serv = new Server(8080);
58 // Server serv = new Server();
59 ServletHandler context = new ServletHandler();
60 context.addServletWithMapping(new ServletHolder(createBoardMessage),createBoardMessagePath);
61 context.addServletWithMapping(new ServletHolder(createBoard),createBoardPath);
62 context.addServletWithMapping(new ServletHolder(editBoardMessage),editMessagePath);
63 context.addServletWithMapping(new ServletHolder(index),"/");
64 context.addServletWithMapping(new ServletHolder(board),showBoardMessagePath);
65 /*
66 * For write benchmark
67 */
68 String editMessageUseGetPath = "/editMessageUseGet";
69 Servlet editMessageUseGet = new EditMessageUseGetServlet(cassaBBS);
70 context.addServletWithMapping(new ServletHolder(editMessageUseGet), editMessageUseGetPath);
71
72 serv.setHandler(context);
73 serv.start();
74 }
75 }