android之socket编程实例

注意点：注册访问的网络权限；android中UI线程不能有访问网络的操作，否则会报android.os.NetworkOnMainThreadException的异常

https://github.com/xionglihui

实例一

客户端

package com.android.xiong.simplesocket;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.io.OutputStream;import java.net.InetSocketAddress;import java.net.Socket;import java.net.SocketTimeoutException;import android.app.Activity;import android.os.Bundle;import android.os.Handler;import android.os.Message;import android.view.Menu;import android.view.View;import android.view.View.OnClickListener;import android.widget.Button;import android.widget.EditText;import android.widget.TextView;public class MainActivity extends Activity {Socket socket = null;String buffer = "";TextView txt1;Button send;EditText ed1;String geted1;public Handler myHandler = new Handler() {@Overridepublic void handleMessage(Message msg) {if (msg.what == 0x11) {Bundle bundle = msg.getData();txt1.append("server:"+bundle.getString("msg")+"\n");}}};@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_main);txt1 = (TextView) findViewById(R.id.txt1);send = (Button) findViewById(R.id.send);ed1 = (EditText) findViewById(R.id.ed1);send.setOnClickListener(new OnClickListener() {@Overridepublic void onClick(View v) {geted1 = ed1.getText().toString();txt1.append("client:"+geted1+"\n");//启动线程 向服务器发送和接收信息new MyThread(geted1).start();}});}class MyThread extends Thread {public String txt1;public MyThread(String str) {txt1 = str;}@Overridepublic void run() {//定义消息Message msg = new Message();msg.what = 0x11;Bundle bundle = new Bundle();bundle.clear();try {//连接服务器 并设置连接超时为5秒socket = new Socket();socket.connect(new InetSocketAddress("1.1.9.30", 30000), 5000);//获取输入输出流OutputStream ou = socket.getOutputStream();BufferedReader bff = new BufferedReader(new InputStreamReader(socket.getInputStream()));//读取发来服务器信息String line = null;buffer="";while ((line = bff.readLine()) != null) {buffer = line + buffer;}//向服务器发送信息ou.write("android 客户端".getBytes("gbk"));ou.flush();bundle.putString("msg", buffer.toString());msg.setData(bundle);//发送消息 修改UI线程中的组件myHandler.sendMessage(msg);//关闭各种输入输出流bff.close();ou.close();socket.close();} catch (SocketTimeoutException aa) {//连接超时 在UI界面显示消息bundle.putString("msg", "服务器连接失败！请检查网络是否打开");msg.setData(bundle);//发送消息 修改UI线程中的组件myHandler.sendMessage(msg);} catch (IOException e) {e.printStackTrace();}}}@Overridepublic boolean onCreateOptionsMenu(Menu menu) {// Inflate the menu; this adds items to the action bar if it is present.getMenuInflater().inflate(R.menu.main, menu);return true;}}

服务端

package com.android.net;import java.io.IOException;import java.net.ServerSocket;import java.net.Socket;import java.util.ArrayList;import java.util.List;public class AndroidService {public static void main(String[] args) throws IOException {ServerSocket serivce = new ServerSocket(30000);while (true) {//等待客户端连接Socket socket = serivce.accept();new Thread(new AndroidRunable(socket)).start();}}}

package com.android.net;import java.io.BufferedReader;import java.io.BufferedWriter;import java.io.IOException;import java.io.InputStream;import java.io.InputStreamReader;import java.io.OutputStream;import java.io.OutputStreamWriter;import java.io.PrintWriter;import java.net.Socket;public class AndroidRunable implements Runnable {Socket socket = null;public AndroidRunable(Socket socket) {this.socket = socket;}@Overridepublic void run() {// 向android客户端输出hello worildString line = null;InputStream input;OutputStream output;String str = "hello world!";try {//向客户端发送信息output = socket.getOutputStream();input = socket.getInputStream();BufferedReader bff = new BufferedReader(new InputStreamReader(input));output.write(str.getBytes("gbk"));output.flush();//半关闭socket  socket.shutdownOutput();//获取客户端的信息while ((line = bff.readLine()) != null) {System.out.print(line);}//关闭输入输出流output.close();bff.close();input.close();socket.close();} catch (IOException e) {e.printStackTrace();}}}

实例二

客户端

package com.android.xiong.sockettwotest;import android.app.Activity;import android.os.Bundle;import android.os.Handler;import android.os.Message;import android.view.Menu;import android.view.View;import android.view.View.OnClickListener;import android.widget.Button;import android.widget.EditText;import android.widget.TextView;public class MainActivity extends Activity {// 定义界面上的两个文本框EditText input;TextView show;// 定义界面上的一个按钮Button send;Handler handler;// 定义与服务器通信的子线程ClientThread clientThread;@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_main);input = (EditText) findViewById(R.id.input);show = (TextView) findViewById(R.id.show);send = (Button) findViewById(R.id.send);handler = new Handler() {@Overridepublic void handleMessage(Message msg) {// 如果消息来自子线程if (msg.what == 0x123) {// 将读取的内容追加显示在文本框中show.append("\n" + msg.obj.toString());}}};clientThread = new ClientThread(handler);// 客户端启动ClientThread线程创建网络连接、读取来自服务器的数据new Thread(clientThread).start();send.setOnClickListener(new OnClickListener() {@Overridepublic void onClick(View v) {try {// 当用户按下按钮之后，将用户输入的数据封装成Message// 然后发送给子线程HandlerMessage msg = new Message();msg.what = 0x345;msg.obj = input.getText().toString();clientThread.revHandler.sendMessage(msg);input.setText("");} catch (Exception e) {}}});}@Overridepublic boolean onCreateOptionsMenu(Menu menu) {getMenuInflater().inflate(R.menu.main, menu);return true;}}

package com.android.xiong.sockettwotest;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.io.OutputStream;import java.net.InetSocketAddress;import java.net.Socket;import java.net.SocketTimeoutException;import android.os.Handler;import android.os.Looper;import android.os.Message;public class ClientThread implements Runnable {private Socket s;// 定义向UI线程发送消息的Handler对象Handler handler;// 定义接收UI线程的Handler对象Handler revHandler;// 该线程处理Socket所对用的输入输出流BufferedReader br = null;OutputStream os = null;public ClientThread(Handler handler) {this.handler = handler;}@Overridepublic void run() {s = new Socket();try {s.connect(new InetSocketAddress("1.1.9.30", 3000), 5000);br = new BufferedReader(new InputStreamReader(s.getInputStream()));os = s.getOutputStream();// 启动一条子线程来读取服务器相应的数据new Thread() {@Overridepublic void run() {String content = null;// 不断的读取Socket输入流的内容try {while ((content = br.readLine()) != null) {// 每当读取到来自服务器的数据之后，发送的消息通知程序// 界面显示该数据Message msg = new Message();msg.what = 0x123;msg.obj = content;handler.sendMessage(msg);}} catch (IOException io) {io.printStackTrace();}}}.start();// 为当前线程初始化LooperLooper.prepare();// 创建revHandler对象revHandler = new Handler() {@Overridepublic void handleMessage(Message msg) {// 接收到UI线程的中用户输入的数据if (msg.what == 0x345) {// 将用户在文本框输入的内容写入网络try {os.write((msg.obj.toString() + "\r\n").getBytes("gbk"));} catch (Exception e) {e.printStackTrace();}}}}; // 启动LooperLooper.loop();} catch (SocketTimeoutException e) {Message msg = new Message();msg.what = 0x123;msg.obj = "网络连接超时！";handler.sendMessage(msg);} catch (IOException io) {io.printStackTrace();}}}

服务端

package com.android.net;import java.io.IOException;import java.net.ServerSocket;import java.net.Socket;import java.util.ArrayList;import java.util.List;public class MyService {// 定义保存所有的Socketpublic static List socketList = new ArrayList();public static void main(String[] args) throws IOException {ServerSocket server = new ServerSocket(3000);while(true){Socket s=server.accept();socketList.add(s);//每当客户端连接之后启动一条ServerThread线程为该客户端服务new Thread(new ServiceThreada(s)).start();}}}

package com.android.net;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.io.OutputStream;import java.net.Socket;public class ServiceThreada implements Runnable {// 定义当前线程处理的SocketSocket s = null;// 该线程所处理的Socket所对应的输入流BufferedReader br = null;public ServiceThreada(Socket s) {this.s = s;try {br = new BufferedReader(new InputStreamReader(s.getInputStream()));} catch (IOException e) {e.printStackTrace();}}@Overridepublic void run() {String content = null;//采用循环不断的从Socket中读取客户端发送过来的数据while((content=readFromClient())!=null){//遍历socketList中的每个Socket//将读取到的内容每个向Socket发送一次for(Socket s:MyService.socketList){OutputStream os;try {os = s.getOutputStream();os.write((content+"\n").getBytes("gbk"));} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}}// 定义读取客户端的信息public String readFromClient() {try {return br.readLine();} catch (Exception e) {e.printStackTrace();}return null;}}

实例一

客户端

服务端

实例二

客户端

服务端

更多相关文章

随机推荐