之前查找過很多網上的例子,直接new一個socket對象,傳ip值和端口号進去,發現在手機上運作之後,都是不行的,會出現android.os.NetworkOnMainThreadException 異常錯誤,弄了幾天,終于發現隻有通過異步線程的方法才測試出一個可以運作的代碼。此程式是可以掃描伺服器開放的端口,再連接配接,我這裡是開放了60000端口,測試時連接配接60000的端口。需要伺服器和用戶端都連在同一個區域網路上。我的ip位址是192.168.2.106,本例子是查找哪個端口開放,有句socket.close()被我注釋掉了,可保證伺服器與用戶端一直通信。
Linux伺服器端:編譯通過之後執行,這裡為友善測試,用戶端發送什麼資料,伺服器便收到傳回同樣資料
#include "./Server.cc"
int main()
{
Server server;
while (true)
{
server.setPort(60000);
std::cout << "start connect...\n";
Server new_sock;
std::string pattern = ",";
//get client connect and accept it.
server.accept(new_sock);
while (true)
{
std::string ack = "";
std::string recv;
new_sock >> recv;
if (recv=="")
{
server.close();
break;
}
//std::cout << "\nWe recv the message from client : " << recv << std::endl;
new_sock << recv;
}
}
}
手機用戶端:
package com.example.kam_socket3;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.net.SocketAddress;
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.TextView;
import android.widget.Toast;
public class MainActivity extends Activity {
private TextView tvPorts;
private Button starScanBtn;
private Handler handler = new Handler(){
@Override
public void handleMessage(Message msg){
//将已經打開的端口号顯示在TextView控件上
tvPorts.append(String.valueOf(msg.what) + ":OK\n");
super.handleMessage(msg);
}
};
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
tvPorts = (TextView) findViewById(R.id.tvPorts);
starScanBtn = (Button)findViewById(R.id.starScanBtn);
starScanBtn.setOnClickListener(new OnClickListener() {
@Override
public void onClick(View arg0) {
// TODO Auto-generated method stub
Thread thread = new Thread(new ConnetPort("192.168.2.106",60000));
thread.start();
Toast.makeText(MainActivity.this, "開始掃描", Toast.LENGTH_LONG).show();
}
});
}
class ConnetPort extends Thread{
private int conPort;
private String ipAddress;
public ConnetPort(String ipAddress,int conPort){
this.conPort = conPort;
this.ipAddress = ipAddress;
}
@Override
public void run(){
try{
Socket socket = new Socket();
SocketAddress socketAddress = new InetSocketAddress(ipAddress,conPort);
socket.connect(socketAddress,50);
handler.sendEmptyMessage(conPort);
// socket.close();
}
catch(Exception e){
}
handler.post(new Runnable(){
@Override
public void run(){
Toast.makeText(MainActivity.this, "掃描完成", Toast.LENGTH_LONG).show();
}
});
}
}
@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;
}
}
AndroidManifest:
<?xml version="1.0" encoding="utf-8"?>
<manifest xmlns:android="http://schemas.android.com/apk/res/android"
package="com.example.kam_socket3"
android:versionCode="1"
android:versionName="1.0" >
<uses-sdk
android:minSdkVersion="8"
android:targetSdkVersion="17" />
<application
android:allowBackup="true"
android:icon="@drawable/ic_launcher"
android:label="@string/app_name"
android:theme="@style/AppTheme" >
<activity
android:name="com.example.kam_socket3.MainActivity"
android:label="@string/app_name" >
<intent-filter>
<action android:name="android.intent.action.MAIN" />
<category android:name="android.intent.category.LAUNCHER" />
</intent-filter>
</activity>
</application>
<uses-permission android:name="android.permission.INTERNET" />
</manifest>
注意,一定要在系統資料庫上加上<uses-permission android:name="android.permission.INTERNET" />這句添加通路網絡權限,否則連接配接不上。
異步線程方法如:(簡單說下)
new Thread(){
@Override
public void run(){
//你要執行的方法
//執行完畢後給handler發送一個空消息
handler.sendEmptyMessage(0);
}
}.start();
//定義Handler對象
private Handler handler =new Handler(){
@Override
//當有消息發送出來的時候就執行Handler的這個方法
public void handleMessage(Message msg){
super.handleMessage(msg);
//處理UI
}
};