Solved websockets how to sent data back?

Hello,

so I'm trying to make my own http socket since jetty is pretty big for just a single callback system for greylisting.

but whenever I run my own variant, it displays a normal page rather than a json file I think ive used the DataOutputStream incorrectly, could someone explain me how to sent it back to the client?, its my first time making sockets

my whole class is, of course its looks a bit messy and maybe also redurant though:

Code:java

 
public class GreyListServer implements Runnable {
 
/*
this is a example how the greylist works through php, we can use the json which gets returned by jetty in this way.
currently we have 3 possible return types:
 
success = when the player change from group,
greylisted = when the player already is greylisted
notexist = if the player has never played before
php callback example:
<?php
$string = file_get_contents("[url]http://127.0.0.1:8001/adduser/Xeph0re[/url]");
$json = json_decode($string, true);
$args = $json["xEssentials"]["response"];
if($args == "success") {
echo "player has been promoted";
} else if($args == "greylisted") {
echo "player already is greylisted";
} else if($args == "notexist") {
echo "player has never played before";
}
?>
*/
 
private final int port;
private ServerSocket server;
private Thread thread;
 
public GreyListServer(int port) {
this.port = port;
}
 
public boolean isRunning() {
if(!(thread instanceof Thread)) {
return false;
} else {
return thread.isAlive();
}
}
 
@SuppressWarnings({ "deprecation" })
public void stop() {
if(isRunning()) {
try {
server.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
thread.stop();
}
}
 
public void start() {
if(!(thread instanceof Thread)) {
try {
this.server = new ServerSocket(port);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
this.thread = new Thread(this);
this.thread.start();
}
}
@Override
public void run() {
while(true) {
try {
Socket client = server.accept();
 
String uri;
String line;
String user;
 
InputStream stream = client.getInputStream();
InputStreamReader iread = new InputStreamReader(stream);
BufferedReader reader = new BufferedReader(iread);
DataOutputStream response = new DataOutputStream(client.getOutputStream());
 
while((line = reader.readLine()) != null) {
System.out.print("line: " + line);
if(line.startsWith("GET".toUpperCase())) {
System.out.print("found get: " + line);
//we've found the request, now we need to validate that request, and sent a json back in return.
//if the method is not returned at all then we return a 404 and disconnect the client.
 
uri = line.replace("GET ", "").replace(" HTTP/1.1", "");
 
if(uri.startsWith("/adduser/") && uri.length() > "/adduser/".length()) {
//valid url lets go futher to check if this is a player.
 
response.writeBytes("HTTP/1.1 200 OK\r\n");
 
user = uri.substring("/adduser/".length());
 
System.out.print("user: " + user);
System.out.print("url is correct.");
 
if(xEssentials.isEssentialsPlayer(user)) {
//user is valid.
response.writeBytes("Content-Type: application/json");
 
xEssentialsOfflinePlayer off = xEssentials.getOfflinePlayer(user);
if(!off.isGreyListed()) {
//user is not greylisted before.
response.writeBytes("{\"xEssentials\": {\"response\": \"success\"}}");
off.setGreyListed(true);
if(off.getPlayer() instanceof Player) {
off.getPlayer().sendMessage(ChatColor.GREEN + "you are successfully promoted to " + Configuration.getGrayListConfig().getGroup());
if(Hooks.isVaultEnabled()) {
String oldGroup = xEssentials.getPlugin().getVault().getGroup(Bukkit.getWorlds().get(0), user);
String newgroup = Configuration.getGrayListConfig().getGroup();
xEssentials.getPlugin().getVault().setGroup(Bukkit.getWorlds().get(0), off.getUser(), newgroup);
Bukkit.getPluginManager().callEvent(new PlayerGreyListedEvent(off.getPlayer(), newgroup, oldGroup, GreyListCause.SITE));
}
} else {
if(Hooks.isVaultEnabled()) {
String oldGroup = xEssentials.getPlugin().getVault().getGroup(Bukkit.getWorlds().get(0), user);
String newgroup = Configuration.getGrayListConfig().getGroup();
xEssentials.getPlugin().getVault().setGroup(Bukkit.getWorlds().get(0), off.getUser(), newgroup);
Bukkit.getPluginManager().callEvent(new PlayerGreyListedEvent(off.getPlayer(), newgroup, oldGroup, GreyListCause.SITE));
}
}
} else {
//user already was greylisted
response.writeBytes("{\"xEssentials\": {\"response\": \"greylisted\"}}");
}
} else {
//user is invalid and has never played before.
response.writeBytes("{\"xEssentials\": {\"response\": \"notexist\"}}");
}
} else {
//invalid url.
response.writeBytes("HTTP/1.1 404 Not Found");
}
 
reader.close();
iread.close();
stream.close();
client.close();
return;
}
}
} catch (IOException e) {
e.printStackTrace();
}
 
}
}
}
 

I think ive forgot a few important things here, all advise and help are welcome


thanks!

-edit-
by alot of testing it seems I had to flush the DataOutputStream a few times and by means don't forget to flush when being done creating the headers they are seperated by an enter and then you need to flush again and then you can futher with the content and you need to flush again.