clientwithrr.java

来自「A byte comunication system made in java 」· Java 代码 · 共 30 行

import RequestReply.*;
import MessageMarshaller.*;
import Registry.*;
import Commons.Address;


public class ClientWithRR
{
	public static void main(String args[])
	{
		new Configuration();

                Address dest=Registry.instance().get("Server");

		Message msg= new Message("Client","How are you");

		Requestor r = new Requestor("Client");
		
		Marshaller m = new Marshaller();
			
		byte[] bytes = m.marshal(msg);

		bytes = r.deliver_and_wait_feedback(dest, bytes);
		
		Message answer = m.unmarshal(bytes);

		System.out.println("Client received message "+answer.data+" from "+answer.sender);
	}

}