Mercurial > hg > Database > jungle-network
annotate src/main/java/app/bbs/codesegment/StartBBSCodeSegment.java @ 176:6f104ab4eb81
fit jungle core but editMessage is not work
author | tatsuki |
---|---|
date | Mon, 01 Sep 2014 00:04:32 +0900 |
parents | 2403b9a4416f |
children | 89db8388db0f |
rev | line source |
---|---|
112 | 1 package app.bbs.codesegment; |
44 | 2 |
3 import java.util.regex.Pattern; | |
4 import java.util.regex.Matcher; | |
5 | |
6 import javax.servlet.Servlet; | |
7 | |
154 | 8 import org.eclipse.jetty.server.Server; |
9 import org.eclipse.jetty.servlet.ServletHandler; | |
10 import org.eclipse.jetty.servlet.ServletHolder; | |
155 | 11 import org.eclipse.jetty.util.thread.ThreadPool; |
154 | 12 |
125 | 13 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.bbs.CreateBoardMessageServlet; |
14 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.bbs.CreateBoardServlet; | |
140
09b405d0830b
Removed EditMessageUseGetServlet
Nobuyasu Oshiro <dimolto@cr.ie.u-ryukyu.ac.jp>
parents:
139
diff
changeset
|
15 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.bbs.EditMessageUseGetServlet; |
125 | 16 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.bbs.ShowBoardsServlet; |
17 | |
154 | 18 |
44 | 19 |
20 import alice.codesegment.CodeSegment; | |
21 import alice.datasegment.CommandType; | |
22 import alice.datasegment.Receiver; | |
124 | 23 import app.bbs.NetworkBulletinBoard; |
112 | 24 import app.bbs.NetworkJungleBulletinBoard; |
143
7a7bac51a3cc
Added RequestNumCheckServlet
Nobuyasu Oshiro <dimolto@cr.ie.u-ryukyu.ac.jp>
parents:
140
diff
changeset
|
25 import app.bbs.RequestNumCheckServlet; |
146
29734d7d6521
Added ShowMessageWithTimeStampServlet
Nobuyasu Oshiro <dimolto@cr.ie.u-ryukyu.ac.jp>
parents:
143
diff
changeset
|
26 import app.bbs.ShowMessageWithTimeStampServlet; |
169 | 27 import app.bbs.thinks.CreateNode; |
28 import app.bbs.thinks.EditAttributeServlet; | |
29 import app.bbs.thinks.EditNodeName; | |
165 | 30 import app.bbs.thinks.ShowMatrix; |
31 import app.bbs.thinks.createAttributeMatrix; | |
169 | 32 import app.bbs.thinks.deleteAttributeServlet; |
33 import app.bbs.thinks.deleteNodeServlet; | |
106
f42f2e6b31de
Removed project reference and Added dependency in pom.xml
one
parents:
105
diff
changeset
|
34 |
44 | 35 public class StartBBSCodeSegment extends CodeSegment { |
155 | 36 |
37 int bbsPort = 8080; | |
38 Receiver host = ids.create(CommandType.PEEK); | |
39 private Pattern pattern = Pattern.compile("^(node|cli)([0-9]+)$"); | |
40 private String[] args; | |
41 boolean persistentFlag = false; | |
42 | |
43 public StartBBSCodeSegment(String[] _args, int p) { | |
44 args = _args; | |
45 bbsPort = p; | |
46 host.setKey("host"); | |
47 } | |
48 | |
49 public StartBBSCodeSegment() { | |
50 args = null; | |
51 host.setKey("host"); | |
52 } | |
53 | |
54 @Override | |
55 public void run() { | |
56 String name = host.asString(); | |
57 Matcher matcher = pattern.matcher(name); | |
58 matcher.find(); | |
59 // String type = matcher.group(1); | |
60 for(String arg: args) { | |
61 if(arg.equals("-persistent")){ | |
62 persistentFlag = true; | |
63 } | |
64 } | |
65 NetworkBulletinBoard cassaBBS = null; | |
66 if(persistentFlag) { | |
67 System.out.println("log loading..."); | |
68 cassaBBS = NetworkJungleBulletinBoard.NewPersistentJungle(name); | |
69 cassaBBS.init(); | |
70 } else { | |
71 cassaBBS = new NetworkJungleBulletinBoard(name); | |
72 cassaBBS.init(); | |
73 } | |
48 | 74 |
155 | 75 System.out.println("StartBBSCodeSegment"); |
76 System.out.println("name : "+ name); | |
77 /* Jetty registration */ | |
78 String createBoardMessagePath = "/createBoardMessage"; | |
165 | 79 String createFolderPath = "/createFolder"; |
155 | 80 String createBoardPath = "/createBoard"; |
81 String editMessagePath = "/editMessage"; | |
82 String showBoardMessagePath = "/showBoardMessage"; | |
165 | 83 String showMatrixPath = "/showMatrix"; |
84 String createAttributePath = "/createAttribute"; | |
168 | 85 String editAttributePath = "/editAttribute"; |
169 | 86 String deleteAttributePath = "/deleteAttribute"; |
87 String deleteNodePath = "/deleteNode"; | |
155 | 88 Server serv = new Server(bbsPort); |
89 ThreadPool thp = serv.getThreadPool(); | |
90 Servlet createBoardMessage = new CreateBoardMessageServlet(cassaBBS); | |
169 | 91 Servlet createFolder = new CreateNode(cassaBBS); |
155 | 92 Servlet createBoard = new CreateBoardServlet(cassaBBS); |
169 | 93 Servlet editBoardMessage = new EditNodeName(cassaBBS); |
165 | 94 Servlet createAttribute = new createAttributeMatrix(cassaBBS); |
169 | 95 Servlet editAttribute = new EditAttributeServlet(cassaBBS); |
96 Servlet deleteAttribute = new deleteAttributeServlet(cassaBBS); | |
97 Servlet deleteNode = new deleteNodeServlet(cassaBBS); | |
155 | 98 Servlet index = new ShowBoardsServlet(cassaBBS,createBoardPath,showBoardMessagePath); |
99 // Servlet board = new ShowBoardMessageServlet(cassaBBS,createBoardMessagePath,editMessagePath); | |
165 | 100 Servlet board = new ShowMessageWithTimeStampServlet(cassaBBS,createBoardMessagePath,editMessagePath,showMatrixPath, thp); |
169 | 101 Servlet matrix = new ShowMatrix(cassaBBS,createFolderPath,editMessagePath, showMatrixPath, createAttributePath, editAttributePath,deleteAttributePath,deleteNodePath,thp); |
165 | 102 |
155 | 103 ServletHandler context = new ServletHandler(); |
104 context.addServletWithMapping(new ServletHolder(createBoardMessage),createBoardMessagePath); | |
165 | 105 context.addServletWithMapping(new ServletHolder(createFolder),createFolderPath); |
155 | 106 context.addServletWithMapping(new ServletHolder(createBoard),createBoardPath); |
107 context.addServletWithMapping(new ServletHolder(editBoardMessage),editMessagePath); | |
165 | 108 context.addServletWithMapping(new ServletHolder(createAttribute),createAttributePath); |
155 | 109 context.addServletWithMapping(new ServletHolder(index),"/"); |
169 | 110 context.addServletWithMapping(new ServletHolder(deleteAttribute),deleteAttributePath); |
111 context.addServletWithMapping(new ServletHolder(deleteNode),deleteNodePath); | |
168 | 112 context.addServletWithMapping(new ServletHolder(editAttribute),editAttributePath); |
155 | 113 context.addServletWithMapping(new ServletHolder(board),showBoardMessagePath); |
165 | 114 context.addServletWithMapping(new ServletHolder(matrix),showMatrixPath); |
155 | 115 /* |
116 * For write benchmark | |
117 */ | |
118 String editMessageUseGetPath = "/editMessageUseGet"; | |
119 Servlet editMessageUseGet = new EditMessageUseGetServlet(cassaBBS); | |
120 context.addServletWithMapping(new ServletHolder(editMessageUseGet), editMessageUseGetPath); | |
121 String requestNumCheckPath = "/requestNum"; | |
122 Servlet requestNumCheckServlet = new RequestNumCheckServlet(cassaBBS); | |
123 context.addServletWithMapping(new ServletHolder(requestNumCheckServlet), requestNumCheckPath); | |
124 | |
125 serv.setHandler(context); | |
126 try { | |
127 serv.start(); | |
128 } catch (Exception e) { | |
129 e.printStackTrace(); | |
130 } | |
131 new LogUpdateCodeSegment(); | |
132 } | |
44 | 133 |
134 } |