Android向node.js编写的服务器发送数据并接收请求

var http = require("http"); 
var fs = require("fs"); 
var queryString = require('querystring'); 
var url = require('url'); 
var util = require('util'); 
 
http.createServer(function (request, response) { 
 // 定义了一个post变量，用于暂存请求体的信息 
 var post = ''; 
 request.on('data', function(chunk){ 
 post += chunk; 
 }); 
// 在end事件触发后，通过querystring.parse将post解析为真正的POST请求格式，然后向客户端返回。 
 request.on('end', function(){ 
 post = queryString.parse(post); 
 console.log("请求结束"+post.body); 
 response.writeHead(200, {"Content-Type": "text/plain;charset=utf8"}); 
 response.write("请求成功"); 
 response.end(); 
 }); 
 
}).listen(8888); 
console.log("服务器启动"); 
 
function writeFile(str) { 
 fs.writeFile('E:/log.txt', str, function (err) { 
 if (err) { 
  return console.error(err); 
 } 
 console.log("数据写入成功！"); 
 }) 
} 

package com.example.hanbo.servertest; 
import android.support.v7.app.AppCompatActivity; 
import android.os.Bundle; 
import android.view.View; 
import android.widget.Button; 
import android.widget.TextView; 
import org.json.JSONObject; 
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.UnsupportedEncodingException; 
import java.net.HttpURLConnection; 
import java.net.MalformedURLException; 
import java.net.ProtocolException; 
import java.net.URL; 
import java.net.URLEncoder; 
public class MainActivity extends AppCompatActivity { 
private TextView textView; 
@Override 
protected void onCreate(Bundle savedInstanceState) { 
super.onCreate(savedInstanceState); 
setContentView(R.layout.activity_main); 
textView= (TextView) findViewById(R.id.textView); 
Button button= (Button) findViewById(R.id.button); 
button.setOnClickListener(new View.OnClickListener() { 
@Override 
public void onClick(View view) { 
textView.setText("开始请求"); 
new Thread(new Runnable() { 
@Override 
public void run() { 
HttpURLConnection connection = null; 
URL url = null; 
try { 
url = new URL("http://192.168.1.177:8888"); 
connection = (HttpURLConnection) url.openConnection(); 
connection.setRequestMethod("POST"); 
connection.setConnectTimeout(8000); 
connection.setReadTimeout(8000); 
connection.setRequestProperty("Content-Type","application/json"); 
OutputStream outputStream=connection.getOutputStream(); 
BufferedWriter requestBody=new BufferedWriter(new OutputStreamWriter(outputStream)); 
String str = URLEncoder.encode("抓哇", "UTF-8"); 
requestBody.write("name=javaPost&body=1"); 
requestBody.flush(); 
requestBody.close(); 
getResponseJava(connection); 
} catch (MalformedURLException e) { 
e.printStackTrace(); 
} catch (ProtocolException e) { 
e.printStackTrace(); 
} catch (IOException e) { 
e.printStackTrace(); 
} 
} 
}).start(); 
} 
}); 
} 
private void getResponseJava(HttpURLConnection urlConnection) { 
InputStream in = null; 
try { 
in = urlConnection.getInputStream();//响应 
} catch (IOException e) { 
urlConnection.disconnect(); 
//textView.setText(e.getMessage()); 
return; 
} 
BufferedReader reader = null; 
try { 
reader = new BufferedReader(new InputStreamReader(in,"UTF-8")); 
} catch (UnsupportedEncodingException e1) { 
e1.printStackTrace(); 
} 
final StringBuilder result = new StringBuilder(); 
String tmp = null; 
try { 
while((tmp = reader.readLine()) != null){ 
result.append(tmp); 
} 
} catch (IOException e) { 
//textView.setText(e.getMessage()); 
return; 
} finally { 
try { 
reader.close(); 
urlConnection.disconnect(); 
} catch (IOException e) { 
} 
} 
runOnUiThread(new Runnable() { 
@Override 
public void run() { 
textView.setText(result); 
} 
}); 
} 
}