C# 服务端与 android app通信 实例源码

【实例简介】C#服务端Android客户端发送通知实例(建立连接后直接发送通知版)

服务端实现了：安装服务/启动服务/停止服务/卸载服务 监听消息通知等功能。

注意事项：

1.服务端需要右键 以管理员身份运行

2.app端的ip地址也需要修改成 服务端监听的ip地址

【实例截图】

【核心代码】

package com.example.sockettestclient;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
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.Menu;
import android.view.MenuItem;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;

public class MainActivity extends Activity {
	private boolean isConnect = false;
	private static final String ServerIP = "192.168.1.166";
	private static final int ServerPort = 4567;
	private Socket socket = null;
	private ReceiveThread receiveThread = null;
	private boolean isReceive = false;
	private Handler myHandler = null;
	private OutputStream outStream;
	private String strMessage;
	private TextView textReceive = null;
	private EditText textSend = null;
	@Override
	protected void onCreate(Bundle savedInstanceState) {
		super.onCreate(savedInstanceState);
		setContentView(R.layout.activity_main);
		Button btnConnect = (Button)findViewById(R.id.button1);
		Button btnSend = (Button)findViewById(R.id.button2);
		 textReceive = (TextView)findViewById(R.id.textView1);
		 textSend = (EditText)findViewById(R.id.editText1);
		//连接
		btnConnect.setOnClickListener(new View.OnClickListener() {
			
			@Override
			public void onClick(View v) {
				// TODO Auto-generated method stub
				if (!isConnect){
					new Thread(connectThread).start();
				}
			}
		});
		//发送按钮的监听器
				btnSend.setOnClickListener(new View.OnClickListener() {
					
					@Override
					public void onClick(View v) {
						if(isConnect){
						// TODO Auto-generated method stub
						strMessage = textSend.getText().toString();
						new Thread(sendThread).start();
						}
					}
				});
				myHandler = new Handler(){
					@Override
					public void handleMessage(Message msg){
						textReceive.append(" | " (msg.obj).toString());
					}
				};
	}
Runnable connectThread = new Runnable() {
		
		@Override
		public void run() {
			// TODO Auto-generated method stub
			try {
				//初始化Scoket，连接到服务器
				socket = new Socket(ServerIP, ServerPort);
				isConnect = true;
				//启动接收线程
				isReceive = true;
				receiveThread = new ReceiveThread(socket);
				receiveThread.start();
				System.out.println("----connected success----");
			} catch (UnknownHostException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
				System.out.println("UnknownHostException-->"   e.toString());
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
				System.out.println("IOException"   e.toString());
			}
		}
	};
	//接收线程
		private class ReceiveThread extends Thread{
			private InputStream inStream = null;
			
			private byte[] buffer;
			private String str = null;
			
			ReceiveThread(Socket socket){
				try {
					inStream = socket.getInputStream();
				} catch (IOException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
			@Override
			public void run(){
				while(isReceive){
					buffer = new byte[512];
					try {
						inStream.read(buffer);
					} catch (IOException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
					try {
						str = new String(buffer,"UTF-8").trim();
					} catch (UnsupportedEncodingException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
					Message msg = new Message();
					msg.obj = str;
					myHandler.sendMessage(msg);
				}
			}
		}
		//发送消息的接口
		Runnable sendThread = new Runnable() {
			
			@Override
			public void run() {
				// TODO Auto-generated method stub
				byte[] sendBuffer = null;
				try {
					sendBuffer = strMessage.getBytes("UTF-8");
				} catch (UnsupportedEncodingException e1) {
					// TODO Auto-generated catch block
					e1.printStackTrace();
				}
				try {
					outStream = socket.getOutputStream();
				} catch (IOException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				try {
					outStream.write(sendBuffer);
				} catch (IOException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
		};
		
		@Override
		protected void onDestroy() {
			// TODO Auto-generated method stub
			super.onDestroy();
			
			if(receiveThread != null){
				isReceive = false;
				receiveThread.interrupt();
			}
		}
	
}