Probleme: Senden und Empfangen von Daten

Question

Ich versuche, zwei Prozesse mit Bean durchzuführen, ist mein Problem, dass ich nicht finden kann, wie diese Prozesse kontinuierlich ausgeführt werden. Der erste Prozess ist das Senden eines Objekts und der zweite Prozess ist die Antwort des Objekts.

Ich stelle mir vor, dass mit dem Code meine Frage klarer wird.

Answer 1

versuchen Synchronisierte auf Ihre Methoden hinzufügen

ich diese Probleme oft hatte, weil der Empfänger versucht, etwas zu lesen, die nicht

Mehr Informationen im javadoc beendet ist: https://docs.oracle.com/javase/tutorial/essential/concurrency/syncmeth.html

, wenn Sie Fügen Sie dieses Schlüsselwort zu den Methoden hinzu, die auf den anderen warten, bis es fertig ist

Answer 2

danke maquina,

diese

ist die Lösung:

@Component 
public class Proceso implements InitializingBean{ 
    private static final String XML_SCHEMA_LOCATION = "/proceso/model/schema/proceso.xsd"; 
    private Envio envio; 
    private Respuesta respuesta; 

    public synchronized void Proceso_envio(Proceso proceso, OutputStream outputstream) throws JAXBException{ 
     envio.marshal(proceso, outputstream);} 

    public void synchronized Proceso_respuesta(InputStream inputstream) throws JAXBException, FileNotFoundException{ 
    Object obj = unmarshaller.unmarshal(inputStream); 
    return (Proceso_respuesta) obj;} 

    @Override 
    public void afterPropertiesSet() throws Exception{ 
     SchemaFactory schemaFactory = SchemaFactory.newInstance(XMLConstants.W3C_XML_SCHEMA_NS_URI); 
     Schema schema = schemaFactory.newSchema(getClass().getResource(XML_SCHEMA_LOCATION)); 
     JAXBContext jc = JAXBContext.newInstance(Envio.class, Respuesta.class); 

     this.marshaller = jc.createMarshaller(); 
     this.marshaller.setProperty(Marshaller.JAXB_FORMATTED_OUTPUT, true); 
     this.marshaller.setProperty(Marshaller.JAXB_ENCODING, StandardCharsets.UTF_8.displayName()); 
     this.marshaller.setSchema(schema); 

     this.unmarshaller = jc.createUnmarshaller(); 

     this.unmarshaller.setSchema(schema); 
    }