2121import com .tencent .trpc .core .rpc .def .DefProviderInvoker ;
2222import com .tencent .trpc .core .utils .NetUtils ;
2323import com .tencent .trpc .proto .standard .common .TRPCProtocol ;
24- import java .net .InetSocketAddress ;
25- import javax .ws .rs .HttpMethod ;
26- import org .eclipse .jetty .http .HttpFields ;
27- import org .eclipse .jetty .http .HttpURI ;
28- import org .eclipse .jetty .http .HttpVersion ;
29- import org .eclipse .jetty .http .MetaData ;
30- import org .eclipse .jetty .server .HttpChannel ;
31- import org .eclipse .jetty .server .HttpConfiguration ;
32- import org .eclipse .jetty .server .HttpOutput ;
33- import org .eclipse .jetty .server .Request ;
34- import org .eclipse .jetty .server .Response ;
24+
25+ import java .net .HttpURLConnection ;
26+ import java .net .URL ;
3527import org .eclipse .jetty .server .Server ;
3628import org .eclipse .jetty .server .ServerConnector ;
3729import org .eclipse .jetty .util .thread .QueuedThreadPool ;
@@ -59,7 +51,7 @@ private static ProviderInvoker<Hello> buildProviderInvoker() {
5951 }
6052
6153 @ Test
62- public void testRegist () {
54+ public void testRegist () throws Exception {
6355 HTTP_EXECUTOR .register (INVOKER );
6456
6557 QueuedThreadPool threadPool = new QueuedThreadPool ();
@@ -76,23 +68,15 @@ public void testRegist() {
7668 connector .setAcceptQueueSize (60 );
7769 server .addConnector (connector );
7870
79- HttpChannel httpChannel = new HttpChannel (connector , new HttpConfiguration (),
80- null , null );
81- Request request = new Request (httpChannel , null );
82- request .setMetaData (
83- new MetaData .Request (HttpMethod .GET ,
84- new HttpURI (
85- "http://localhost:8080/hello/trpc.test.rpc.Hello/sayHello?verison=1" ),
86- HttpVersion .HTTP_1_0 , new HttpFields ()));
87- request .setMethod (HttpMethod .GET );
88- request .setPathInfo ("/trpc.test.rpc.Hello/sayHello" );
89- request .setRemoteAddr (new InetSocketAddress ("127.0.0.1" , 8080 ));
90-
91- Response response = new Response (new HttpChannel (connector , new HttpConfiguration (),
92- null , null ),
93- new HttpOutput (new HttpChannel (connector , new HttpConfiguration (), null ,
94- null )));
95- HTTP_EXECUTOR .execute (request , response );
71+ server .start ();
72+ try {
73+ URL url = new URL ("http://localhost:8080/hello/trpc.test.rpc.Hello/sayHello?verison=1" );
74+ HttpURLConnection conn = (HttpURLConnection ) url .openConnection ();
75+ conn .setRequestMethod ("GET" );
76+
77+ } finally {
78+ server .stop ();
79+ }
9680 }
9781
9882 @ Test
0 commit comments