Interesting idea, my compliments, I'll save your code...
But when I start thinking about it, I'm not sure where I'm going to end up if I
started using this approach. If every application would have an FTP server
running to configure log4j, I would quickly die managing the FTP ports. The
final solution would need to be able to handle multiple Log4j context via one
FTP server.
So that is a problem (me being dead, that is). I use Log4j mostly in a
webserver (webapp), so why use FTP if I have HTTP available? Then all I would
require is a servlet that handles a file upload. And I think I saw that coming
by a few weeks ago.
Tom
Quoting "ROQUES Arnaud - NTR ( [EMAIL PROTECTED] )"
<[EMAIL PROTECTED]>:
> Hi!
>
> log4j is great, but I think that
> PropertyConfigurator.configureAndWatch(String configFilename) is not good
> enough for
> dynamic modification, as you have to wait until the delay so that your
> modification are taken into account.
>
> So I imagine a solution: to put a *very* little FTP server in the
> application on a particular port (example:2100).
> When you put a file on this server, the file is not saved on disk, but sent
> to PropertyConfigurator, so that modifications of the configu are taken into
> account immediatly. (You can log with any username and password)
>
> (Some text editor have embedded FTP client, so it can be very easy to change
> the log4j configuration with them)
>
> I have coded this little FTP server, so if you want to use it, all you have
> to do is:
>
> PropertyConfigurator.configure("myconf.properties"); // As
usually
> new FTPServer(2100, "myconf.properties"); // Launch the server
on the 2100
>
> Note that when you put some files on the FTP server, data are *not* saved to
> disk. It's only sent to log4j PropertyConfigurator. (You can also get the
> last config from the FTP server).
>
> Please free to improve it, or to integrate it in next version of log4j!
>
> Arnaud Roques
>
> FTPServer.java file:
> ------------------------
>
> import java.io.*;
> import java.net.*;
> import java.util.*;
> import org.apache.log4j.*;
>
> public class FTPServer extends Thread
> {
> ServerSocket server;
> ArrayList data;
>
> FTPServer(int port, String fileName) throws Exception
> {
> data = new ArrayList();
> File f = new File(fileName);
> BufferedReader br = new BufferedReader(new FileReader(f));
> String s;
> while ((s=br.readLine())!=null)
> data.add(s);
> server = new ServerSocket(port);
> System.err.println("FTP Server on " +
> InetAddress.getLocalHost().getHostAddress()+" "+port);
> start();
> }
>
> public void run()
> {
> try
> {
> while (true)
> {
> Socket client = server.accept(); // when the
signal arrives, the server
> build a new socket in order to communicate witht the client
> Thread session = new FTPSession(client, data);
> session.start();
> }
> }
> catch (IOException e)
> {
> e.printStackTrace();
> }
> }
> }
>
> class FTPSession extends Thread
> {
> private PrintWriter out;
> private BufferedReader in;
> private String dataHost;
> private int dataPort = -1;
> private ArrayList data;
>
> public FTPSession(Socket s, ArrayList data)
> {
> this.data = data;
> try
> {
> in = new BufferedReader(new
> InputStreamReader(s.getInputStream()));
> out = new PrintWriter(s.getOutputStream(), true);
> }
> catch (Exception e)
> {
> e.printStackTrace();
> }
> }
>
>
> int reply(int code, String text)
> {
> out.println(code + " " + text);
> return code;
> }
>
> //
> // The run method...
> //
> public void run()
> {
> reply(220, "log4j FTP server");
> try
> {
> while (true)
> {
> String response = in.readLine().toUpperCase();
> if (response.startsWith("USER"))
> {
> reply(331, "Password required");
> }
> else if (response.startsWith("PASS"))
> {
> reply(230, "Logged in.");
> }
> else if (response.startsWith("SYST"))
> {
> reply(215, "javaFTP");
> }
> else if (response.startsWith("TYPE"))
> {
> reply(200, "Type OK");
> }
> else if (response.startsWith("PORT"))
> {
> String portStr = response.substring
(response.indexOf(' ')+1);
> StringTokenizer st = new StringTokenizer
(portStr, ",");
> String h1 = st.nextToken();
> String h2 = st.nextToken();
> String h3 = st.nextToken();
> String h4 = st.nextToken();
> int p1 = Integer.parseInt(st.nextToken
());
> int p2 = Integer.parseInt(st.nextToken
());
>
> String dataHost = h1 + "." + h2 + "." +
h3 + "." + h4;
> int dataPort = (p1 << 8) | p2;
> setDataPort(dataHost, dataPort);
>
> reply(200, "Port OK");
> }
> else if (response.startsWith("MODE"))
> {
> reply(200, "Mode OK");
> }
> else if (response.startsWith("STRU"))
> {
> reply(200, "Stru OK");
> }
> else if (response.startsWith("PWD"))
> {
> reply(257, "/");
> }
> else if (response.startsWith("CWD"))
> {
> reply(250, "CWD command successful.");
> }
> else if (response.startsWith("QUIT"))
> {
> reply(221, "Goodbye");
> return;
> }
> else if (response.startsWith("RETR"))
> {
> Socket dataSocket = new Socket
(dataHost, dataPort);
> PrintWriter writer = new PrintWriter
(dataSocket.getOutputStream());
> reply(150, "Opening connection");
> for (int i=0; i<data.size(); i++)
> {
> writer.print((String)data.get
(i));
> writer.print("\r\n");
> }
> writer.flush();
> writer.close();
> reply(226, "Transfer complete.");
> }
> else if (response.startsWith("STOR"))
> {
> Socket dataSocket = new Socket
(dataHost, dataPort);
> BufferedReader br = new BufferedReader(
> new InputStreamReader
(dataSocket.getInputStream()));
> reply(150, "Opening connection");
> String s;
> data.clear();
> StringBuffer sb = new StringBuffer();
> while ((s=br.readLine())!=null)
> {
> data.add(s);
> sb.append(s);
> sb.append('\n');
> }
> br.close();
> reply(226, "Transfer complete.");
>
> Properties prop = new Properties();
> prop.load(new ByteArrayInputStream
(sb.toString().getBytes()));
> // Send data to log4J
> PropertyConfigurator.configure(prop);
>
> }
> else if (response.startsWith("LIST"))
> {
> Socket dataSocket = new Socket
(dataHost, dataPort);
> PrintWriter writer = new PrintWriter
(dataSocket.getOutputStream());
> reply(150, "Opening connection");
> writer.print("total 0\r\n");
> writer.print("LOG4J.properties\r\n");
> writer.flush();
> writer.close();
> reply(226, "Transfer complete.");
> }
> else
> {
> reply(500, "Not supported");
> }
> }
> }
> catch(Exception e)
> {
> e.printStackTrace();
> }
>
> }
>
> public void setDataPort(String host, int port)
> {
> dataHost = host;
> dataPort = port;
> }
>
> }
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: [EMAIL PROTECTED]
> For additional commands, e-mail: [EMAIL PROTECTED]
>
>
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
