Mercurial Hosting > luan
annotate src/luan/webserver/Connection.java @ 1142:0f59eab45f3d
webserver - threading
| author | Franklin Schmidt <fschmidt@gmail.com> |
|---|---|
| date | Tue, 30 Jan 2018 18:02:47 -0700 |
| parents | 4189027691b7 |
| children | ae0a048f3bc7 |
| rev | line source |
|---|---|
| 1137 | 1 package luan.webserver; |
| 2 | |
| 3 import java.io.InputStream; | |
| 4 import java.io.OutputStream; | |
| 5 import java.io.IOException; | |
| 6 import java.net.Socket; | |
| 7 import org.slf4j.Logger; | |
| 8 import org.slf4j.LoggerFactory; | |
| 9 import luan.lib.parser.ParseException; | |
| 10 | |
| 11 | |
| 12 final class Connection { | |
| 13 private static final Logger logger = LoggerFactory.getLogger(Connection.class); | |
| 14 | |
|
1142
0f59eab45f3d
webserver - threading
Franklin Schmidt <fschmidt@gmail.com>
parents:
1138
diff
changeset
|
15 static void handle(Server server,Socket socket) { |
|
0f59eab45f3d
webserver - threading
Franklin Schmidt <fschmidt@gmail.com>
parents:
1138
diff
changeset
|
16 new Connection(server,socket).handle(); |
|
0f59eab45f3d
webserver - threading
Franklin Schmidt <fschmidt@gmail.com>
parents:
1138
diff
changeset
|
17 } |
|
0f59eab45f3d
webserver - threading
Franklin Schmidt <fschmidt@gmail.com>
parents:
1138
diff
changeset
|
18 |
| 1137 | 19 private final Server server; |
| 20 private final Socket socket; | |
| 21 | |
|
1142
0f59eab45f3d
webserver - threading
Franklin Schmidt <fschmidt@gmail.com>
parents:
1138
diff
changeset
|
22 private Connection(Server server,Socket socket) { |
| 1137 | 23 this.server = server; |
| 24 this.socket = socket; | |
| 25 } | |
| 26 | |
| 27 private void handle() { | |
| 28 try { | |
| 29 InputStream in = socket.getInputStream(); | |
| 30 byte[] a = new byte[8192]; | |
| 31 int endOfHeader; | |
| 32 int size = 0; | |
| 33 int left = a.length; | |
| 34 outer: while(true) { | |
| 35 int n = in.read(a,size,left); | |
|
1138
4189027691b7
webserver - add LogHandler
Franklin Schmidt <fschmidt@gmail.com>
parents:
1137
diff
changeset
|
36 if( n == -1 ) { |
|
4189027691b7
webserver - add LogHandler
Franklin Schmidt <fschmidt@gmail.com>
parents:
1137
diff
changeset
|
37 if( size == 0 ) { |
|
4189027691b7
webserver - add LogHandler
Franklin Schmidt <fschmidt@gmail.com>
parents:
1137
diff
changeset
|
38 socket.close(); |
|
4189027691b7
webserver - add LogHandler
Franklin Schmidt <fschmidt@gmail.com>
parents:
1137
diff
changeset
|
39 return; |
|
4189027691b7
webserver - add LogHandler
Franklin Schmidt <fschmidt@gmail.com>
parents:
1137
diff
changeset
|
40 } |
| 1137 | 41 throw new IOException("unexpected end of input at "+size); |
|
1138
4189027691b7
webserver - add LogHandler
Franklin Schmidt <fschmidt@gmail.com>
parents:
1137
diff
changeset
|
42 } |
| 1137 | 43 size += n; |
| 44 for( int i=0; i<=size-4; i++ ) { | |
| 45 if( a[i]=='\r' && a[i+1]=='\n' && a[i+2]=='\r' && a[i+3]=='\n' ) { | |
| 46 endOfHeader = i + 4; | |
| 47 break outer; | |
| 48 } | |
| 49 } | |
| 50 left -= n; | |
| 51 if( left == 0 ) { | |
| 52 byte[] a2 = new byte[2*a.length]; | |
| 53 System.arraycopy(a,0,a2,0,size); | |
| 54 a = a2; | |
| 55 left = a.length - size; | |
| 56 } | |
| 57 } | |
| 58 String rawRequest = new String(a,0,endOfHeader); | |
| 59 //System.out.println(rawRequest); | |
| 60 Request request = RequestHeadParser.parse(rawRequest); | |
| 61 //System.out.println(request.headers); | |
| 62 | |
| 63 Response response = server.handler.handle(request); | |
| 64 response.headers.put("Connection","close"); | |
| 65 response.headers.put("Content-Length",Long.toString(response.body.length)); | |
| 66 byte[] header = response.toHeaderString().getBytes(); | |
| 67 | |
| 68 OutputStream out = socket.getOutputStream(); | |
| 69 out.write(header); | |
| 70 copyAll(response.body.content,out); | |
| 71 out.close(); | |
| 72 socket.close(); | |
| 73 } catch(IOException e) { | |
| 74 logger.info("",e); | |
| 75 } catch(ParseException e) { | |
| 76 logger.info("",e); | |
| 77 } | |
| 78 } | |
| 79 | |
| 80 private static void copyAll(InputStream in,OutputStream out) | |
| 81 throws IOException | |
| 82 { | |
| 83 byte[] a = new byte[8192]; | |
| 84 int n; | |
| 85 while( (n=in.read(a)) != -1 ) { | |
| 86 out.write(a,0,n); | |
| 87 } | |
| 88 } | |
| 89 | |
| 90 } |