THREADS - SOCKETS
Hi everybody. I have this problem:
i have a Thread class wich writtes in sockets to make a connection
with another class is waiting requests.The server classes transforms
xml to pdf files , the problem is that the process is too slow because
there are threads wich start another threads...so the operative system
put jobs in queues and all the process gets very slow . Maybe exists
another way to limit number of threads or that they wait between them
to optimice the use of processors...these are my classes....thank
you !!! im running on solaris 10 enviroment.
server classes :
package formatterservice;
import java.io.IOException;
import java.net.*;
/**
*
* @author adam
*/
public class Server {
/** Creates a new instance of Main */
public Server() {
}
/**
* @param args the command line arguments
*/
public static void main(String[] args) {
final int serverPort = 20202;
if (args.length >= 1) {
// try to set serverPort from an argument
}
long connNum = 0;
try {
ServerSocket ssock = new ServerSocket(serverPort);
System.out.println("server opened port: " + serverPort);
while (true) {
Socket sock = ssock.accept();
++connNum;
System.out.println("client " + connNum + " has
connected.");
OneConnection client = new OneConnection(sock,
connNum);
new Thread(client).start();
}
} catch (Exception ex) {
ex.printStackTrace();
}
}
}
/*
* OneConnection.java
*
* Created on April 4, 2008, 12:37 PM
*
* To change this template, choose Tools | Template Manager
* and open the template in the editor.
*/
package formatterservice;
import java.io.*;
import java.net.*;
import jp.co.antenna.XfoJavaCtl.*;
/**
*
* @author adam
*/
public class OneConnection implements Runnable {
Socket sock;
BufferedReader in = null;
BufferedWriter out = null;
final long connNum;
XfoObj axfo;
/** Creates a new instance of OneConnection */
public OneConnection(Socket sock, long connNum) throws Exception {
axfo = new XfoObj();
axfo.setExitLevel(4);
axfo.setStylesheetURI("91.xsl");
axfo.setOutputFilePath("result-" + connNum + ".pdf");
axfo.setExternalXSLT("Xalan -o %3 %1 %2");
this.sock = sock;
this.connNum = connNum;
in = new BufferedReader(new
InputStreamReader(sock.getInputStream()));
out = new BufferedWriter(new
OutputStreamWriter(sock.getOutputStream()));
}
public void run() {
try {
// Process with Formatter
String filename = in.readLine();
System.out.println(connNum + ": " + filename);
axfo.setDocumentURI(filename);
axfo.execute();
// out.write("result-" + connNum + ".pdf");
// out.write("\n\r");
// Close the socket
sock.close();
System.out.println(connNum + " finished.");
} catch (Exception e) {
e.printStackTrace();
}
}
}