Skip to content

Commit

Permalink
create parser config files
Browse files Browse the repository at this point in the history
  • Loading branch information
bukarevd committed Jan 14, 2019
1 parent d3db989 commit 56b972e
Show file tree
Hide file tree
Showing 7 changed files with 81 additions and 10 deletions.
2 changes: 0 additions & 2 deletions pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,4 @@
</plugin>
</plugins>
</build>


</project>
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
package Client;

import java.io.*;
import java.net.Socket;

Expand All @@ -12,8 +14,10 @@ public void start(){
BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(socketClient.getOutputStream()));
BufferedReader reader = new BufferedReader(new InputStreamReader(socketClient.getInputStream())))
{
writer.write("Hello");
writer.flush();
System.out.println(reader.readLine());



}catch (IOException e){
e.getStackTrace();
}
Expand Down
53 changes: 53 additions & 0 deletions src/main/java/ConfigParser/ConfigParser.java
Original file line number Diff line number Diff line change
@@ -0,0 +1,53 @@
package ConfigParser;
import java.io.*;
import java.nio.charset.Charset;

public class ConfigParser extends Parser {
@Override
public void command(File file) {
switch (file.getName()){
case ("server.conf"):
new ServerObject(file).readFile();
break;
case ("client.conf"):
new ClientObject();
break;
}
}

public static void main(String[] args) {

File server = new File(ConfigParser.class.getClassLoader().getResource("server.conf").getFile());
System.out.println(server.getAbsoluteFile());

new ConfigParser().command(server);
}
}
class ServerObject{
File file;

public ServerObject(File file) {
this.file = file;
}

public void readFile(){
try(InputStream in = new FileInputStream(file);
ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream()){
byte[] buf = new byte [1024];
int len;
while ((len = in.read()) > 0){
byteArrayOutputStream.write(buf, 0, len);
}
String str = new String(byteArrayOutputStream.toByteArray(), Charset.forName("UTF-8"));
System.out.println(str);
}catch (FileNotFoundException e){
e.getMessage();
} catch (IOException e) {
e.printStackTrace();
}
}
}

class ClientObject{

}
9 changes: 9 additions & 0 deletions src/main/java/ConfigParser/Parser.java
Original file line number Diff line number Diff line change
@@ -0,0 +1,9 @@
package ConfigParser;

import java.io.File;

abstract public class Parser{
public abstract void command(File file);
// public abstract void writeJSONFile(File file);
}

15 changes: 9 additions & 6 deletions src/main/java/Server.java → src/main/java/Server/Server.java
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
package Server;

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
Expand All @@ -8,20 +10,21 @@ public static void main(String[] args) {
}

public static void start() {

try (ServerSocket server = new ServerSocket(8411)) {
System.out.println("Server started on " + server);
while (true)
while (true) {
try (Socket socket = server.accept();
BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()))) {
String request = reader.readLine();
System.out.println(request);
writer.write("test " + request.length());

writer.write("Server");
writer.flush();



}catch (IOException e){
e.getStackTrace();
}
}

} catch (IOException e) {
e.getStackTrace();
Expand Down
3 changes: 3 additions & 0 deletions src/main/resources/client.conf
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
name => client1;
server => 127.0.0.1;
port => 8411;
1 change: 1 addition & 0 deletions src/main/resources/server.conf
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
port => 8411;

0 comments on commit 56b972e

Please sign in to comment.