Subversion Repositories Projects

package dongfang.mkt.comm.tcp;

import java.io.IOException;

import java.io.InputStream;

import java.io.OutputStream;

import java.net.Socket;

import dongfang.mkt.comm.MKConnection;

public class MKTCPConnection implements MKConnection {

        private InputStream inputStream;

        private OutputStream outputStream;

        @Override

        public void init(String id) throws IOException {

                //URL url = new URL(id);

                Socket socket = new Socket("localhost", Integer.parseInt(id));

                inputStream = socket.getInputStream();

                outputStream = socket.getOutputStream();

        }

        @Override

        public InputStream getInputStream() throws IOException {

                return inputStream;

        }

        @Override

        public OutputStream getOutputStream() throws IOException {

                return outputStream;

        }

}