package cn.edu.buaa.scse.liyi.network.test;

import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;

public class AdapterSocketClient
{
	private static Socket socket;
	private static ObjectInputStream objectInputStream;
	private static ObjectOutputStream objectOutputStream;
	private static Message message=null;
	
	public static String sendMsg(String msg)
	{
		String s=null;
		try
		{
			socket=new Socket("127.0.0.1",9090);
			System.out.println("The Server Connected!");
			message=new Message(msg);
			objectOutputStream=new ObjectOutputStream(socket.getOutputStream());
			objectInputStream=new ObjectInputStream(socket.getInputStream());
			objectOutputStream.writeObject(message);
			message=(Message)objectInputStream.readObject();
			System.out.println(message.toString());
			s=message.toString();
			objectOutputStream.writeObject(null);
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
		finally
		{
			try
			{
				objectInputStream.close();
				objectOutputStream.close();
				socket.close();
			}
			catch(IOException e)
			{
				e.printStackTrace();
			}
		}
		return s;
	}
	
	public static void main(String[] args)
	{
		String s=AdapterSocketClient.sendMsg("hello world!");
		System.out.println("echo:"+s);
	}
}