这方面的知识不是孤立的,其中有关于,Socket编程,多线程的操作,以及I/O流的操作。当然,实现方法不止一种,这只是其中一种,给同是新手一点点思路。如果有什么推荐的话,欢迎指点!
先给大家看一下应用程序的界面,基本就能知道大致的功能了。
activity_main.java
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
xmlns:tools="http://schemas.android.com/tools"
android:layout_width="match_parent"
android:layout_height="match_parent"
android:orientation="vertical"
tools:context=".MainActivity">
<EditText
android:id="@+id/editText"
android:layout_width="match_parent"
android:layout_height="wrap_content"
android:hint="请输入要发送的内容"/>
<Button
android:id="@+id/button01"
android:layout_width="match_parent"
android:layout_height="wrap_content"
android:text="连接"/>
<Button
android:id="@+id/button02"
android:layout_width="match_parent"
android:layout_height="wrap_content"
android:text="发送"/>
<ScrollView
android:layout_width="match_parent"
android:layout_height="wrap_content"
android:scrollbars="vertical"
android:fadingEdge="vertical">
<TextView
android:id="@+id/textView"
android:layout_width="match_parent"
android:layout_height="wrap_content"
android:text="输出信息:"/>
</ScrollView>
</LinearLayout>
界面很是简单。
下面我们需要一个服务器,和一个客户端。服务器,我用的是Eclipse写的Java的服务器;客户端,我用的是Android Studio写的。
package com.ryan.socketdemo01;
import android.os.Handler;
import android.os.Message;
import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.util.Log;
import android.view.Menu;
import android.view.MenuItem;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;
import android.widget.Toast;
import java.io.IOException;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import java.net.Socket;
public class MainActivity extends AppCompatActivity implements View.OnClickListener{
private Button button01 = null;
private Button button02 = null;
private EditText editText = null;
private TextView textView = null;
private static Socket ClientSocket = null;
private byte[] msgBuffer = null;
Handler handler = new Handler();
private void initView() {
button01 = (Button) findViewById(R.id.button01);
button02 = (Button) findViewById(R.id.button02);
editText = (EditText) findViewById(R.id.editText);
textView = (TextView) findViewById(R.id.textView);
button01.setOnClickListener(this);
button02.setOnClickListener(this);
button01.setEnabled(true);
button02.setEnabled(false);
}
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
initView();
}
@Override
public void onClick(View v) {
switch (v.getId()){
case R.id.button01:
// TODO: 15-9-4 socket连接线程
connectThread();
break;
case R.id.button02:
// TODO: 15-9-4 发送数据线程
sendMsgThread();
break;
}
}
private void sendMsgThread() {
final String text = editText.getText().toString();
try {
msgBuffer = text.getBytes("UTF-8");
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
}
new Thread(new Runnable() {
@Override
public void run() {
try {
OutputStream outputStream;
//Socket输出流
outputStream = ClientSocket.getOutputStream();
outputStream.write(msgBuffer);
outputStream.flush();
outputStream.close();
} catch (IOException e) {
e.printStackTrace();
}
handler.post(new Runnable() {
@Override
public void run() {
textView.append("发送成功:"+text+"\n");
}
});
}
}).start();
}
private void connectThread() {
new Thread(new Runnable() {
@Override
public void run() {
try {
ClientSocket = new Socket("10.0.2.2",9001);
if (ClientSocket.isConnected()){
handler.post(new Runnable() {
@Override
public void run() {
textView.append("连接成功!"+"\n");
button01.setEnabled(false);
button02.setEnabled(true);
}
});
}else {
handler.post(new Runnable() {
@Override
public void run() {
textView.append("连接失败!"+"\n");
}
});
}
} catch (IOException e) {
e.printStackTrace();
}
}
}).start();
}
@Override
public boolean onCreateOptionsMenu(Menu menu) {
// Inflate the menu; this adds items to the action bar if it is present.
getMenuInflater().inflate(R.menu.menu_main, menu);
return true;
}
@Override
public boolean onOptionsItemSelected(MenuItem item) {
// Handle action bar item clicks here. The action bar will
// automatically handle clicks on the Home/Up button, so long
// as you specify a parent activity in AndroidManifest.xml.
int id = item.getItemId();
//noinspection SimplifiableIfStatement
if (id == R.id.action_settings) {
return true;
}
return super.onOptionsItemSelected(item);
}
}
这里我的线程使用方式是:
new Thread (new Runnable) {
@Override
public void run() {
}
}
网上有人说这个方式很LOW,而且不好,但现在我只会这个,就连asynctask也还在学习中。
还有一点,子线程更新主UI的方法:
我使用的是 Handler.post(); 同样十分简单的使用方法。
Handler handler = new Handler();
handler.post(new Runnable() {
@Override
public void run() {
textView.append("发送成功:"+text+"\n");
}
});
关于几种子线程更新主UI的方法,我以后会再写一篇博客。我现在已经知道了不下4中方法,还没实地操作。
再来就是关于I/O流操作的方法:
这里我不做详细介绍,大家自行Google!什么你不会Google? 自行找FQ工具吧~~
这里我说一下我对于I/O的简单使用方法。
万物始于最初的,InputStream,OutputStream,他的方法只有reader()和write()。再其之上的,例如什么使用最多的BufferedReader对象,都是再其之上的升级包装,穿了个衣服,变得更加华丽而已。他的专业术语就是——装饰者模式,感兴趣的可以去翻翻资料。
最初,我对InputStream和OutputStream的方法不是很明了,经常错将InputStream用上write()的方法。 不知在哪里看到这么一段话,I/O流的操作实质是相对于Socket,ServerSocket连接后产生的数据流管道,reader与write是读取与写入的意思,是相对于那个数据流管道进行操作的。即读取管道里的信息,写入信息至管道。不知道这样大家动不动。
最后就是我们要学习的Socket。
他的使用也很简单,建立一个Socket对象,设置IP和端口,获取其I/O流。
ClientSocket = new Socket("10.0.2.2",9001);
outputStream = ClientSocket.getOutputStream();
到这里基本的使用方法就这么多。
说说我在这其中遇到的问题:
1.模拟器连接Java服务器连接不上。IP设置不对,我最开始设置的Ip是 127.0.0.1。 解决的连接:
http://stackoverflow.com/questions/8191192/reaching-a-network-device-by-ip-and-port-using-the-android-emulator/8191487#8191487
http://stackoverflow.com/questions/10336637/how-do-i-socket-an-android-program-to-a-localhost-server
2.忘记设置manifest,或者系统提供的android.permission.INTERNET全是大写的!!说来滑稽,但我就是遇到这样的问题,系统自动完成的代码提示,全是大写的,我以为就是那样呢,结果明明应该是小写。
<uses-permission android:name="android.permission.INTERNET" />
忘记贴上java服务器的代码了,补上。
public class Main {
public static void main(String[] args) {
// TODO Auto-generated method stub
new SerVerListener().start();
}
}
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException;
import java.net.ServerSocket;
import java.net.Socket;
import javax.swing.JOptionPane;
public class SerVerListener extends Thread{
private Socket clientSocket = null;
private ServerSocket serverSocket = null;
private InputStream inputStream = null;
private byte[] buffer = null;
@Override
public void run() {
// TODO Auto-generated method stub
try {
serverSocket = new ServerSocket(9001);
System.out.println("端口已开启,等待连接中〜〜");
//block
clientSocket = serverSocket.accept();
System.out.println("已有用户连接");
inputStream = clientSocket.getInputStream();
BufferedReader br = new BufferedReader(new InputStreamReader(inputStream));
String str;
while((str = br.readLine())!= null){
System.out.println(str);
}
}catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally{
try {
inputStream.close();
serverSocket.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
这是服务器端就收到的数据:
OK,基本就这样。
您可能感兴趣的文章:Android使用socket创建简单TCP连接的方法python服务器与android客户端socket通信实例Android中Socket通信的实现方法概述Android NDK中socket的用法以及注意事项分析Android顶栏定时推送消息使用SignalR推送服务在Android的实现 SignalAAndroid中利用App实现消息推送机制的代码Android Socket通信详解Android编程之客户端通过socket与服务器通信的方法Android 模拟器(JAVA)与C++ socket 通讯 分享Android中使用socket通信实现消息推送的方法详解