我需要创建一个使用REST的程序,老师给我们提供了以下代码作为起点,应该是正确的。
import java.io.*;
import java.net.InetSocketAddress;
import java.util.*;
import java.util.concurrent.Executors;
import com.sun.net.httpserver.*;
public class HttpServerDemo {
public static void main(String[] args) throws IOException {
InetSocketAddress addr = new InetSocketAddress(8080);
HttpServer server = HttpServer.create(addr, 0);
server.createContext( "/", new RootHandler());
server.createContext( "/foo/", new FooHandler());
server.setExecutor( Executors.newCachedThreadPool());
server.start();
System.out.println("Server is listening on port 8080" );
}
public static void printHeaders( HttpExchange exchange, PrintStream response) {
Headers requestHeaders = exchange.getRequestHeaders();
Set<String> keySet = requestHeaders.keySet();
Iterator<String> iter = keySet.iterator();
while( iter.hasNext()) {
String key = iter.next();
response.println( key + " = " + requestHeaders.get(key));
}
}
public static void printBody( HttpExchange exchange, PrintStream response) throws IOException {
BufferedReader body = new BufferedReader( new InputStreamReader( exchange.getRequestBody()));
String bodyLine;
while( (bodyLine = body.readLine()) != null) {
response.println( bodyLine);
}
}
}
class RootHandler implements HttpHandler {
public void handle( HttpExchange exchange) throws IOException {
String requestMethod = exchange.getRequestMethod();
Headers responseHeaders = exchange.getResponseHeaders();
responseHeaders.set( "Content-Type", "text/plain");
exchange.sendResponseHeaders( 200, 0);
PrintStream response = new PrintStream( exchange.getResponseBody());
response.println( "context: ROOT; method: " + requestMethod);
response.println( "--- headers ---");
HttpServerDemo.printHeaders( exchange, response);
if( requestMethod.equalsIgnoreCase( "POST")) {
response.println( "=== body ===");
HttpServerDemo.printBody( exchange, response);
}
response.close();
}
}
class FooHandler implements HttpHandler {
public void handle( HttpExchange exchange) throws IOException {
String requestMethod = exchange.getRequestMethod();
Headers responseHeaders = exchange.getResponseHeaders();
responseHeaders.set( "Content-Type", "text/plain");
exchange.sendResponseHeaders( 200, 0);
PrintStream response = new PrintStream( exchange.getResponseBody());
response.println( "context: FOO; method: " + requestMethod);
HttpServerDemo.printHeaders( exchange, response);
response.close();
}
}
由于RootHandler类中有一个if语句检查"POST",因此我将使用它来进行测试。因此,当我使用curl从单独的终端与该程序通信时,我输入:
curl –d "message=helloworld" http://localhost:8080/
然后我得到了以下回复:
curl: (6) Could not resolve host: –d; nodename nor servname provided, or not known
curl: (6) Could not resolve host: message=helloworld; nodename nor servname provided, or not known
context: ROOT; method: GET
--- headers ---
Host = [localhost:8080]
User-agent = [curl/7.21.4 (universal-apple-darwin11.0) libcurl/7.21.4 OpenSSL/0.9.8r zlib/1.2.5]
Accept = [*/*]
我觉得当我在终端使用curl时,我总是犯错。通过查看错误,它无法接受我输入的"-d"选项,这导致程序将请求方式读取为"GET"而不是"POST"。我已经尝试了"DELETE"和"PUT"请求方法,并得到了相同的结果。
curl localhost
,curl localhost:8080
等等,直到出现错误为止。如果在逐位输入时没有出现任何错误,请怀疑复制/粘贴。尝试使用不同的数据。对选项进行合理性检查。 - Dave Newton