Databases
StackOverflow2013
Postsdbo
POWhy does my Datagram socket stop recieving data, even though it recieved data perfectly fine?
 

Note that there are some explanatory texts on larger screens.

plurals
  1. POWhy does my Datagram socket stop recieving data, even though it recieved data perfectly fine?
    primarykey
    data
    text
    <p>I'm making a multiplayer game in java, and I'm really have some issues here. For some reason, my Datagram socket will stop receiving packets set from the client even though according to the console, it recieved them perfectly fine before. I don't know much about networking or programming with sockets, so this has me stumped.</p> <p>Here's my code:</p> <p>Server:</p> <pre><code>package server; import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; import java.net.SocketException; import java.util.Arrays; import java.util.HashMap; import java.util.Map; import java.util.Vector; import java.util.concurrent.atomic.AtomicInteger; import shared.BaseEntity; import shared.MethodNotOverridenException; import shared.Packet; import shared.Player; public class S_GameLoop implements Runnable{ //Constants private static final int TICKS_PER_SECOND = 25; private static final int TICKS_TO_SKIP = 1000 / TICKS_PER_SECOND; private static final int MAX_FRAMESKIP = 5; private static final int SPAWN_COORD_X = 50; private static final int SPAWN_COORD_Y = 50; private Vector&lt;S_Client&gt; ClientList; private Map&lt;Integer, BaseEntity&gt; EntityMap; private AtomicInteger IDGenerator; private boolean gameIsRunning = true; private DatagramSocket socket; byte[] recieveData = new byte[1024]; byte[] prevRecieveData = new byte[1024]; private int port; private int loops; public S_GameLoop(int port) { ClientList = new Vector&lt;S_Client&gt;(); this.port = port; IDGenerator = new AtomicInteger(); EntityMap = new HashMap&lt;Integer, BaseEntity&gt;(); } private void Init() throws SocketException { System.out.println("INIT"); socket = new DatagramSocket(port); System.out.println("[Server] Create listen server on " + socket.getLocalAddress().getHostAddress() + " on port " + socket.getLocalPort()); socket.setSoTimeout(0); } private void Running() { System.out.println("S_GameLoop staring"); long nextGameTick = System.currentTimeMillis(); DatagramPacket recievePacket = new DatagramPacket(recieveData, recieveData.length); //GameLoop goes here while(gameIsRunning) { loops = 0; //Receive the data try { socket.receive(recievePacket); } catch (IOException e1) { e1.printStackTrace(); } while(System.currentTimeMillis() &gt; nextGameTick &amp;&amp; loops &lt; MAX_FRAMESKIP) { try { Update(recievePacket); } catch (MethodNotOverridenException | IOException e) { System.err.println(e); } nextGameTick += TICKS_TO_SKIP; loops++; } nextGameTick += TICKS_TO_SKIP; loops++; try { Thread.sleep(500); } catch (InterruptedException e) { e.printStackTrace(); } } } private void Update(DatagramPacket recievePacket) throws IOException, MethodNotOverridenException { if(prevRecieveData != recieveData) { parseData(formatData(recievePacket.getData()), recievePacket); prevRecieveData = recieveData; } else { return; } } public static Packet formatData(byte[] data) { try { if(data[1] == 0); String tag = new String(Arrays.copyOfRange(data, 1, 8)); System.out.println("[Server] Recieved packet " + data[0] + " " + new String(tag)); return new Packet(data[0],tag.getBytes(), Arrays.copyOfRange(data, 8, data.length)); } catch (ArrayIndexOutOfBoundsException e) { return new Packet((byte)0, new byte[0], new byte[0]); } } private void parseData(Packet p, DatagramPacket recievePacket) throws IOException, MethodNotOverridenException { if(p.getTag() == new byte[0]) { System.out.println("[Server] Recieved NULL packet"); return; } switch (p.getTagAsString()) { case "LGN_RQS": System.out.println("[Server] Login Request Recieved"); //Login was accepted //Create a Client ref, and add it to the vector S_Client newClient = new S_Client(recievePacket.getAddress(), recievePacket.getPort()); ClientList.add(newClient); //Create a player and add it to Entity list Player newPlayer = new Player(IDGenerator.getAndIncrement(), ClientList.indexOf(newClient)); EntityMap.put(newPlayer.getEntID(), newPlayer); System.out.println("[Server] Created new Player with EID " + newPlayer.getEntID() + " and CID " + newPlayer.getCID()); //Send reply to Client that is logging in sendData(new Packet((byte)2, "LGN_ACP".getBytes(), ("CID;" + ClientList.indexOf(newClient) + ";EID;" + newPlayer.getEntID()).getBytes()).getBytes(), newClient.getIp(), newClient.getPort()); //New Entity was created //sendData(newPlayer.onCreate(this)); break; case "HND_SHK": System.out.println("[Server] Handshake Recieved"); String fdata = new String(p.getData()); String[] data = fdata.split(";"); //Get client by client ID S_Client c = ClientList.get(Integer.parseInt(data[1])); c.setUsername(data[3]); System.out.println("[Server] Set Client " + data[1] + "'s username to " + data[3]); //Now spawn the player sendData(new Packet((byte)9, "PLR_SPW".getBytes(), ("CID;" + data[1] + ";X;" + SPAWN_COORD_X + ";Y;" + SPAWN_COORD_Y).getBytes()).getBytes()); break; } } public String[] byteArrayToStringArray(byte[] b) { String fdata = new String(b); return fdata.split(";"); } public void createEntity(BaseEntity be) throws MethodNotOverridenException, IOException { int ID = IDGenerator.incrementAndGet(); be.setEntID(ID); EntityMap.put(ID, be); sendData(be.onCreate(this)); } public void sendData(byte[] sendData, InetAddress IP, int port) throws IOException { System.out.println("[Server] Send packet " + sendData[0] + " " + new String(Arrays.copyOfRange(sendData, 1, 8))); DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, IP, port); socket.send(sendPacket); } public void sendData(byte[] sendData) throws IOException { for (S_Client entry : ClientList) { sendData(sendData, entry.getIp(), entry.getPort()); } } @Override public void run() { try { Init(); Running(); } catch (SocketException e) { System.err.println(e); } catch (IOException e) { System.err.println(e); } } } </code></pre> <p>Client:</p> <pre><code>package client; import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; import java.net.SocketException; import java.net.SocketTimeoutException; import java.util.Arrays; import java.util.Vector; import shared.BaseEntity; import shared.Packet; import shared.Player; public class C_GameLoop { //How fast should the game update? private static final int TICKS_PER_SECOND = 25; //How many ticks should be skipped in order to run it at that speed? //If it runs faster, then the Render() will be called more often private static final int TICKS_TO_SKIP = 1000 / TICKS_PER_SECOND; //How many times should you skip rendering, if you have to? private static final int MAX_FRAMESKIP = 5; RenderCanvas rc; InetAddress ServerIP; private DatagramSocket socket; private int port; private boolean connectedToServer = false; private boolean waitForData = false; private String username = "Dummy"; byte[] sendPacket; Vector&lt;BaseEntity&gt; RenderList; Player player; int fps = 0; public C_GameLoop(RenderCanvas rc){ this.rc = rc; RenderList = new Vector&lt;BaseEntity&gt;(); } public boolean Connect(InetAddress ServerIP, int port) throws IOException { this.port = port; this.ServerIP = ServerIP; socket = new DatagramSocket(); socket.setSoTimeout(4000); DatagramPacket recieveData = new DatagramPacket(new byte[1024], new byte[1024].length); System.out.println("[Client] Connecting to: " + ServerIP.getHostAddress() + ":" + port); //Send a login request sendData(new Packet((byte)1, "LGN_RQS".getBytes()).getBytes()); int retries = 0; //Start the connect loop while(!connectedToServer) { try { socket.receive(recieveData); waitForData = false; parseData(formatData(recieveData.getData())); //recieveData.setData(new Packet((byte)0, new byte[0], new byte[0]).getBytes()); } catch (SocketTimeoutException e) { if(waitForData = true &amp;&amp; retries &lt;= 4) { System.out.println("[Client] Failed to recieve response from server, retrying"); parseData(formatData(recieveData.getData())); retries++; } else { System.out.println("[Client] Failed to Connect to the server!"); return false; } } catch (IOException e) { e.printStackTrace(); } } return true; } public void sendData(byte[] data) throws IOException { System.out.println("[Client] Sent packet " + data[0] + " " + new String(Arrays.copyOfRange(data, 1, 8))); DatagramPacket sendPacket = new DatagramPacket(data, data.length, ServerIP, port); socket.send(sendPacket); waitForData = true; } private void parseData(Packet p) throws IOException { switch (p.getTagAsString()) { case "LGN_ACP": System.out.println("[Client] Login Accepted"); //Get the data needed to create a new player from the packet String fdata = new String(p.getData()); String[] data = fdata.split(";"); Player player = new Player(Integer.parseInt(data[1]), Integer.parseInt(data[3].trim())); //Add it to the render list this.player = player; rc.getCamera().addDrawableEntity(player); System.out.println("[Client] Player created with CID " + data[1] + " and EID " + data[3]); //Send the handshake System.out.println("[Client] Finshing Handshake..."); sendData(new Packet((byte)4, "HND_SHK".getBytes(), ("CID;" + player.getCID() + ";Username;" + username).getBytes()).getBytes()); break; case "PLR_SPW": System.out.println("[Client] Spawn Recieved"); //Get the coords String[] spawn_data = byteArrayToStringArray(p.getData()); this.player.setX(Integer.parseInt(spawn_data[3])); this.player.setY(Integer.parseInt(spawn_data[5].trim())); sendData(new Packet((byte)0, "KEP_ALV".getBytes()).getBytes()); break; } } public String[] byteArrayToStringArray(byte[] b) { String fdata = new String(b); return fdata.split(";"); } /* * Formats data into a packet */ public static Packet formatData(byte[] data) { try { if(data[1] == 0); String tag = new String(Arrays.copyOfRange(data, 1, 8)); System.out.println("[Client] Recieved packet " + data[0] + " " + new String(tag)); return new Packet(data[0],tag.getBytes(), Arrays.copyOfRange(data, 8, data.length)); } catch (ArrayIndexOutOfBoundsException e) { return new Packet((byte)0, new byte[0], new byte[0]); } } } </code></pre> <p>Console output when running code:</p> <pre><code> INIT [Server] Create listen server on 0.0.0.0 on port 4334 S_GameLoop staring [Client] Connecting to: 127.0.0.1:4334 [Client] Sent packet 1 LGN_RQS [Server] Recieved packet 1 LGN_RQS [Server] Login Request Recieved [Server] Created new Player with EID 0 and CID 0 [Server] Send packet 2 LGN_ACP [Client] Recieved packet 2 LGN_ACP [Client] Login Accepted [Client] Player created with CID 0 and EID 0 [Client] Finshing Handshake... [Client] Sent packet 4 HND_SHK [Client] Failed to recieve response from server, retrying (Same lines as previous 6 just repeat 4 times) [Client] Failed to Connect to the server! </code></pre> <p>Any Ideas?</p>
    singulars
    1. PO
      singulars
      1. PTAnswer
    1. This table or related slice is empty.
    1. PTQuestion
    1. USILikePizza555
    1. USILikePizza555
    plurals
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. PO
      singulars
      1. PTAnswer
    1. VO
      singulars
      1. POWhy does my Datagram socket stop recieving data, even though it recieved data perfectly fine?
      1. This table or related slice is empty.
      1. VTClose
    2. VO
      singulars
      1. POWhy does my Datagram socket stop recieving data, even though it recieved data perfectly fine?
      1. USMoonlit
      1. VTFavorite
    1. COFor more help faster provide an SSCCE.
      singulars
      1. POWhy does my Datagram socket stop recieving data, even though it recieved data perfectly fine?
      1. USBevynQ
    2. CO@BevynQ I'm not sure exactly what I could remove. I know there are a few functions that aren't used, but I don't exactly know what people need to know. As fore making it compilable, I can't really identify where the problem is at, or what could be causing the problem. I'll remove the unused functions, but I'm afraid that's all I know how to do.
      singulars
      1. POWhy does my Datagram socket stop recieving data, even though it recieved data perfectly fine?
      1. USILikePizza555
    3. COJust have the code that sends and receives data, strip out everything else.
      singulars
      1. POWhy does my Datagram socket stop recieving data, even though it recieved data perfectly fine?
      1. USBevynQ
 

Querying!

 
Guidance
A row detail

Detail views are divided into sections. All the information in the data section comes from columns in the selected row. The other sections display data from other, related rows.

Related data can be related in a to-one or a to-many fashion. Captions of data related in a to-many fashion link to a list view showing a filtered view of the table.

Try moving around until you find a non-empty to-many entry and click on the label to get to one. You can move back to the root by clicking on the database name in the header.

SQuiL has stopped working due to an internal error.

If you are curious you may find further information in the browser console, which is accessible through the devtools (F12).

Reload