Вот работающий примерчик:
Сервер:
| Код | package xml.net;
import org.xml.sax.*;
import org.xml.sax.helpers.DefaultHandler;
import javax.xml.parsers.*;
import java.io.IOException;
import java.net.*;
public class XMLServer
{
public static final int PORT = 7892;
public static void main(String[] args) throws Exception
{
ServerSocket serverSocket = new ServerSocket(PORT);
while(true)
{
Socket socket = serverSocket.accept();
System.out.println("Client from " + socket.getRemoteSocketAddress() + " connected");
new XMLNetParser(socket);
}
}
private static class XMLNetParser extends DefaultHandler implements Runnable
{
private Socket socket;
public XMLNetParser(Socket socket)
{
this.socket = socket;
Thread thread = new Thread(this, "XMLSocketListener");
thread.start();
}
public void startDocument() throws SAXException
{
System.out.println("Document start");
}
public void endDocument() throws SAXException
{
System.out.println("Document end");
}
public void startElement(String uri, String localName, String qName, Attributes attributes) throws SAXException
{
System.out.println("element '" + qName + "' start");
}
public void endElement(String uri, String localName, String qName) throws SAXException
{
System.out.println("element '" + qName + "' end");
}
public void characters(char ch[], int start, int length) throws SAXException
{
String str = new String(ch, start, length).trim();
System.out.println('"' + str + '"');
}
public void warning(SAXParseException e) throws SAXException
{
System.err.println("WARNING: " + e);
}
public void error(SAXParseException e) throws SAXException
{
System.err.println("ERROR: " + e);
}
public void fatalError(SAXParseException e) throws SAXException
{
System.err.println("FATAL ERROR: " + e);
}
public void run()
{
try
{
System.out.println("Starting parsing...");
SAXParser parser = SAXParserFactory.newInstance().newSAXParser();
parser.parse(socket.getInputStream(), this);
}
catch(Exception e)
{
e.printStackTrace();
}
try
{
socket.close();
}
catch(IOException e)
{
}
System.out.println("Connection to " + socket.getRemoteSocketAddress() + " closed");
socket = null;
}
}
} |
Клиент:
| Код | package xml.net;
import java.io.*;
import java.net.Socket;
public class XMLClent
{
public static void main(String[] args)
{
Socket socket = null;
try
{
socket = new Socket("localhost", XMLServer.PORT);
Writer writer = new OutputStreamWriter(socket.getOutputStream(), "UTF-8");
writer.write("<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n");
writer.write("<root>\n");
for(int i = 1; i <= 5; i++)
{
writeNode(writer, "Iteration " + i);
writer.flush();
Thread.sleep(10 * 1000);
}
writer.write("</root>\n");
writer.flush();
}
catch(Exception e)
{
e.printStackTrace();
}
try
{
if(socket != null)
socket.close();
}
catch(IOException e)
{
}
}
private static void writeNode(Writer writer, String text) throws IOException
{
writer.write(" <node>");
writer.write(text);
writer.write("</node>\n");
}
} |
|
