mrpastewart/protevus
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Delete multi_server.dart

Browse source
This commit is contained in:
Tobe O 2016-12-26 08:20:22 -05:00 committed by GitHub
parent 55672d1fe9
commit da42107196
1 changed files with 0 additions and 65 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

65
bin/multi_server.dart
View file

@ -1,65 +0,0 @@
import 'dart:convert';
import 'dart:io';
import 'package:angel_multiserver/angel_multiserver.dart';
final Uri cluster = Platform.script.resolve('cluster.dart');
final error502 = GZIP.encode(UTF8.encode('''
<!DOCTYPE html>
<html>
<head>
<title>502 Bad Gateway</title>
</head>
<body>
<h1>502 Bad Gateway</h1>
</body>
</html>
'''));
final error503 = GZIP.encode(UTF8.encode('''
<!DOCTYPE html>
<html>
<head>
<title>503 Service Unavailable</title>
</head>
<body>
<h1>503 Service Unavailable</h1>
<i>There is no server available to service your request.</i>
</body>
</html>
'''));
main() async {
var loadBalancer = new LoadBalancer();
await loadBalancer.spawnIsolates(cluster, count: 3);
loadBalancer
..onCrash.listen((_) {
// Auto-spawn a new instance on crash
loadBalancer.spawnIsolates(cluster);
})
..onErrored.listen((socket) async {
try {
socket
..writeln('HTTP/1.1 502 Bad Gateway')
..writeln(HttpDate.format(new DateTime.now()))
..writeln('Content-Encoding: gzip')
..writeln()
..add(error502)
..writeln();
await socket.close();
} catch(_) {}
})
..onUnavailable.listen((socket) async {
socket
..writeln('HTTP/1.1 503 Service Unavailable')
..writeln(HttpDate.format(new DateTime.now()))
..writeln('Content-Encoding: gzip')
..writeln()
..add(error503)
..writeln();
await socket.close();
});
var server = await loadBalancer.startServer();
print(
'Load balancer listening at http://${server.address.address}:${server.port}');
}