android:id="@+id/send_1_button"
android:layout_width="fill_parent"android:layout_height="wrap_content"
android:text="send 1 request"/>

importjava.io.IOException;
importjava.io.InputStream;

importandroid.app.Activity;
importandroid.net.LocalServerSocket;
importandroid.net.LocalSocket;
importandroid.net.LocalSocketAddress;
importandroid.os.Bundle;
importandroid.os.Handler;
importandroid.util.Log;
importandroid.view.View;
importandroid.view.View.OnClickListener;
importandroid.widget.Button;
importandroid.widget.Toast;

/**
*
* @author Denis Migol
*
*/
publicclassDemoActivityextendsActivity{

publicstaticStringSOCKET_ADDRESS="your.local.socket.address";

// background threads use this Handler to post messages to
// the main application thread
privatefinalHandlerhandler=newHandler();

publicclassNotificationRunnableimplementsRunnable{
privateStringmessage=null;

publicvoidrun(){
if(message!=null&&message.length()>0){
showNotification(message);
}
}

/**
* @param message the message to set
*/
publicvoidsetMessage(Stringmessage){
this.message=message;
}
}

// post this to the Handler when the background thread notifies
privatefinalNotificationRunnablenotificationRunnable=newNotificationRunnable();

publicvoidshowNotification(Stringmessage){
Toast.makeText(this,message,Toast.LENGTH_SHORT).show();
}

classSocketListenerextendsThread{
privateHandlerhandler=null;
privateNotificationRunnablerunnable=null;

publicSocketListener(Handlerhandler,NotificationRunnablerunnable){
this.handler=handler;
this.runnable=runnable;
this.handler.post(this.runnable);
}

/**
* Show UI notification.
* @param message
*/
privatevoidshowMessage(Stringmessage){
this.runnable.setMessage(message);
this.handler.post(this.runnable);
}

@Override
publicvoidrun(){
//showMessage("DEMO: SocketListener started!");
try{
LocalServerSocketserver=newLocalServerSocket(SOCKET_ADDRESS);
while(true){
LocalSocketreceiver=server.accept();
if(receiver!=null){
InputStreaminput=receiver.getInputStream();

// simply for java.util.ArrayList
intreaded=input.read();
intsize=0;
intcapacity=0;
byte[]bytes=newbyte[capacity];

// reading
while(readed!=-1){
// java.util.ArrayList.Add(E e);
capacity=(capacity*3)/2+1;
//bytes = Arrays.copyOf(bytes, capacity);
byte[]copy=newbyte[capacity];
System.arraycopy(bytes,0,copy,0,bytes.length);
bytes=copy;
bytes[size++]=(byte)readed;

// read next byte
readed=input.read();
}

showMessage(newString(bytes,0,size));
}
}
}catch(IOExceptione){
Log.e(getClass().getName(),e.getMessage());
}
}
}

publicstaticvoidwriteSocket(Stringmessage)throwsIOException{
LocalSocketsender=newLocalSocket();
sender.connect(newLocalSocketAddress(SOCKET_ADDRESS));
sender.getOutputStream().write(message.getBytes());
sender.getOutputStream().close();
}

@Override
publicvoidonCreate(BundlesavedInstanceState){
super.onCreate(savedInstanceState);
setContentView(R.layout.main);

newSocketListener(this.handler,this.notificationRunnable).start();

Buttonsend1=(Button)findViewById(R.id.send_1_button);
send1.setOnClickListener(newOnClickListener(){

@Override
publicvoidonClick(Viewv){
try{
writeSocket("hello");
}catch(IOExceptione){
Log.e(getClass().getName(),e.getMessage());
}
}

});
}
}