Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Add HTTP proxy, multiple connections to client, clustering to server #11

Open
wants to merge 19 commits into
base: master
Choose a base branch
from
Open

Add HTTP proxy, multiple connections to client, clustering to server #11

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
19 commits
Select commit Hold shift + click to select a range
3e5aa56
Add initial cluster support
seanf Oct 30, 2017
fe9a380
Disable coroutine compiler warnings
seanf Oct 31, 2017
304adfb
Convert ProxyHookServer to coroutines
seanf Oct 30, 2017
c19c42d
Update main method to use cluster mode
seanf Oct 31, 2017
f33d505
Use openjdk18-openshift for docker base
seanf Oct 31, 2017
86921cf
Extract buildAndTest()
seanf Nov 3, 2017
d25e169
Update Kotlin
seanf Dec 15, 2017
5dd17b0
Upgrade Gradle
seanf Dec 15, 2017
ece1a27
Use JDK from RH Container Catalog for client
seanf Dec 15, 2017
30b34dc
Refactor http proxy code
seanf Dec 15, 2017
11ec71b
Support running with or without cluster
seanf Dec 15, 2017
f436095
Upgrade Kotlin to 1.2.30
seanf Mar 6, 2018
15c5495
Upgrade to vert.x 3.5.1
seanf Mar 7, 2018
8396496
Allow client to use multiple websockets
seanf Mar 7, 2018
967821c
Simplify using AsyncMap/HashMap, no LocalMap/Counter
seanf Mar 9, 2018
6297650
Remove FakeClusterManager
seanf Mar 9, 2018
6e812a5
Merge remote-tracking branch 'origin/master' into cluster-support
seanf Mar 9, 2018
8fa886a
Clean up for codacy
seanf Mar 9, 2018
5661330
Merge remote-tracking branch 'origin/master' into cluster-support
seanf Sep 14, 2018
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Update main method to use cluster mode
  • Loading branch information
@seanf
seanf committed Oct 31, 2017
commit c19c42ddc3e2ecc4bcb22202eee72fc2a0a1dbf3
5 changes: 5 additions & 0 deletions server/build.gradle
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,9 @@ plugins {
dependencies {
compile project(':common')
compile 'de.svenkubiak:jBCrypt:0.4.1'
runtime 'io.vertx:vertx-infinispan:3.5.0'
// // http://vertx.io/docs/vertx-infinispan/java/#_configuring_for_kubernetes_or_openshift_3
runtime 'org.infinispan:infinispan-cloud:9.1.2.Final'
}

mainClassName = 'io.vertx.core.Launcher'
Expand Down Expand Up @@ -37,11 +40,13 @@ shadowJar {
classifier = 'fat'

manifest {
attributes "Main-Class": "io.vertx.core.Launcher"
attributes "Main-Verticle": mainVerticleName
}

mergeServiceFiles {
include 'META-INF/services/io.vertx.core.spi.VerticleFactory'
include 'META-INF/services/io.vertx.core.spi.cluster.ClusterManager'
}
}

Expand Down
21 changes: 17 additions & 4 deletions server/src/main/java/org/zanata/proxyhook/server/ProxyHookServer.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@ package org.zanata.proxyhook.server

import io.vertx.core.Future
import io.vertx.core.Vertx
import io.vertx.core.VertxOptions
import org.mindrot.jbcrypt.BCrypt
import io.vertx.core.buffer.Buffer
import io.vertx.core.eventbus.EventBus
Expand Down Expand Up @@ -92,12 +93,24 @@ class ProxyHookServer(
var actualPort: Future<Int>? = null) : CoroutineVerticle() {

companion object {
// Try these JVM arguments: -Djava.net.preferIPv4Stack=true -Djgroups.bind_addr=127.0.0.1
@JvmStatic fun main(args: Array<String>) {
Vertx.vertx().deployVerticle(ProxyHookServer(port = null), { result ->
result.otherwise { e ->
exit(e)
Vertx.clusteredVertx(VertxOptions().apply {
// clusterHost = "localhost"
// clusterPort = 0
// isClustered = true
}) { res ->
if (res.succeeded()) {
res.result().deployVerticle(ProxyHookServer(port = null), { result ->
result.otherwise { e ->
exit(e)
}
}
)
} else {
exit(res.cause())
}
})
}
}
}
private inner class ConnectionManager(val connections: AsyncMap<String, Boolean>, val connectionCount: Counter)
Expand Down