2

我尝试了许多不同的方式来通过服务器和客户端之间的套接字连接发送我的 xml 文档，而无需在发送后关闭套接字（保持输出流打开，以发送另一个文档）。我找到了几个声称它应该工作的网站，所以我尝试了他们建议的所有方式，但我没有找到一种有效的方式。（这描述了我想做的事情：http: //jaxb.java.net/guide/Designing_a_client_server_protocol_in_XML.html）

如果我在发送 (@code marsh.marshal(element, xsw);) 后关闭套接字，则以下代码可以完美运行，但是如果我尝试保持套接字打开，它会卡在服务器端的解组中。

客户端....

public void sendMessage(String message){
         JAXBContext jaxbContext;   
        try {
            jaxbContext = JAXBContext.newInstance("cdl.wizard.library");
            Marshaller marsh = jaxbContext.createMarshaller();
            marsh.setProperty(Marshaller.JAXB_FORMATTED_OUTPUT, true);
            marsh.setProperty(Marshaller.JAXB_SCHEMA_LOCATION, "http://www.example.org/WizardShema WizardsSchema.xsd");
            ObjectFactory of = new ObjectFactory();
                    // the Dataset is the root element of the xml document
            Dataset set = new Dataset("CONN01", "CONTR", "MCL01@localhost", "SV01@localhost:32000");
            CommandSet cmdSet = new CommandSet();
            Command cmd = new Command();
            cmd.setFunctionName("RegisterAs");
            Param p = new Param();
            p.setString("RemoteClient");
            cmd.addParameter(p);
            cmdSet.addCommand(cmd);
            set.setInstruction(cmdSet);
                    // creates a valid xml dataset, with startDocument, startElement...
            JAXBElement<Dataset> element = of.createData(set);
            XMLStreamWriter xsw = XMLOutputFactory.newInstance().createXMLStreamWriter(mOOS);
            marsh.marshal(element, xsw);
            xsw.flush();
        } catch (JAXBException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } catch (XMLStreamException e) {
            e.printStackTrace();
        } catch (FactoryConfigurationError e) {
            e.printStackTrace();
        }

服务器端....

private void handleMessage() {
        JAXBContext jaxbContext;
        try {
            jaxbContext = JAXBContext.newInstance("cdl.wizard.library") ;
            Unmarshaller um = jaxbContext.createUnmarshaller();
            XMLInputFactory xmlif = XMLInputFactory.newInstance();
            // XMLEventReader xmlr = xmlif.createXMLEventReader(mOIS);
            XMLStreamReader xmlr = xmlif.createXMLStreamReader(mOIS, "UTF8");
            // move to the root element and check its name.
            xmlr.nextTag();
            System.out.println("TagName:" + xmlr.getLocalName());
            xmlr.require(START_ELEMENT, null, "Data");

            JAXBElement<Dataset> obj = um.unmarshal(xmlr, Dataset.class);
            Dataset set = obj.getValue();
            System.out.println("ID:"+ set.getID());

        } catch (JAXBException e) {
            e.printStackTrace();
        } catch (XMLStreamException e) {
            e.printStackTrace();
        } catch (FactoryConfigurationError e) {
            e.printStackTrace();
        }
    }
4

0 回答 0