Socket Programming

b3n_hysteria · by **b3n_hysteria** » Thu May 07, 2009 1:54 pm

hai.. ok,
i have been try source from qamerfarooq

i'm use in 1 computer,
but nothing happen..

this my list source

Server :
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;

public class TCPDesktopServer implements Runnable{

/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
new Thread(new TCPDesktopServer()).start();
}

public void run() {
// TODO Auto-generated method stub
try {
System.out.println("S: Connecting...");
ServerSocket serverSocket = new ServerSocket(8221);
while (true) {
Socket client = serverSocket.accept();
System.out.println("S: Receiving...");

try {

BufferedReader in = new BufferedReader(new InputStreamReader(client.getInputStream()));
String str = in.readLine();
System.out.println("S: Received: '" + str + "'");

} catch(Exception e) {
System.out.println("S: Error");
e.printStackTrace();

} finally {
client.close();
System.out.println("S: Done.");
}
}

} catch (IOException e) {
// TODO Auto-generated catch block
System.out.println("S: Error");
e.printStackTrace();
}
}

}

Client :

the manifest :
<?xml version="1.0" encoding="utf-8" ?>
<manifest xmlns:android="http://schemas.android.com/apk/res/android" package="socket.desktop" android:versionCode="1" android:versionName="1.0.0">
<application android:icon="@drawable/icon" android:label="@string/app_name">
<activity android:name=".socket" android:label="@string/app_name">
<intent-filter>
<action android:name="android.intent.action.MAIN" />
<category android:name="android.intent.category.LAUNCHER" />
</intent-filter>
</activity>
</application>
<uses-permission android:name="android.permission.INTERNET" />
</manifest>

import java.io.BufferedWriter;
import java.io.IOException;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;

import android.app.Activity;
import android.os.Bundle;
import android.util.Log;

public class socket extends Activity {
/** Called when the activity is first created. */
@Override
public void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.main);
connectSocket();
}

private void connectSocket() {
// TODO Auto-generated method stub
try {
InetAddress serverAddr = InetAddress.getByName("127.0.0.1");//10.66.3.44 is my pc' IP
Log.d("TCP", "C: Connecting...");
Socket socket = new Socket(serverAddr, 8221);
String message = "Hello from Client android emulator";
try {
Log.d("TCP", "C: Sending: '" + message + "'");
PrintWriter out = new PrintWriter( new BufferedWriter( new OutputStreamWriter(socket.getOutputStream())),true);

out.println(message);
Log.d("TCP", "C: Sent.");
Log.d("TCP", "C: Done.");

} catch(Exception e) {
Log.e("TCP", "S: Error", e);
} finally {
socket.close();
}

} catch (UnknownHostException e) {
// TODO Auto-generated catch block
Log.e("TCP", "C: UnknownHostException", e);
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
Log.e("TCP", "C: IOException", e);
e.printStackTrace();
}

}
}

and last :
package socket.desktop;
import java.io.BufferedWriter;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.Socket;

import android.util.Log;

public class TCPClient implements Runnable {

String message = "aaaaaaaa";
public void run() {
message = "haseum";
try {
InetAddress serverAddr = InetAddress.getByName("localhost");
Log.d("TCP", "C: Connecting...");
Socket socket = new Socket(serverAddr, 4444);
message = "bbbbb";

try {
Log.d("TCP", "C: Sending: '" + message + "'");
PrintWriter out = new PrintWriter( new BufferedWriter( new OutputStreamWriter(socket.getOutputStream())),true);
out.println(message);
Log.d("TCP", "C: Sent.");
Log.d("TCP", "C: Done.");
message = "cccccc";

} catch(Exception e) {
Log.e("TCP", "S: Error", e);

} finally {
socket.close();
}

} catch (Exception e) {
Log.e("TCP", "C: Error", e);
}
}
public String a(){
return message;
}
}

please help me to undrestand.. give me your suggetion, or argument..
this for my TA.. my final exam... T_T

blowfish08 · by **blowfish08** » Mon Jun 01, 2009 1:04 am

qamerfarooq wrote:
GeorgieYuan wrote:
Hi all,

I found that when the Server is an Android Server, the socket communication(TCP/UDP) will be failed, any suggestion on this issue?

Regards.

In case your server is on Android then you need to follow the following steps to make your server available on network:

1- Lets say your server is listening on port number 6100 in android.

2- Forward the ports using the following command, so you can connect to android from localhost

Code: Select all
adb forward tcp:6100 tcp:6100

3- Now you can connect to this port from localhost but not from the network, it means you can connect using localhost:6100 from your desktop computer but not with the IP (192.168.0.1:6100 )

telnet localhost 6100 OK
telnet 192.168.0.1 6100 Failed
4- An extra step is needed for network access.
Use some proxy server which can listen on 192.168.0.140:6100 and forward the data to localhost:6100 (which is your android server)

Very nice tutorial, however Android development guide suggests not to use the adb tool to redir ports because there is no way to delete them. I found this one very useful.

Code: Select all: http://developer.android.com/guide/developing/tools/emulator.html#emulatornetworking

At least it worked for me

PS. Sorry for the code but I couldn't post the link because this is my first post.

donalduck0304 · by **donalduck0304** » Wed Oct 21, 2009 10:16 am

Can u tell more detailed

I really want to make Android Server and Android Client on 2 emulators. But I don't know how to do. Please help me :cry:

Annapurna · by **Annapurna** » Sun Nov 08, 2009 9:02 am

Hi,
I have tried the post posted client server program , On my host pc I wrote server program and on android client program.
server.
[syntax="java"]import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;

public class TCPDesktopServer implements Runnable{

public static final String SERVERIP = "127.0.0.1";
public static final int SERVERPORT = 4445;

public void run() {
try {
System.out.println("S: Connecting...");
ServerSocket serverSocket = new ServerSocket(SERVERPORT);
while (true) {
Socket client = serverSocket.accept();
System.out.println("S: Receiving...");

try {

BufferedReader in = new BufferedReader(new InputStreamReader(client.getInputStream()));
String str = in.readLine();
System.out.println("S: Received: '" + str + "'");

} catch(Exception e) {
System.out.println("S: Error");
e.printStackTrace();

} finally {
client.close();
System.out.println("S: Done.");
}
}
} catch (Exception e) {
System.out.println("S: Error");
e.printStackTrace();
}
}

public static void main (String a[]) {

Thread desktopServerThread = new Thread(new TCPDesktopServer());
desktopServerThread.start();
}
}

client(on android)

for socket:

package com.android.SocketTest;

import android.app.Activity;
import android.os.Bundle;

public class SocketTest extends Activity {
/** Called when the activity is first created. */
@Override
public void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.main);
}
}

package com.android.SocketTest;

import java.io.BufferedWriter;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.Socket;

import android.util.Log;

public class TCPClient implements Runnable {

public void run() {
try {
InetAddress serverAddr = InetAddress.getByName("10.64.18.178");// Ip of my desktop.
Log.d("TCP", "C: Connecting...");
Socket socket = new Socket(serverAddr, 4445);
String message = "Hello from Client android emulator";

try {
Log.d("TCP", "C: Sending: '" + message + "'");
PrintWriter out = new PrintWriter( new BufferedWriter( new OutputStreamWriter(socket.getOutputStream())),true);
out.println(message);
Log.d("TCP", "C: Sent.");
Log.d("TCP", "C: Done.");

} catch(Exception e) {
Log.e("TCP", "S: Error", e);

} finally {
socket.close();
}

} catch (Exception e) {
Log.e("TCP", "C: Error", e);
}
}
}

Androidmanifest.xml is

[syntax="xml"]
<?xml version="1.0" encoding="utf-8"?>
<manifest xmlns:android="http://schemas.android.com/apk/res/android"
package="com.android.SocketTest"
android:versionCode="1"
android:versionName="1.0.0">
<application android:icon="@drawable/icon" android:label="@string/app_name">
<activity android:label="@string/app_name" android:name="SocketTest">
<intent-filter>
<action android:name="android.intent.action.MAIN" />
<category android:name="android.intent.category.LAUNCHER" />
</intent-filter>
</activity>
<uses-permission android:name="android.permission.INTERNET" />
</application>
</manifest>

problem: The client couldn't able to send the massage to server. Server is running properly but it is not showing the massage from client.
Please help me . It is so much urgent for me.

Thanks to all.

Sapientum · by **Sapientum** » Tue Nov 24, 2009 4:16 pm

Hey guys,

First of all, I'm not very experienced with Android or network communication, only just began, so some of my questions might be very simple

I'm trying to develop a small app that will send a string/integer from an Android Phone to a PC, so I've been looking at getting the code from this post to work...
I've come to the point where the code executes without error messages, but I don't seem to receive anything in the Android emulator... The app opens on the emulator, but then nothing else happens.

I'm not quite sure whether the problem is port- or execution-based.
I'm compiling/running all the code directly from Eclipse, but is that the proper method for testing it? I'm not sure if some of the code(the server?) should be run differently, and only the client be run from Eclipse?

Or is the problem most likely port-based? That the port isn't forwarded?

Also, like I mentioned, I need the client to run on a phone afterwards, and I've noticed that in many other discussions(like Bluetooth) people seem to have had problems with running apps on a HTC Hero... Is this also the case with TCP-communication?

zizo · by **zizo** » Fri Nov 27, 2009 2:47 am

Hello!
I'm trying to do a chat application. I have a android app and a windows mobile application running in the same pc and i want to put the two comunicating with each other. Sometimes i put one being the client and other the server and another times vice-versa. It's suposed to be able to receive and send messages both in server and in client.

My windows app is fine because was tested many times before. I can't put the android app on when i run it being the server and i can't connect with the wm server when android is the client. android app freezes in the if next to the creation of the client socket saying that the socket is null(not created - nullpointerexception).

In the end i put the wm app just in case...
First i put the android eclipse app.
Help me.

Cumps

Syntax: [ Download ] [ Hide ]

Using java Syntax Highlighting

package com.android.chat;
 
import java.io.BufferedReader;
 
import java.io.IOException;
 
import java.io.InputStream;
 
import java.io.InputStreamReader;
 
import java.io.OutputStream;
 
import java.io.PrintWriter;
 
import java.net.InetAddress;
 
import java.net.ServerSocket;
 
import java.net.Socket;
 
import java.net.UnknownHostException;
 
import android.app.Activity;
 
import android.os.Bundle;
 
import android.os.Handler;
 
import android.os.Message;
 
import android.view.View;
 
import android.view.View.OnClickListener;
 
import android.widget.Button;
 
import android.widget.EditText;
 
import android.widget.ListView;
 
import android.widget.TextView;
 
public class Chat extends Activity implements OnClickListener {
 
  private EditText etChat;
 
  private EditText etInfos;
 
  private Button bEnviar;
 
  private Button bDesligar;
 
  private Button bLigarServer;
 
  private Button bLigarClient;
 
  private ListView lvConversa;
 
  private TextView tvChat;
 
  private boolean isServer = false;
 
  private boolean isClient = false;
 
  //cliente
 
  Socket socketCliente;
 
  String hostIpServidor;
 
  int portoServidor;
 
  PrintWriter outClient;
 
  TCPClient tcpclient;
 
  //Servidor
 
  int portoEscutaGeral;
 
  ServerSocket socketGeralServidor;
 
  PrintWriter outServer;
 
  TCPServer tcpserver;
 
  /** Called when the activity is first created. */
 
  @Override
 
  public void onCreate(Bundle savedInstanceState) {
 
    super.onCreate(savedInstanceState);
 
    setContentView(R.layout.main);
 
    etChat = (EditText)findViewById(R.id.EditText01);
 
    etInfos = (EditText)findViewById(R.id.EditText02);
 
    lvConversa = (ListView)findViewById(R.id.ListView01);
 
    tvChat = (TextView)findViewById(R.id.TextView01);
 
    bEnviar = (Button)findViewById(R.id.Button01);
 
    bEnviar.setOnClickListener((OnClickListener)this);
 
    bDesligar = (Button)findViewById(R.id.Button02);
 
    bDesligar.setOnClickListener((OnClickListener)this);
 
    bLigarServer = (Button)findViewById(R.id.Button03);
 
    bLigarServer.setOnClickListener((OnClickListener)this);
 
    bLigarClient = (Button)findViewById(R.id.Button04);
 
    bLigarClient.setOnClickListener((OnClickListener)this);
 
  }
 
  private Handler handlerCliente = new Handler() {
 
    public void handleMessage(Message msg) {
 
      // processar mensagem
 
      if (msg.what == 0) {
 
        tvChat.append("Servidor diz: " + (String)msg.obj);
 
      }
 
    }
 
  };
 
  Handler handlerServidor = new Handler() {
 
    public void handleMessage(Message msg) {
 
      // processar mensagem
 
      if (msg.what == 0){
 
        tvChat.append("Cliente diz: " + (String)msg.obj);
 
      }
 
    }
 
  };
 
  public void onClick(View v) {
 
    switch(v.getId()){
 
    case R.id.Button01:
 
      try {
 
        if (isClient){
 
          //desligarCliente();
 
          socketCliente.close();
 
          isClient = false;
 
        }
 
        else if (isServer){
 
          //desligarServidor();//só fecha socket que o servidor tinha aberta para este cliente
 
          tcpserver.getSocketServerCliente().close();
 
          isServer = false;
 
        } 
 
      }catch (IOException ioe) {
 
        ioe.printStackTrace();
 
      }
 
      break;
 
    case R.id.Button02:
 
      try {
 
        if (isClient) {
 
          outClient = new PrintWriter(socketCliente.getOutputStream(), true);
 
          outClient.println(etChat.getText().toString() + "\n");
 
        }
 
        else if (isServer){
 
          outServer = new PrintWriter(tcpserver.getSocketServerCliente().getOutputStream(), true);
 
          outServer.println(etChat.getText().toString() + "\n");
 
        }
 
      }
 
      catch (IOException ioe) {
 
        ioe.printStackTrace();
 
      }
 
      break;
 
    case R.id.Button03:    
 
      isServer = true;
 
      //lerDadosServidor();
 
      portoEscutaGeral = Integer.parseInt(etInfos.getText().toString());
 
      //ligarServidor();
 
      try {
 
        socketGeralServidor = new ServerSocket(portoEscutaGeral);
 
        socketGeralServidor.bind(socketGeralServidor.getLocalSocketAddress(), 10);
 
        //receberInfoServidor()
 
        tcpserver = new TCPServer(socketGeralServidor, handlerServidor);
 
        Thread threadServer = new Thread(tcpserver);
 
        threadServer.start();
 
      }
 
      catch (IOException ioe) {
 
        ioe.printStackTrace();
 
      }
 
      break;
 
    case R.id.Button04:
 
      isClient = true;
 
      //lerDadosCliente();
 
      String[] meu = etInfos.getText().toString().split(":");
 
      hostIpServidor = meu[0];
 
      portoServidor = Integer.parseInt(meu[1]);
 
      //ligarCliente();
 
      try {
 
        InetAddress serverAddr = InetAddress.getByName(hostIpServidor);
 
        socketCliente = new Socket(serverAddr, portoServidor/*"10.101.226.2", 4444*/); 
 
      } catch (UnknownHostException e) {
 
        e.printStackTrace();
 
      } catch (IOException e) {
 
        e.printStackTrace();
 
      }
 
      if(socketCliente.isConnected()){
 
        // o socket do cliente esta pronto para enviar e receber mensagens
 
      }
 
      //receberInfoCliente();
 
      tcpclient = new TCPClient(socketCliente, handlerCliente);
 
      Thread threadClient = new Thread(tcpclient);
 
      threadClient.start();
 
      break;
 
    }
 
  }
 
}
Parsed in 0.053 seconds,  using GeSHi 1.0.8.4

Syntax: [ Download ] [ Hide ]

Using java Syntax Highlighting

package com.android.chat;
 
import java.io.BufferedReader;
 
import java.io.IOException;
 
import java.io.InputStreamReader;
 
import java.net.Socket;
 
import android.os.Handler;
 
import android.os.Message;
 
public class TCPClient implements Runnable {
 
  Socket socketCliente;
 
  Handler handler;
 
  public TCPClient(Socket socketCliente, Handler handler) {
 
    this.socketCliente = socketCliente;
 
    this.handler = handler;
 
  }
 
  @Override
 
  public void run() {
 
    char[] line = new char[100];
 
    BufferedReader in = null;
 
    try {
 
      in = new BufferedReader(new InputStreamReader(socketCliente.getInputStream()));
 
      while (true) {
 
        line = new char[100];
 
        in.read(line, 0, 100);
 
        if (line.length > 0) {
 
          String msg = new String(line);
 
          // processar a mensagem
 
          Message lmsg = new Message();
 
          lmsg.what = 0;
 
          lmsg.obj = msg;
 
          handler.sendMessage(lmsg);
 
        }
 
      }
 
    } catch (IOException e) {
 
      e.printStackTrace();
 
    }
 
  }
 
}
Parsed in 0.035 seconds,  using GeSHi 1.0.8.4

Syntax: [ Download ] [ Hide ]

Using java Syntax Highlighting

package com.android.chat;
 
import java.io.BufferedReader;
 
import java.io.IOException;
 
import java.io.InputStreamReader;
 
import java.net.ServerSocket;
 
import java.net.Socket;
 
import android.os.Handler;
 
import android.os.Message;
 
/**
 
 * Faz a leitura do lado do servidor.
 
 * @author Celso
 
 *
 
 */
 
public class TCPServer implements Runnable {
 
  Handler handlerServidor;
 
  ServerSocket socketGeralServidor;
 
  Socket socketServerCliente;//socket do lado do servidor para falar com este cliente
 
  public TCPServer(ServerSocket socketGeralServidor, Handler handlerServidor) {
 
    this.socketGeralServidor = socketGeralServidor;
 
    this.handlerServidor = handlerServidor;
 
  }
 
  @Override
 
  public void run() {
 
    try {
 
      while(true){
 
        socketServerCliente = socketGeralServidor.accept();//bloqueia até ligação com novo cliente seja estabelecida
 
        if (socketServerCliente != null)
 
        {
 
          if (socketServerCliente.isConnected())
 
          {
 
            // ligacao estabelecida
 
          }
 
        }      
 
        char[] line = new char[100];
 
        BufferedReader in = new BufferedReader(new InputStreamReader(socketServerCliente.getInputStream()));
 
        while (true) {
 
          line = new char[100];
 
          in.read(line, 0, 100);
 
          if (line.length > 0) {
 
            String msg = new String(line);
 
            // processar a mensagem
 
            Message lmsg = new Message();
 
            lmsg.what = 0;
 
            lmsg.obj = msg;
 
            handlerServidor.sendMessage(lmsg);
 
          }
 
        }
 
      } 
 
    } catch (IOException ioe) {
 
      ioe.printStackTrace();
 
    } 
 
  }
 
  public Socket getSocketServerCliente(){
 
    return socketServerCliente;
 
  }
 
}
 
Parsed in 0.040 seconds,  using GeSHi 1.0.8.4

Syntax: [ Download ] [ Hide ]

Using xml Syntax Highlighting

<?xml version="1.0" encoding="utf-8"?>
 
<manifest xmlns:android="http://schemas.android.com/apk/res/android"
 
      package="com.android.chat"
 
      android:versionCode="1"
 
      android:versionName="1.0">
 
      <uses-permission android:name="android.permission.INTERNET" />
 
    <application android:icon="@drawable/icon" android:label="@string/app_name">
 
        <activity android:name=".Chat"
 
                  android:label="@string/app_name">
 
            <intent-filter>
 
                <action android:name="android.intent.action.MAIN" />
 
                <category android:name="android.intent.category.LAUNCHER" />
 
            </intent-filter>
 
        </activity>
 
    </application>
 
</manifest> 
Parsed in 0.003 seconds,  using GeSHi 1.0.8.4

Syntax: [ Download ] [ Hide ]

Using xml Syntax Highlighting

<?xml version="1.0" encoding="utf-8"?>
 
<TextView xmlns:android="http://schemas.android.com/apk/res/android"
 
        android:id="@+id/TextView01" android:layout_width="wrap_content"
 
        android:layout_height="wrap_content"></TextView>
 
Parsed in 0.001 seconds,  using GeSHi 1.0.8.4

Syntax: [ Download ] [ Hide ]

Using xml Syntax Highlighting

<?xml version="1.0" encoding="utf-8"?>
 
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
 
    android:orientation="vertical"
 
    android:layout_width="fill_parent"
 
    android:layout_height="fill_parent">
 
        <ListView android:id="@+id/ListView01" 
 
                android:layout_height="200dip" 
 
                android:layout_width="fill_parent">
 
                </ListView>
 
        <EditText android:id="@+id/EditText01" 
 
                android:layout_width="200dip" 
 
                android:layout_height="40dip"></EditText>
 
        <Button android:id="@+id/Button01" 
 
                android:text="Enviar" 
 
                android:layout_height="40dip" 
 
                android:layout_width="120dip" 
 
                android:layout_marginLeft="200dip" 
 
                android:layout_marginTop="-41dip"></Button>
 
        <EditText android:id="@+id/EditText02" 
 
                android:layout_width="200dip" 
 
                android:layout_height="40dip"></EditText>
 
        <Button android:id="@+id/Button02" 
 
                android:layout_width="120dip" 
 
                android:layout_marginTop="-41dip" 
 
                android:layout_marginLeft="200dip" 
 
                android:layout_height="40dip" 
 
                android:text="Desligar"></Button>
 
        <Button android:id="@+id/Button03" 
 
                android:text="Ligar-se como servidor" 
 
                android:layout_height="40dip" 
 
                android:layout_width="175dip"></Button>
 
        <Button android:id="@+id/Button04" 
 
                android:text="Ligar-se como cliente" 
 
                android:layout_height="40dip" 
 
                android:layout_width="175dip"></Button>
 
</LinearLayout>
Parsed in 0.005 seconds,  using GeSHi 1.0.8.4

Syntax: [ Download ] [ Hide ]

Using java Syntax Highlighting

using System;
 
using System.Linq;
 
using System.Collections.Generic;
 
using System.ComponentModel;
 
using System.Data;
 
using System.Net;
 
using System.Net.Sockets;
 
using System.Drawing;
 
using System.Text;
 
using System.Windows.Forms;
 
namespace ex1g4 {
 
    public partial class Form1 : Form {
 
        private Socket temp;
 
        private EndPoint client_EndPoint;
 
        private Socket server_listenSocket;
 
        private Socket client_Socket;
 
        private bool isServer;
 
        public Form1() {
 
            InitializeComponent();
 
        }
 
        private void button1_Click(object sender, EventArgs e) {
 
            isServer = false;
 
            try {
 
                char[] arr = { ':' };
 
                String[] meu = textBoxIp.Text.Split(arr);
 
                int porto = int.Parse(meu[1]);
 
                client_EndPoint = new IPEndPoint(IPAddress.Parse(meu[0]),
 
                                                     Convert.ToInt16(porto));
 
            } catch (FormatException) {
 
                MessageBox.Show("Invalid IP address entered - needs n.n.n.n, for example 192.168.0.103");
 
                return;
 
            }
 
            try {
 
                client_Socket = new Socket(AddressFamily.InterNetwork,
 
                              SocketType.Stream,
 
                              ProtocolType.Tcp);
 
                client_Socket.Connect(client_EndPoint);
 
            } catch (SocketException) {
 
                MessageBox.Show("Não é possível estabelecer a ligação");
 
                return;
 
            }
 
            textBoxWriteMsg.Enabled = true;
 
            textBoxReadMsg.Enabled = true;
 
            buttonEnviar.Enabled = true;
 
            buttonDesligar.Enabled = true;
 
            buttonLigar.Enabled = false;
 
            buttonLancarServer.Enabled = false;
 
            textBoxIp.Enabled = false;
 
            System.Threading.ThreadStart ts = new System.Threading.ThreadStart(receiveLoop);
 
            System.Threading.Thread t1 = new System.Threading.Thread(ts);
 
            t1.Start();
 
        }
 
        public void receiveLoop() {
 
            if (isServer) {
 
                while (true) {
 
                    //textBoxIp.Text += "while ";
 
                    try {
 
                        temp = server_listenSocket.Accept();
 
                        textBoxWriteMsg.Enabled = true;
 
                        textBoxReadMsg.Enabled = true;
 
                        buttonEnviar.Enabled = true;
 
                    } catch (ObjectDisposedException) {
 
                        return;
 
                    }
 
                    try {
 
                        Byte[] l_Buffer;
 
                        string l_receivedString;
 
                        while (temp.Connected) {
 
                            l_Buffer = new Byte[100];
 
                            int received = temp.Receive(l_Buffer, l_Buffer.Length, SocketFlags.None);
 
                            l_receivedString = System.Text.Encoding.UTF8.GetString(l_Buffer, 0, received);
 
                            myDelegate updateDelegate = new myDelegate(updateMessageLog); // updateMessageLog é a funcao noutra thread que processa a string recebida
 
                            updateDelegate(l_receivedString); // passagem da string para a funcao updateMessageLog atraves de um delegado 
 
                        }
 
                    } catch (System.Exception) {
 
                        if (temp != null)
 
                            temp.Close(); // fecha os sockets do cliente e do servidor
 
                    }
 
                    textBoxWriteMsg.Enabled = false;
 
                    textBoxReadMsg.Enabled = false;
 
                    buttonEnviar.Enabled = false;
 
                }
 
            } else {
 
                temp = client_Socket;
 
                try {
 
                    Byte[] l_Buffer;
 
                    string l_receivedString;
 
                    while (temp.Connected) {
 
                        l_Buffer = new Byte[100];
 
                        int received = temp.Receive(l_Buffer, l_Buffer.Length, SocketFlags.None);
 
                        l_receivedString = System.Text.Encoding.UTF8.GetString(l_Buffer, 0, received);
 
                        myDelegate updateDelegate = new myDelegate(updateMessageLog); // updateMessageLog é a funcao noutra thread que processa a string recebida
 
                        updateDelegate(l_receivedString); // passagem da string para a funcao updateMessageLog atraves de um delegado 
 
                    }
 
                } catch (System.Exception) {
 
                    if (temp != null)
 
                        temp.Close(); // fecha os sockets do cliente e do servidor
 
                }
 
            }
 
        }
 
        public delegate void myDelegate(String str);
 
        public void updateMessageLog(String str) {
 
            textBoxReadMsg.Text += "Remoto diz:\r\n" + str + "\r\n";
 
        }
 
        private void button2_Click(object sender, EventArgs e) {
 
            buttonLancarServer.Enabled = false;
 
            textBoxIp.Enabled = false;
 
            buttonLigar.Enabled = false;
 
            isServer = true;
 
            server_listenSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
 
            try {
 
                server_listenSocket.Bind(new IPEndPoint(IPAddress.Any, 4444));
 
            } catch (SocketException) {
 
                MessageBox.Show("Já existe um servidor neste porto");
 
                Application.Exit();
 
            }
 
            server_listenSocket.Listen((int)SocketOptionName.MaxConnections);
 
            System.Threading.ThreadStart ts = new System.Threading.ThreadStart(receiveLoop);
 
            System.Threading.Thread t1 = new System.Threading.Thread(ts);
 
            t1.Start();
 
        }
 
        private void buttonEnviar_Click(object sender, EventArgs e) {
 
            if (!isServer) {
 
                client_Socket.Send(Encoding.UTF8.GetBytes(textBoxWriteMsg.Text));
 
            } else {
 
                temp.Send(Encoding.UTF8.GetBytes(textBoxWriteMsg.Text));
 
            }
 
            textBoxReadMsg.Text += "Local diz: \r\n" + textBoxWriteMsg.Text + "\r\n";
 
            textBoxWriteMsg.Text = "";
 
        }
 
        private void buttonDesligar_Click(object sender, EventArgs e) {
 
            if (client_Socket != null)
 
                client_Socket.Close();
 
            if (temp != null)
 
                temp.Close();
 
            if (!isServer) {
 
                textBoxWriteMsg.Enabled = false;
 
                textBoxReadMsg.Enabled = false;
 
                buttonEnviar.Enabled = false;
 
                buttonLigar.Enabled = true;
 
                textBoxIp.Enabled = true;
 
                buttonDesligar.Enabled = false;
 
                buttonLancarServer.Enabled = true;
 
            }
 
        }
 
        private void Form1_Closing(object sender, CancelEventArgs e) {
 
            if (isServer) {
 
                try {
 
                    if (server_listenSocket != null) {
 
                        server_listenSocket.Close();
 
                    }
 
                } catch (Exception) {
 
                }
 
            } else {
 
                if (client_Socket != null)
 
                    client_Socket.Close();
 
            }
 
        }
 
        private void Form1_Load(object sender, EventArgs e) {
 
            buttonEnviar.Enabled = false;
 
            textBoxWriteMsg.Enabled = false;
 
            textBoxReadMsg.Enabled = false;
 
            buttonDesligar.Enabled = false;
 
        }
 
    }
 
}
Parsed in 0.065 seconds,  using GeSHi 1.0.8.4

Laurid · by **Laurid** » Mon Jan 25, 2010 1:06 am

Hi, I'm working with the tcp example from qamerfarooq. I have an EchoServer running on my Desktop and I'm testing direktly on my Device.
It's working great. Thanks for that!!

Now I wanted to modify the code a little bit, that I'm able to change the text which is send.

In the TCPClient-Class I added a simple "test" function:

Syntax: [ Download ] [ Hide ]

Using java Syntax Highlighting

package de.lauridmeyer.egocontrol;
public class TCPClient implements Runnable {
 
    public static final String SERVERIP = "192.168.0.6";//192.168.0.6
    public static final int SERVERPORT = 6200;
    PrintWriter out;
    String message = "Hello from Client!!";
    
    public TCPClient(){
        
    }
    
    public void test(){
        message ="TESTEST";
        Log.d("TCP", "C: Sending: '" + message + "'");
        out.println(message);
    
    }
        
    public void run() {
         try {
                 
                 InetAddress serverAddr = InetAddress.getByName(SERVERIP);//TCPServer.SERVERIP
                 
                 Log.d("TCP", "C: Connecting...");
                 Socket socket = new Socket(serverAddr, SERVERPORT);
                
                     try {
                         Log.d("TCP", "C: Sending: '" + message + "'");
                         out = new PrintWriter( new BufferedWriter( new OutputStreamWriter(socket.getOutputStream())),true);
                         
                         out.println(message);
                         Log.d("TCP", "C: Sent.");
                     Log.d("TCP", "C: Done.");
                     test();
                         
             } catch(Exception e) {
                 Log.e("TCP", "S: Error", e);
                      } finally {
                        //socket.close();
                      }
         } catch (Exception e) {
              Log.e("TCP", "C: Error", e);
         }
    }
}
 
Parsed in 0.042 seconds,  using GeSHi 1.0.8.4

When I execute this function from the TCP Client Class it works. (See line after "C:Done")

Now I tried executing it from the SocketTest (activity)

Syntax: [ Download ] [ Hide ]

Using java Syntax Highlighting

import android.app.Activity;
import android.os.Bundle;
 
public class SocketTest extends Activity {
        private TCPClient tcpclient;
        
    public void onCreate(Bundle icicle) {
        super.onCreate(icicle);
        setContentView(R.layout.main);
       
 
        Thread cThread = new Thread(new TCPClient());
          cThread.start();
          
         tcpclient.test();
    }
}
Parsed in 0.036 seconds,  using GeSHi 1.0.8.4

I get an Error Mesage on my device:
Sorry! The application TCPConnection (prozess com ....test) has stopped unexpectedly. Please try again.

What am I doing wrong?

Thanks a lot for your efforts!!

zuper · by **zuper** » Tue Feb 23, 2010 1:59 pm

Hello everyone!

Does exist alternatives of Socket on TCP communication between a Client Android and a Server Android or PC? Maybe RMI, corba or other strange protocols(I need Object transmission between Client & Server so i think that HTTP is not for me)?

Thanks to everyone

kaziu · by **kaziu** » Thu Feb 25, 2010 6:37 pm

Hello

I would like to know if it is possible to use Android client and C++ server to communicate via TCP protocol. Did someone do something like this?

Laurid · by **Laurid** » Tue Mar 02, 2010 8:16 am

Does nobody has a solution for my problem??

roysamuel · by **roysamuel** » Mon May 10, 2010 8:24 am

Hi..
I am setting up the client on the android and the server on my desktop PC.
After setting up the code, running the code returned

C: Connecting
C: error

on logcat.

However, after the change in the manifest file as mentioned in the post by zhufan

zhufan wrote::D ,I sovle the problem,
the modfication is necessary in the android.Manifest.xml,
<uses-permission android:name="android.permission.INTERNET" />

It worked.

The code needs to be changed like so : (this is mentioned in a prev. post....)

Code: Select all: <?xml version="1.0" encoding="utf-8"?> <manifest xmlns:android="http://schemas.android.com/apk/res/android" package="com.android.TCP" android:versionCode="1" android:versionName="1.0.0"> <uses-permission android:name="android.permission.INTERNET" /> <application android:icon="@drawable/icon" android:label="@string/app_name"> <activity android:label="@string/app_name" android:name="SocketTest"> <intent-filter> <action android:name="android.intent.action.MAIN" /> <category android:name="android.intent.category.LAUNCHER" /> </intent-filter> </activity> </application> </manifest>

dickwan · by **dickwan** » Fri May 14, 2010 4:19 pm

zuper wrote:Hello everyone!

Does exist alternatives of Socket on TCP communication between a Client Android and a Server Android or PC? Maybe RMI, corba or other strange protocols(I need Object transmission between Client & Server so i think that HTTP is not for me)?

Thanks to everyone

Hi Zuper,

so far I know, android does not support RNI yet and so it goes with Corba. I think you can "stream" object between client (let us say emulator) and the server (your pc) by creating serializable class/objects.

I'm also working on C/S programming over socket with android as client. But what I want is to able able to remotely call server methods... Well I guess I would have to define the packet I stream so that the server reacts the proper way.

wahaneebelly · by **wahaneebelly** » Fri May 28, 2010 5:46 am

I wrote a script in Perl which displays the Outlook Folders but For socket programming, Python provides the socket module. It is a very common module and it's most likely that you have it. The socket module consists of the socket() function, which is used for socket initiation/creation. We will be primarily concerned with this function only, i.e. socket.socket. The socket module also provides several other methods.

DMacATTACK · by **DMacATTACK** » Tue Jun 15, 2010 3:44 am

Hi all,
Since I learned how to establish a TCP client connection from this thread I thought I'd add to it. This thread creates a client that establishes a connection, sends data and then closes. I've worked with sockets before, and it is desirable to maintain a connection to the client, send data as you please, and disconnect. So I've done just that. I'm sorry if this concept has been posted by someone else, but I couldn't find the thread that does so. Also by having a persistent connection with a Connection timeout prevents your program from crashing when a connection is not found.

Syntax: [ Download ] [ Hide ]

Using java Syntax Highlighting

// Private variable
private Socket socket;
 
try {
                 InetSocketAddress remoteAddr = new InetSocketAddress("string of Server IP address",Port#);
                         
                 Log.d("TCP", "Connecting...");
                
                 socket = new Socket();
                 socket.connect(remoteAddr, 1000);                               
                   
         } catch (Exception e) {
              Log.e("TCP", "Error Connecting" + e);
         }
 
Parsed in 0.037 seconds,  using GeSHi 1.0.8.4

This code snippet tries to connect to the server, and if no connection is made within 1000 milliseconds, the connection is timed out, and your program wont hang. Ive used the socket as a private variable, so that it can be accessed from a function.
In the examples I've seen in this thread use
Socket socket = new socket(IP address, port);

This creates the socket object AND connects it to the IP address and port. Mine creates it and allows the socket to send data with any amount of time in between, and then the connection can be closed at your leisure as well.

My other Change/ Issue I ran into when creating the TCP client had to do how I was writing data to the socket.
I did not want the line feed character at the end of my stream, and I found some methods that just don't work. See the code Below for the solution to this:

Syntax: [ Download ] [ Hide ]

Using java Syntax Highlighting

Printwriter out = new PrintWriter.....etc
out.println("hello");
/*
* This writes "hello" followed by Line feed  (ASCII character 10)
*/ 
 
 
Printwriter out = new PrintWriter.....etc
out.print("hello");
/*
* This does not work. It should write "hello" not followed by any ASCII characters
*/ 
 
Printwriter out = new PrintWriter.....etc
out.write("hello");
/*
* This does not work. It should write "hello" not followed by any ASCII characters
*/ 
 
// --------------- SOLUTION ------------------
String strMessage = "Hello" + (char)13;
byte[] arrByteMessage = strMessage.getBytes();
 
OutputStream output = socket.getOutputStream();
                output.write(arrByteMessage);
 
/*
* This method performs the action I wanted "Hello" followed by Carriage Return (ASCII character 13)
*/
 
 
Parsed in 0.037 seconds,  using GeSHi 1.0.8.4

I hope this Helps anyone,

- DMacATTACK -

hsonbk · by **hsonbk** » Tue Sep 28, 2010 7:35 am

Hi guys
I'm a new user and sorry for digging this thread
I'm having a same old problem.
Here it is: I want to establish a socket connection between client (run on Android emulator) and server (run on PC)
The code on my client is liked:

public static String serverIP = "10.0.2.2";
public static int serverPort = 3725;
InetAddress serverAddr = InetAddress.getByName(serverIP);
Socket socket = new Socket(serverAddr, serverPort);

and on server:

ServerSocket myServer = new ServerSocket(3725);

I tried redir ports too, like the following:
telnet localhost 5554
redir add tcp:3725:3725
and check with redir list, everything's fine

But it didn't work. I got exception at "Socket socket = new Socket(serverAddr, serverPort);" and I really dont know why.

Please help, thanks very much.

Socket Programming

HELP ME PLEASE... T_T

Socket programing

executing from different class - application crashes ?

The post by zhufan and haugsrud helped in getting it to work

Re: Socket Programming

Re: Socket Programming

Re: Socket Programming

Who is online