Http请求与响应Demo

深藏阁楼爱情的钟 2021-12-05 17:57 396阅读 0赞

Request:

import com.alibaba.fastjson.JSONObject;
    
    public class SendCommand { 
    	public boolean sendCommand(Integer command, Integer mcuId, Integer doorNumber) { 
    		// TODO Auto-generated method stub
    
    			String url="http://127.0.0.1:6688";
    			JSONObject obj =new JSONObject();
    			 obj.put("command", command);
    			 obj.put("mcuId", mcuId);
    			 obj.put("doorNumber", doorNumber);
    			 String str="";
    
    		try { 
    	   str= HttpClient.doPost(url,obj.toString());
    
    		} catch (Exception e) { 
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    			return false;
    		}
    		if(str==null||"".equals(str)){ 
    			return false;
    		}else{ 
    			return true;
    		}
    		
    	}
    	public static void main(String[] args) { 
    		SendCommand send =new SendCommand();
    		send.sendCommand(0,1000,1);
    	}
    }

Response:

import java.io.IOException;
    import java.io.InputStream;
    import java.io.OutputStream; 
    import java.net.InetSocketAddress; 
    import java.util.Iterator; 
    import java.util.List;
    import java.util.Scanner;
    import java.util.Set; 
    import java.util.concurrent.Executors;
    import com.sun.net.httpserver.Headers; 
    import com.sun.net.httpserver.HttpExchange; 
    import com.sun.net.httpserver.HttpHandler; 
    import com.sun.net.httpserver.HttpServer; 
    //在eclipse中会出现Access restriction: The type Headers is not accessible due to restriction on required library 
    //解决办法：把Windows-Preferences-Java-Complicer- Errors/Warnings里面的Deprecated and restricted API中的Forbidden references(access rules)选为Warning就可以编译通过。 
    /** * 使用jdk自带sun httpserver组件构建Http服务器， * JDK自带的HttpServer是一个非常轻量级的Http服务端框架，但是它非常灵活，易于扩展， * @author Administrator * */ 
    public class HttpServerDemo {  
        public static void main(String[] args) throws IOException {  
            InetSocketAddress addr = new InetSocketAddress(6688); 
            HttpServer server = HttpServer.create(addr, 0); 
       
            server.createContext("/", new MyHandler()); 
            server.setExecutor(Executors.newCachedThreadPool()); 
            server.start(); 
            System.out.println("Server is listening on port 6688"); 
        } 
    } 
       
    class MyHandler implements HttpHandler {  
           
        public void handle(HttpExchange exchange) throws IOException {  
               
            String requestMethod = exchange.getRequestMethod(); 
            System.out.println("处理新请求:"+requestMethod); 
            if (requestMethod.equalsIgnoreCase("POST")) {  
                Headers responseHeaders = exchange.getResponseHeaders(); 
                InputStream body= exchange.getRequestBody();
                Scanner scan = new Scanner(body);     
    			scan.useDelimiter("\n"); 
    			String text = "" ;
    			while(scan.hasNext()){ 
    				text += scan.next(); 
    			}
    			scan.close();
    			System.out.println(text);
    
                responseHeaders.set("Content-Type", "application/json"); 
                exchange.sendResponseHeaders(200, 0); 
       
                OutputStream responseBody = exchange.getResponseBody(); 
                Headers requestHeaders = exchange.getRequestHeaders(); 
                Set<String> keySet = requestHeaders.keySet(); 
                Iterator<String> iter = keySet.iterator(); 
                while (iter.hasNext()) {  
                    String key = iter.next(); 
                    List values = requestHeaders.get(key); 
                    String s = key + " = " + values.toString() + "\n"; 
    
                } 
                responseBody.close(); 
            } 
        } 
    }