|
0
|
1 package rep;
|
|
|
2
|
|
|
3 import java.io.IOException;
|
|
|
4 import java.nio.ByteBuffer;
|
|
33
|
5 import java.nio.CharBuffer;
|
|
27
|
6 import java.nio.channels.SelectionKey;
|
|
0
|
7 import java.nio.channels.SocketChannel;
|
|
33
|
8 import java.nio.charset.CharacterCodingException;
|
|
|
9 import java.nio.charset.Charset;
|
|
|
10 import java.nio.charset.CharsetDecoder;
|
|
13
|
11 import java.util.LinkedList;
|
|
|
12 import java.util.StringTokenizer;
|
|
0
|
13
|
|
|
14 public class REPPacketReceive {
|
|
|
15
|
|
|
16 SocketChannel socketchannel;
|
|
17
|
17 private final int HEADER_SIZE = 24;
|
|
51
|
18 private final int CHAR_ORDER = 3;
|
|
17
|
19 //private String host;
|
|
|
20 //private int port;
|
|
27
|
21 SelectionKey key;
|
|
0
|
22
|
|
|
23 public REPPacketReceive(SocketChannel sc){
|
|
|
24 socketchannel = sc;
|
|
|
25 }
|
|
27
|
26
|
|
|
27 public void setkey(SelectionKey key) {
|
|
|
28 this.key = key;
|
|
|
29 //key.cancel();
|
|
|
30 }
|
|
0
|
31
|
|
49
|
32 public REPCommand unpack() {
|
|
|
33
|
|
|
34 ByteBuffer header = ByteBuffer.allocateDirect(HEADER_SIZE);
|
|
|
35 long len = 0;
|
|
|
36 header.clear();
|
|
|
37 try {
|
|
|
38 len = socketchannel.read(header);
|
|
|
39 if(len == -1){
|
|
|
40 if(key != null){
|
|
|
41 key.cancel();
|
|
|
42 }
|
|
|
43 socketchannel.close();
|
|
|
44 return null;
|
|
|
45 }else if(len == 0){
|
|
|
46 return null;
|
|
|
47 }
|
|
|
48 } catch (IOException e1) {
|
|
|
49 e1.printStackTrace();
|
|
|
50 } // limit = read length
|
|
|
51 if (len !=HEADER_SIZE) {
|
|
|
52 System.out.println("てす");
|
|
|
53 // this can't happen
|
|
|
54 }
|
|
|
55 header.rewind(); // position = 0
|
|
|
56
|
|
|
57 String text = "";
|
|
|
58 int cmd = header.getInt();
|
|
|
59 int sid = header.getInt();
|
|
|
60 int eid = header.getInt();
|
|
|
61 int seqid = header.getInt();
|
|
|
62 int lineno = header.getInt();
|
|
|
63 int textsiz = header.getInt()/2;
|
|
|
64
|
|
|
65 ByteBuffer textBuffer = ByteBuffer.allocateDirect(textsiz*2);
|
|
|
66
|
|
|
67 try {
|
|
|
68 len = socketchannel.read(textBuffer);
|
|
|
69 } catch (IOException e1) {
|
|
|
70 e1.printStackTrace();
|
|
|
71 } // limit = read length
|
|
|
72 if (len != textsiz * 2) {
|
|
|
73 // this can't happen
|
|
|
74 System.out.println("あと");
|
|
|
75 }
|
|
|
76 textBuffer.rewind();
|
|
|
77 for(int i=0;i<textsiz;i++) {
|
|
|
78 text +=textBuffer.getChar();
|
|
|
79 }
|
|
|
80 String string = text;
|
|
|
81 //System.out.println(string);
|
|
|
82 //getSocket(string);
|
|
|
83 REPCommand repcommand = new REPCommand(cmd, sid, eid, seqid, lineno, textsiz, string);
|
|
|
84 System.out.println("received command: " + repcommand.toString());
|
|
|
85 //getSocket(repcommand);
|
|
|
86 //System.out.println("received command: " + repcommand.toString());
|
|
|
87 return repcommand;
|
|
|
88 }
|
|
|
89
|
|
33
|
90 public REPCommand unpackUConv() {
|
|
|
91 ByteBuffer header = ByteBuffer.allocateDirect(HEADER_SIZE);
|
|
|
92 long len = 0;
|
|
|
93 header.clear();
|
|
|
94 try {
|
|
|
95 len = socketchannel.read(header);
|
|
|
96 if(len == -1){
|
|
|
97 if(key != null){
|
|
|
98 key.cancel();
|
|
|
99 }
|
|
|
100 socketchannel.close();
|
|
|
101 return null;
|
|
|
102 }else if(len == 0){
|
|
|
103 return null;
|
|
|
104 }
|
|
|
105 } catch (IOException e1) {
|
|
|
106 e1.printStackTrace();
|
|
|
107 } // limit = read length
|
|
|
108 if (len !=HEADER_SIZE) {
|
|
|
109 System.out.println("てす");
|
|
|
110 // this can't happen
|
|
|
111 }
|
|
|
112 header.rewind(); // position = 0
|
|
|
113
|
|
|
114 int cmd = header.getInt();
|
|
|
115 int sid = header.getInt();
|
|
|
116 int eid = header.getInt();
|
|
|
117 int seqid = header.getInt();
|
|
|
118 int lineno = header.getInt();
|
|
46
|
119 int textsiz = header.getInt();
|
|
|
120 //int tmptextsiz = header.getInt();
|
|
|
121 //int textsiz = (tmptextsiz /5) + (tmptextsiz % 5);
|
|
33
|
122
|
|
46
|
123 ByteBuffer textBuffer = ByteBuffer.allocateDirect(textsiz);
|
|
|
124
|
|
33
|
125 try {
|
|
|
126 len = socketchannel.read(textBuffer);
|
|
46
|
127 if(len == -1){
|
|
|
128 if(key != null){
|
|
|
129 key.cancel();
|
|
|
130 }
|
|
|
131 socketchannel.close();
|
|
|
132 return null;
|
|
|
133 }
|
|
33
|
134 } catch (IOException e1) {
|
|
|
135 e1.printStackTrace();
|
|
|
136 } // limit = read length
|
|
46
|
137 if (len != textsiz) {
|
|
33
|
138 // this can't happen
|
|
|
139 System.out.println("あと");
|
|
|
140 }
|
|
|
141 textBuffer.rewind();
|
|
|
142
|
|
|
143 //Decode UTF-8 to System Encoding(UTF-16)
|
|
|
144 Charset charset = Charset.forName("UTF-8");
|
|
|
145 CharsetDecoder decoder = charset.newDecoder();
|
|
|
146 CharBuffer cb = null;
|
|
|
147 try {
|
|
|
148 cb = decoder.decode(textBuffer);
|
|
|
149 } catch (CharacterCodingException e) {
|
|
|
150 e.printStackTrace();
|
|
|
151 }
|
|
46
|
152 cb.rewind();
|
|
33
|
153
|
|
|
154 String string = cb.toString();
|
|
|
155
|
|
51
|
156 textsiz = string.length();
|
|
118
|
157 // if(textsiz > 2){
|
|
|
158 // System.out.println(string);
|
|
|
159 // }
|
|
51
|
160 //System.out.println("CharBuffer size: " +cb.length());
|
|
|
161
|
|
33
|
162 //System.out.println("textsize: " +textsiz);
|
|
51
|
163
|
|
33
|
164 //System.out.println(cb.toString());
|
|
|
165
|
|
|
166 REPCommand repcommand = new REPCommand(cmd, sid, eid, seqid, lineno, textsiz, string);
|
|
46
|
167 System.out.println("UnPack Packet: => cmd:"+cmd+" sid:"+sid+" eid:"+eid+"seqid:"+seqid+" lineno:"+lineno+" textsiz:" +textsiz+" text: "+string);
|
|
33
|
168 System.out.println("received command: " + repcommand.toString());
|
|
49
|
169
|
|
33
|
170 return repcommand;
|
|
|
171 }
|
|
13
|
172
|
|
15
|
173 private void getSocket(REPCommand command) {
|
|
18
|
174 if(command.cmd != REP.SMCMD_JOIN){
|
|
15
|
175 String string = command.string;
|
|
|
176 StringTokenizer st2 = new StringTokenizer(string, ":");
|
|
20
|
177 LinkedList<String> list = new LinkedList<String>();
|
|
|
178 while (st2.hasMoreTokens()){
|
|
|
179 list.add(st2.nextToken());
|
|
|
180 }
|
|
|
181 String port = list.getLast();
|
|
|
182 list.removeLast();
|
|
|
183 String host = list.getLast();
|
|
|
184 int socketInfoLength = host.length() + port.length() + 2;
|
|
|
185 System.out.println(host.length() + ":" + port.length() + ":" + socketInfoLength);
|
|
15
|
186 command.setString(string.substring(0, string.length() - socketInfoLength));
|
|
17
|
187 command.setHost(host);
|
|
20
|
188 command.setPort(port);
|
|
18
|
189 }
|
|
13
|
190 }
|
|
0
|
191 }
|
