您的位置：首页 > 移动开发 > Android开发

Android Socket实例（2）

2016-02-16 14:57 435 查看

http://blog.csdn.net/x605940745/article/details/17001641转载请注明出处

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

[html] view
plain copy

<uses-permission

android:name="android.permission.INTERNET"/>

Android开发联盟③ 433233634

实例一

客户端

[java] view
plain copy

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() {

@Override

public void handleMessage(Message msg) {

if (msg.what == 0x11) {

Bundle bundle = msg.getData();

txt1.append("server:"+bundle.getString("msg")+"\n");

}

}

};

@Override

protected 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() {

@Override

public 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;

}

@Override

public 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();

}

}

}

@Override

public 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;

}

}

[html] view
plain copy

服务端

[java] view
plain copy

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();

}

}

}

[java] view
plain copy

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;

}

@Override

public void run() {

// 向android客户端输出hello worild

String 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();

}

}

}

实例二

客户端

[java] view
plain copy

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;

@Override

protected 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() {

@Override

public 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() {

@Override

public void onClick(View v) {

try {

// 当用户按下按钮之后，将用户输入的数据封装成Message

// 然后发送给子线程Handler

Message msg = new Message();

msg.what = 0x345;

msg.obj = input.getText().toString();

clientThread.revHandler.sendMessage(msg);

input.setText("");

} catch (Exception e) {

}

}

});

}

@Override

public boolean onCreateOptionsMenu(Menu menu) {

getMenuInflater().inflate(R.menu.main, menu);

return true;

}

}

[java] view
plain copy

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;

}

@Override

public 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() {

@Override

public 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();

// 为当前线程初始化Looper

Looper.prepare();

// 创建revHandler对象

revHandler = new Handler() {

@Override

public void handleMessage(Message msg) {

// 接收到UI线程的中用户输入的数据

if (msg.what == 0x345) {

// 将用户在文本框输入的内容写入网络

try {

os.write((msg.obj.toString() + "\r\n")

.getBytes("gbk"));

} catch (Exception e) {

e.printStackTrace();

}

}

}

};

// 启动Looper

Looper.loop();

} catch (SocketTimeoutException e) {

Message msg = new Message();

msg.what = 0x123;

msg.obj = "网络连接超时！";

handler.sendMessage(msg);

} catch (IOException io) {

io.printStackTrace();

}

}

}

[html] view
plain copy

服务端

[java] view
plain copy

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 {

// 定义保存所有的Socket

public static List<Socket> socketList = new ArrayList<Socket>();

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();

}

}

}

[java] view
plain copy

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 {

// 定义当前线程处理的Socket

Socket 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();

}

}

@Override

public 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 block

e.printStackTrace();

}

}

}

}

// 定义读取客户端的信息

public String readFromClient() {

try {

return br.readLine();

} catch (Exception e) {

e.printStackTrace();

}

return null;

}

}

内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理

标签：

相关文章推荐

新的分享

章节导航