platform/bin/prod.dart

48 lines
1.5 KiB
Dart
Raw Normal View History

2018-07-12 14:51:51 +00:00
import 'dart:io';
2017-10-19 21:53:33 +00:00
import 'dart:isolate';
import 'package:angel/angel.dart';
import 'package:angel_framework/angel_framework.dart';
import 'package:logging/logging.dart';
const String hostname = '127.0.0.1';
const int port = 3000;
void main() {
// Start a server instance in multiple isolates.
for (int id = 0; id < Platform.numberOfProcessors; id++)
Isolate.spawn(isolateMain, id);
isolateMain(Platform.numberOfProcessors);
}
void isolateMain(int id) {
2018-03-29 23:55:28 +00:00
var app = new Angel();
2017-10-19 21:53:33 +00:00
app.configure(configureServer).then((_) async {
// In production, we'll want to log errors to a file.
// Alternatives include sending logs to a service like Sentry.
2018-07-11 13:42:43 +00:00
hierarchicalLoggingEnabled = true;
2017-10-19 21:53:33 +00:00
app.logger = new Logger('angel')
..onRecord.listen((rec) {
2018-06-26 20:50:49 +00:00
if (rec.error == null) {
stdout.writeln(rec);
} else {
2018-06-05 23:51:20 +00:00
var err = rec.error;
if (err is AngelHttpException && err.statusCode != 500) return;
2018-06-26 20:50:49 +00:00
var sink = stderr;
sink..writeln(rec)..writeln(rec.error)..writeln(rec.stackTrace);
2017-10-19 21:53:33 +00:00
}
});
2018-03-29 23:55:28 +00:00
// Passing `startShared` to the constructor allows us to start multiple
// instances of our application concurrently, listening on a single port.
//
// This effectively lets us multi-thread the application.
var http = new AngelHttp.custom(app, startShared);
var server = await http.startServer(hostname, port);
2018-07-15 04:31:40 +00:00
print(
'Instance #$id listening at http://${server.address.address}:${server.port}');
2017-10-19 21:53:33 +00:00
});
}