- Notifications
You must be signed in to change notification settings - Fork691
TCP/HTTP/UDP/QUIC client/server with Reactor over Netty
License
reactor/reactor-netty
Folders and files
| Name | Name | Last commit message | Last commit date | |
|---|---|---|---|---|
Repository files navigation
Reactor Netty offers non-blocking and backpressure-readyTCP/HTTP/UDP/QUICclients & servers based onNetty framework.
Reactor Netty requires Java 8 or + to run.
WithGradle fromrepo.spring.io orMaven Central repositories (stable releases only):
repositories {//maven { url 'https://repo.spring.io/snapshot' } mavenCentral() } dependencies {//compile "io.projectreactor.netty:reactor-netty-core:1.3.2-SNAPSHOT" compile"io.projectreactor.netty:reactor-netty-core:1.3.1"//compile "io.projectreactor.netty:reactor-netty-http:1.3.2-SNAPSHOT" compile"io.projectreactor.netty:reactor-netty-http:1.3.1" }See theReference documentationfor more information on getting it (eg. usingMaven, or on how to get milestones and snapshots).
New toReactor Netty? Check thisReactor Netty Workshopand theReference documentation
Here is a very simpleHTTP server and the correspondingHTTP client example
HttpServer.create()// Prepares an HTTP server ready for configuration .port(0)// Configures the port number as zero, this will let the system pick up// an ephemeral port when binding the server .route(routes ->// The server will respond only on POST requests// where the path starts with /test and then there is path parameterroutes.post("/test/{param}", (request,response) ->response.sendString(request.receive() .asString() .map(s ->s +' ' +request.param("param") +'!') .log("http-server")))) .bindNow();// Starts the server in a blocking fashion, and waits for it to finish its initialization
HttpClient.create()// Prepares an HTTP client ready for configuration .port(server.port())// Obtains the server's port and provides it as a port to which this// client should connect .post()// Specifies that POST method will be used .uri("/test/World")// Specifies the path .send(ByteBufFlux.fromString(Flux.just("Hello")))// Sends the request body .responseContent()// Receives the response body .aggregate() .asString() .log("http-client") .block();
Having trouble withReactor Netty? We'd like to help!
- If you are upgrading, read therelease notesfor upgrade instructions andnew and noteworthy features.
- Ask a question - we monitorstackoverflow.com for questionstagged with
reactor-netty. You can also chatwith the community onGitter. - Report bugs with
Reactor Nettyatgithub.com/reactor/reactor-netty/issues. - More aboutSupport and Deprecation policies
Reactor Netty usesGitHub’s integrated issue tracking system to record bugs and feature requests.If you want to raise an issue, please follow the recommendations below:
- Before you log a bug, pleasesearch the issue trackerto see if someone has already reported the problem.
- If the issue doesn't already exist,create a new issue.
- Please provide as much information as possible with the issue report, we like to knowthe version of
Reactor Nettythat you are using, as well as yourOperating SystemandJVMversion. - If you want to raise a security vulnerability, please review ourSecurity Policy for more details.
See ourContributing Guide for information about contributing toReactor Netty.
You don't need to build from source to useReactor Netty (binaries inrepo.spring.io), but if you want to try out the latest andgreatest,Reactor Netty can be easily built with thegradle wrapper. You also need JDK 1.8.
$ git clone https://github.com/reactor/reactor-netty.git$cd reactor-netty$ ./gradlew buildIf you want to publish the artifacts to your localMaven repository use:
$ ./gradlew publishToMavenLocal
https://projectreactor.io/docs/netty/release/api/
- https://projectreactor.io/docs/netty/release/reference/index.html
- https://violetagg.github.io/reactor-netty-workshop/
Reactor Netty is Open Source Software released under theApache License 2.0
About
TCP/HTTP/UDP/QUIC client/server with Reactor over Netty
Topics
Resources
License
Code of conduct
Contributing
Security policy
Uh oh!
There was an error while loading.Please reload this page.
Stars
Watchers
Forks
Uh oh!
There was an error while loading.Please reload this page.