haHAA

gistfile1.txt

val service: ExecutorService = Executors.newFixedThreadPool(512)

fun main(args: Array<String>) {
	val jsonFile = File("aws.json")
	
	val o = JsonParser().parse(FileReader(jsonFile)).asJsonObject
	val arr = o.get("prefixes").asJsonArray
	for (ipE in arr) {
		val prefix = ipE["ip_prefix"].asString
		val ipPrefix = prefix.split("/")[0].replace(".0.0", "")
		for (i in 0..255) {
			for (i2 in 0..255) {
				val ip = "$ipPrefix.$i.$i2"
				portIsOpen(service, ip, 5201, 250)
			}
		}
	}
}

fun portIsOpen(es: ExecutorService, ip: String, port: Int, timeout: Int): Future<Boolean>
		= es.submit(Callable {
	try {
		val socket = Socket()
		socket.connect(InetSocketAddress(ip, port), timeout)
		socket.close()
		
		println("$ip:$port")
		return@Callable true
	} catch (ex: Exception) {
		return@Callable false
	}
})