Android socket client to client

Содержание

Android-er
Saturday, February 8, 2014
Android Server/Client example — client side using Socket
34 comments:
Native Socket.IO and Android
Introduction#
Installing the Dependencies#
Using socket in Activity and Fragment#
Emitting events#
Listening on events#
Managing Socket State#
Further reading#
Стабильный socket клиент для android

Android-er

For Android development, from beginner to beginner.

Saturday, February 8, 2014

Android Server/Client example — client side using Socket

It’s the client side implementation of our Server/Client example, the server side is listed in last post «server side using ServerSocket».

Android client side using Socket

Remark: uses-permission of «android.permission.INTERNET» is needed.

34 comments:

Works like a charm . Awesome

dear andr.oid eric, i created one application where socket programmin g is used, and that application not running on android version 4.0 and later.. i wnat ur help

thanks for your toturial guys

hmm. i try to connect android device to server but it didn’t well
if i try to eclipse emulator instead of android device, it works well
both of them, same situation. only emulator, android device difference
can you answer about my problem??
What can i check to solve this problem?

I am using hyperterminal to pass data to my android phone through wifi the data is being displayed on my phone at a random time and the data is scrambled and lot of extra garbage is also there, pls help!!

I can’t download the project file. The page doesn’t loading.

Hi.
Nice tutorial but i can not run it on my phone. How do i run it on my phone? Please help.

Thank you for posting this; it worked great on the emulator!

I’ll be migrating this app to a phone shortly. I’d also like to expand functionality to have indicators that display data sent from the server; do you have any posts on how I could achieve this? I’m new to Android and the site so will be rooting around in the coming days.

hello. sir
I am new to scripting language.. would you help me to learn this android scripting language by suggesting some useful links.

greet job. working well

Its really great, but in case when i don’t know about the server ip address then how can i connect with server as a client plzz tell me.

How can i user it for Instant messaging app in Android? And how to retrive port number from user while they initiate IM.

Hello. im just thinking if it is possible to divide the codes on connect button. by creating 2 buttons[connect,send].connect is just simply notify you if its connected, then send is to send a message to the server. can anyone help me?

I want to know which protocol is being used here. Is it telnet protocol ?

Awesome ..works very well. -)

Is it working over 4G connection? each device are not in same local network but have 4G connection. But I cannot send the socket. Pls how to solve it

I haven’t tried on mobile network. Somebody said the service provider will block the ports. So actually cannot, because of the mobile network service, not by the program.

ThanQ very Much For Best Script
It is Most Use full For Me But I have Some Problem is There any way to Read
Server Mobile Local Ip Address
i dont want enter Manually ip address in client side Mobile

hello The Creator,

I have no any good idea for your question.

Anyway, you can scan ip in your network, to find which devices can be reached. Scan Reachable IP to discover devices in network

Dear Sir,
Your code work fine,
But I want create once clientThread and reuse it to send different massages to server
because I need to send massage within one millisecond to the server

How can I use this with different network. It works only when both thw server an clients are in same networks.

hello ranjitha ak,

In my understanding, it depends on network setting, not related to the program.

Thanks for this tutorial, I am usually worried over the fact that people would take time to comment on ur work(post) but you find it very difficult to reply them especially when they need it.

Hi, Can anybody tell about UDP communication?

This program only partially works for me — pressing connect does show correct messages on the server device, but the client app only receives the input stream the one time into the buffer, then «inputStream.read(buffer)» receives no more data from the server and blocks the thread — i.e. never exits the while loop below.

while ((bytesRead = inputStream.read(buffer)) != -1) <
byteArrayOutputStream.write(buffer, 0, bytesRead);
response += byteArrayOutputStream.toString(«UTF-8»);
>

Appreciate your time for such a great tutorial. its Awesome, Loved it. simply the best 🙂

Hi,
Is it possible to do in UDP? I am working on this type of my student project.

It is better to close inputstream after read data:

InputStream inputStream = socket.getInputStream();

Great example I was struggling with it before I found this post.
I just can figure out how to send a String to the client?
Do I add the String to the ByteArrayOutputStream?

If you can show me I would appreciate it, Thanks.

Being new to this and would like to learn more. At present want to use android device with graphical buttons to send various commands via telnet?? Or other bidirectional protocol. Any help or links would be appreciated.

Please Share more Tutorials

Very Interesting Blog Post .Now a Days All the People in the world are Connected together by the Technology. Mainly makes human life Much Easier.
I Liiiike this tutorial

Very good, excellent post!

Very informative. Thanks for posting

Not working for multiple devices connection.

Источник

Native Socket.IO and Android

In this tutorial well learn how to create a chat client that communicates with a Socket.IO Node.JS chat server, with our native Android Client! If you want to jump straight to the code, it’s on GitHub. Otherwise, read on!

Introduction#

To follow along, start by cloning the repository: socket.io-android-chat.

The app has the following features:

Sending a message to all users joining to the room.
Notifies when each user joins or leaves.
Notifies when an user start typing a message.

Socket.IO provides an event-oriented API that works across all networks, devices and browsers. It’s incredibly robust (works even behind corporate proxies!) and highly performant, which is very suitable for multiplayer games or realtime communication.

Installing the Dependencies#

The first step is to install the Java Socket.IO client with Gradle.

For this app, we just add the dependency to build.gradle :

We must remember adding the internet permission to AndroidManifest.xml .

Now we can use Socket.IO on Android!

Using socket in Activity and Fragment#

First, we have to initialize a new instance of Socket.IO as follows:

IO.socket() returns a socket for http://chat.socket.io with the default options. Notice that the method caches the result, so you can always get a same Socket instance for an url from any Activity or Fragment. And we explicitly call connect() to establish the connection here (unlike the JavaScript client). In this app, we use onCreate lifecycle callback for that, but it actually depends on your application.

Emitting events#

Sending data looks as follows. In this case, we send a string but you can do JSON data too with the org.json package, and even binary data is supported as well!

Listening on events#

Like I mentioned earlier, Socket.IO is bidirectional, which means we can send events to the server, but also at any time during the communication the server can send events to us.

We then can make the socket listen an event on onCreate lifecycle callback.

With this we listen on the new message event to receive messages from other users.

This is what onNewMessage looks like. A listener is an instance of Emitter.Listener and must be implemented the call method. Youll notice that inside of call() is wrapped by Activity#runOnUiThread() , that is because the callback is always called on another thread from Android UI thread, thus we have to make sure that adding a message to view happens on the UI thread.

Managing Socket State#

Since an Android Activity has its own lifecycle, we should carefully manage the state of the socket also to avoid problems like memory leaks. In this app, we’ll close the socket connection and remove all listeners on onDestroy callback of Activity.

Calling off() removes the listener of the new message event.

Стабильный socket клиент для android

Недавно столкнулся с проблемой создания приложения (наподобие ICQ) с клиентом под андроид, в связи с чем, появилась необходимость реализовать сокет-соединение, которое выполняло бы следующие функции:

Инициировало соединение с сервером
Посылало серверу сообщение типа «Привет, я тут!», чтобы сервер знал, что за устройство к нему подключилось
Сидело и спокойно ждало входящие сообщения от сервера

Сама по себе задача довольно простая и ее решение описывается много где, НО есть следующие заморочки, с которыми я столкнулся:

данное подключение должно работать в фоновом режиме и не грузить основной процесс приложения, т.е. отрабатывать в отдельном потоке;
В случае потери соединения — оно должно автоматом восстанавливаться;

Совместно эти 2 «НО» явились для меня серьезной головной болью на 2 дня. Гугл по данной проблеме выдал несколько более-менее адекватных ссылок, но конечного работоспособного решения я так и не нашел (возможно, плохо искал, конечно, но не суть).

Собственно, предлагаю вам на ~~растерзание~~ рассмотрение свое решение.

1. Фоновый режим

Для того, чтобы наш сокет-клиент отрабатывал в фоновом режиме и принимал сообщения от сервера даже тогда, когда приложение не активно, запустим его внутри сервиса.

Сделать это можно, например, так:

public class NotificationService extends Service <

public class LocalBinder extends Binder <
NotificationService getService() <
return NotificationService.this;
>
>

@Override
public void onCreate() <
super.onCreate();

@Override
public IBinder onBind(Intent intent) <
return mBinder;
>

@Override
public void onDestroy()

// Здесь выполняем инициализацию нужных нам значений
// и открываем наше сокет-соединение
private void startService() <

> catch (InterruptedException e) <
e.printStackTrace();
>
>

// данный метод открыает соединение
public void openConnection() throws InterruptedException
<
try <

// WatchData — это класс, с помощью которого мы передадим параметры в
// создаваемый поток
WatchData data = new WatchData();
data.email = acc_email;
data.ctx = this;

// создаем новый поток для сокет-соединения
new WatchSocket().execute(data);

> catch (Exception e) <
// TODO Auto-generated catch block
e.printStackTrace();
>
>
>

Этот сервис делает 2 вещи:

Получает каким-либо образом e-mail пользователя, который нужно будет передать на сервер (в примере я его просто присвоил);
Передает этот e-mail в поток, который создаст сокет-соединение.

Читайте также: Тврп для андроид что это

В данном коде интерес представляет метод public void openConnection(), а если быть точнее, классы WatchData и WatchSocket, которые используются для создания нового потока, рассмотим их подробнее.

2. Создание потока

Зачем мы вообще создаем поток? Затем, что сервисы в андроиде не создают собственного, а выполняются в потоке приложения, что может (и будет!) тормозить наше приложение. Подробнее про сервисы — тут.
Итак, поток создавать нужно. Я для этой задачи решил использовать хрень под названием AsyncTask.
Для создания нужного мне AsyncTask’а я сделал два класса, о которых писал выше: WatchData и WatchSocket

WatchData:
class WatchData
<
String email;
Context ctx;
>
Поле email — нужно для того, чтобы передать в поток email, который мы хотим отправить на сервер (естественно, тут могут быть любые другие данные). Поле ctx передает контекст приложения. Мне этот контекст, например, нужен, чтобы сохранять получаемые от сервера сообщения в sqlite’овскую базу данных андроида.

WatchSocket:
class WatchSocket extends AsyncTask
<
Context mCtx;
Socket mySock;

protected void onProgressUpdate(Integer. progress)

protected void onPostExecute(Integer result)
<
// Это выполнится после завершения работы потока
>

protected void onCancelled(Object result)
<
// Это выполнится после завершения работы потока
>

protected Integer doInBackground(WatchData. param)
<
InetAddress serverAddr;

mCtx = param[0].ctx;
String email = param[0].email;

try <
while(true)
<
serverAddr = InetAddress.getByName(«192.168.0.10»);
mySock = new Socket(serverAddr, 4505);

// открываем сокет-соединение
SocketData data = new SocketData();
data.ctx = mCtx;
data.sock = mySock;

// ВНИМАНИЕ! Финт ушами — еще один поток =)
// Именно он будет принимать входящие сообщения
GetPacket pack = new GetPacket();
AsyncTask running = pack.execute(data);

String message = email;
// Посылаем email на сервер
try <
PrintWriter out = new PrintWriter( new BufferedWriter( new OutputStreamWriter(mySock.getOutputStream())),true);

// Следим за потоком, принимающим сообщения
while(running.getStatus().equals(AsyncTask.Status.RUNNING))
<

// Если поток закончил принимать сообщения — это означает,
// что соединение разорвано (других причин нет).
// Это означает, что нужно закрыть сокет
// и открыть его опять в бесконечном цикле (см. while(true) выше)
try
<
mySock.close();
>
catch(Exception e)
<>
>
> catch (Exception e) <
return -1;
>
>
>

Тут нас интересует метод protected Integer doInBackground(WatchData… param), который выполняет все, что нам нужно.
В вечном цикле производятся следующие действия:

Открывается сокет-соединение
Запускается новый поток, слушающий сервер
Посылается сообщение на сервер
Отслеживается слушающий поток на предмет закрытия соединения
В случае обрыва соединения цикл срабатывает заново

Здесь может возникнуть вопрос: «Зачем делать еще один поток? Почему не слушать сервер в этом же потоке?»

Отвечаю:
Во время моих экспериментов с AsyncTask’ами выяснилось, что при закрытии соединения методом «сервер взял и вырубился», слушающий его AsyncTask тупо берет и заканчивает работу. Пересоединить сокет с сервером прямо в том же таске у меня, как я ни бился — не вышло. Не берусь заявлять, что этого сделать невозможно — просто предлагаю свое рабочее решение.
Итак, чтобы слушать сервер, создается дополнительный поток GetPacket. Ему, в качестве параметров, в классе SocketData передаются открытый нами сокет и контекст приложения.

3. Слушаем сервер

Собственно, код второго потока:

class SocketData
<
Socket sock;
Context ctx;
>

class GetPacket extends AsyncTask
<
Context mCtx;
char[] mData;
Socket mySock;

protected void onProgressUpdate(Integer. progress)
<
try
<
// Получаем принятое от сервера сообщение
String prop = String.valueOf(mData);
// Делаем с сообщением, что хотим. Я, например, пишу в базу

>
catch(Exception e)
<
Toast.makeText(mCtx, «Socket error: » + e.getMessage(), Toast.LENGTH_LONG).show();
>
>