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