Android

package com.signalr_client;

import java.util.concurrent.ExecutionException;

import microsoft.aspnet.signalr.client.Action;
import microsoft.aspnet.signalr.client.ConnectionState;
import microsoft.aspnet.signalr.client.ErrorCallback;
import microsoft.aspnet.signalr.client.MessageReceivedHandler;
import microsoft.aspnet.signalr.client.Platform;
import microsoft.aspnet.signalr.client.http.android.AndroidPlatformComponent;
import microsoft.aspnet.signalr.client.hubs.HubConnection;
import microsoft.aspnet.signalr.client.hubs.HubProxy;
import android.app.Activity;
import android.os.Bundle;
import android.util.Log;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.ListView;
import android.widget.TextView;
import android.widget.Toast;

import com.google.gson.JsonArray;
import com.google.gson.JsonElement;
import com.google.gson.JsonObject;

public class MainActivity extends Activity {
	HubConnection chatConnection;
	HubProxy SignalRChatHub;

	Button ChatButton;
	EditText ChatInput;
	TextView ChatMessages;

	<a href="http://www.codeproject.com/Members/override">@Override</a>
	protected void onCreate(Bundle savedInstanceState) {
		super.onCreate(savedInstanceState);
		// Platform.loadPlatformComponent(new AndroidPlatformComponent());
		setContentView(R.layout.activity_main);
		// Intent i= new Intent(getApplicationContext(), NotifyService.class);
		// startService(i);

		chatConnection = new HubConnection("http://www.mynotyfy.somee.com/");
		SignalRChatHub = chatConnection.createHubProxy("ChatHub");
		// SignalRChatHub.subscribe(MainActivity.this);

		chatConnection.error(new ErrorCallback() {

			<a href="http://www.codeproject.com/Members/override">@Override</a>
			public void onError(final Throwable error) {
				runOnUiThread(new Runnable() {
					public void run() {
						Toast.makeText(getApplicationContext(),
								error.getMessage(), Toast.LENGTH_LONG).show();
					}
				});
			}
		});
		Init();

		ChatButton.setOnClickListener(new View.OnClickListener() {

			<a href="http://www.codeproject.com/Members/override">@Override</a>
			public void onClick(View v) {
				runThread();
			}
		});
		SignalRChatHub.subscribe(new Object() {
			@SuppressWarnings("unused")
			public void broadcastMessage(final String name, final String message) {
				runOnUiThread(new Runnable() {
					public void run() {
						Toast.makeText(getApplicationContext(),
								name + ": " + message, Toast.LENGTH_LONG)
								.show();
					}
				});
			}
		});

		chatConnection.start().done(new Action<Void>() {

			<a href="http://www.codeproject.com/Members/override">@Override</a>
			public void run(Void obj) throws Exception {
				runOnUiThread(new Runnable() {
					public void run() {
						Toast.makeText(getApplicationContext(),
								"Done Connecting!", Toast.LENGTH_LONG).show();
					}
				});
			}
		});
		chatConnection.received(new MessageReceivedHandler() {
			<a href="http://www.codeproject.com/Members/override">@Override</a>
			public void onMessageReceived(final JsonElement json) {
				runOnUiThread(new Runnable() {
					public void run() {
						Toast.makeText(getApplicationContext(),
								"testing!", Toast.LENGTH_LONG).show();
						JsonObject jsonObject = json.getAsJsonObject();
						JsonArray jsonArray = jsonObject.getAsJsonArray("A");
						String messagex = jsonArray.get(0).getAsString() + ": "
								+ jsonArray.get(1).getAsString();
						ChatMessages.append(messagex + "\n");
						Toast.makeText(getApplicationContext(),
								"loading!", Toast.LENGTH_LONG).show();
						// Toast.makeText(getApplicationContext(), messagex ,
						// Toast.LENGTH_LONG).show();
					}
				});
			}
		});
	}

	public void Init() {
		ChatButton = (Button) findViewById(R.id.ChatButton);
		ChatInput = (EditText) findViewById(R.id.ChatInput);
		ChatMessages = (TextView) findViewById(R.id.ChatMessages);
	}

	public void runThread() {

		new Thread(new Runnable() {
			public void run() {
				try {
					Thread.sleep(500);
				} catch (InterruptedException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				} 
				MainActivity.this.runOnUiThread(new Runnable() {
					public void run() {
						Toast.makeText(getApplicationContext(),
								"Click button1", Toast.LENGTH_SHORT).show();
						try{
							SignalRChatHub.invoke("Send", "Android", "hixhix");
						}catch(Exception e){
							ChatMessages.setText(e.getMessage().toString());
						}
							
					}
				});
			}
		}).start();

	}

}

using System;
using Android.App;
using Android.Content;
using Android.Runtime;
using Android.Views;
using Android.Widget;
using Android.OS;

using Microsoft.AspNet.SignalR.Client;

using System.Collections.Generic;
//đọc thêm ở đây
//http://developer.telerik.com/products/real-time-mobile-apps-with-appbuilder-xamarin-and-signalr/
namespace SignalRWithXamarin
{
    [Activity(Label = "SignalRWithXamarin", MainLauncher = true)]
    public class MainActivity : Activity
    {
        HubConnection chatConnection;
        IHubProxy SignalRChatHub;


        public event EventHandler<string> OnMessageReceived;

        protected override void OnCreate(Bundle bundle)
        {
            base.OnCreate(bundle);
            SetContentView(Resource.Layout.Main);

           
            chatConnection = new HubConnection("http://www.mynotyfy.somee.com/");
            SignalRChatHub = chatConnection.CreateHubProxy("ChatHub");


            SignalRChatHub.On("broadcastMessage", (string name, string message) =>
            {
                if (OnMessageReceived != null)
                    OnMessageReceived(this, string.Format("{0}: {1}", name, message));
            });

            var input = FindViewById<EditText>(Resource.Id.ChatInput);
            var messages = FindViewById<ListView>(Resource.Id.ChatMessages);
            var adapter = new ArrayAdapter<string>(this, Android.Resource.Layout.SimpleListItem1, new List<string>());

            JoinChat();

           

           
            messages.Adapter = adapter;
            OnMessageReceived += (sender, message) => RunOnUiThread(() =>
            adapter.Add(message));

            Button button = FindViewById<Button>(Resource.Id.ChatButton);
            button.Click += delegate
            {
                if (string.IsNullOrEmpty(input.Text))
                    return;

                Chat(input.Text);
                input.Text = "";
            };
        }

        public async virtual void JoinChat()
        {
            try
            {
                await chatConnection.Start();
            }
            catch (Exception)
            {
                // Do some error handling.
            }
        }

        public async virtual void Chat(string phoneChatMessage)
        {
            if (chatConnection.State == ConnectionState.Connected)
                await SignalRChatHub.Invoke("Send", "Android", phoneChatMessage);
        }

      
    }
}