1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
|
/**
* Copyright 2009 Google Inc.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS-IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package net.appjet.oui;
object monitoring {
def startMonitoringServer() {
// remote JMX monitoring
// see: http://java.sun.com/javase/6/docs/technotes/guides/management/agent.html
import java.rmi.registry.LocateRegistry;
import java.lang.management.ManagementFactory;
import javax.management.ObjectName;
import javax.management.remote.{JMXServiceURL, JMXConnectorServerFactory};
def REGISTRY_PORT = config.listenMonitoringPrimaryPort;
def SECONDARY_PORT = config.listenMonitoringSecondaryPort;
System.setProperty("java.rmi.server.randomIDs", "true");
// we must set 'java.rmi.server.hostname' to the host that the client machine
// should connect to; in production, it will be the dashboard host, but the property
// can also be specified on the command-line, in which case it takes precedence.
var listenHost = config.listenMonitoringHost
if (listenHost == null || listenHost.length == 0) listenHost = "localhost";
if (System.getProperty("java.rmi.server.hostname") == null) {
System.setProperty("java.rmi.server.hostname", listenHost);
}
else {
listenHost = System.getProperty("java.rmi.server.hostname");
}
LocateRegistry.createRegistry(REGISTRY_PORT);
val mbs = ManagementFactory.getPlatformMBeanServer();
mbs.createMBean(classOf[JSExecutor].getName, new ObjectName("net.appjet:type=JSExecutor"));
val env = new java.util.HashMap[String,Object]();
//val csf = new javax.rmi.ssl.SslRMIClientSocketFactory();
//val ssf = new javax.rmi.ssl.SslRMIServerSocketFactory();
//env.put(javax.management.remote.rmi.RMIConnectorServer.RMI_CLIENT_SOCKET_FACTORY_ATTRIBUTE, csf);
//env.put(javax.management.remote.rmi.RMIConnectorServer.RMI_SERVER_SOCKET_FACTORY_ATTRIBUTE, ssf);
val PASSWORD_FILE_PATH = "data/jconsole-password.properties";
val ACCESS_FILE_PATH = "data/jconsole-access.properties";
def writeStringToFile(str: String, path: String) {
val out = new java.io.PrintStream(new java.io.BufferedOutputStream(
new java.io.FileOutputStream(path)));
out.println(str);
out.close;
}
if (! new java.io.File(PASSWORD_FILE_PATH).exists) {
System.err.println("Creating "+PASSWORD_FILE_PATH+"...");
writeStringToFile("appjet foo", PASSWORD_FILE_PATH);
}
if (! new java.io.File(ACCESS_FILE_PATH).exists) {
System.err.println("Creating "+ACCESS_FILE_PATH+"...");
writeStringToFile("appjet readwrite", ACCESS_FILE_PATH);
}
env.put("jmx.remote.x.password.file", PASSWORD_FILE_PATH);
env.put("jmx.remote.x.access.file", ACCESS_FILE_PATH);
val url = new JMXServiceURL(
"service:jmx:rmi://localhost:"+SECONDARY_PORT+"/jndi/rmi://localhost:"+REGISTRY_PORT+"/server");
try {
val cs = JMXConnectorServerFactory.newJMXConnectorServer(url, env, mbs);
cs.start();
System.err.println("Monitor server listening on "+listenHost+":{"+REGISTRY_PORT+
","+SECONDARY_PORT+"}");
}
catch {
case e => {
System.err.println("!!Could not start monitor server on "+listenHost+":{"+REGISTRY_PORT+
","+SECONDARY_PORT+"} due to:");
e.printStackTrace(System.err);
}
}
}
}
trait JSExecutorMXBean {
def executeJS(code: String): String;
}
class JSExecutor extends JSExecutorMXBean {
import org.mozilla.javascript.{Context,ContextFactory,ContextAction};
import org.mozilla.javascript.tools.ToolErrorReporter;
import org.mozilla.javascript.tools.shell.{Global, ShellContextFactory};
def executeJS(code: String): String = {
val outStream = new java.io.ByteArrayOutputStream;
val out = new java.io.PrintStream(outStream, true, "UTF-8");
val contextFactory = new ShellContextFactory;
try {
contextFactory.call(new ContextAction { def run(cx: Context): Object = {
val global = new Global(cx);
global.setOut(out);
global.setErr(out);
val errorReporter = new ToolErrorReporter(false, global.getErr);
val result = cx.evaluateString(global, code, "<script>", 1, null);
out.println(Context.toString(result));
null;
} });
}
catch {
case e => {
e.printStackTrace(out);
}
}
return new String(outStream.toByteArray, "UTF-8");
}
}
|
