Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package me.yakovliam.bdev.yakoapi.Socket;
- import me.yakovliam.bdev.yakoapi.Configuration.ConfigManager;
- import me.yakovliam.bdev.yakoapi.Query.Parser;
- import me.yakovliam.bdev.yakoapi.YakoAPI;
- import net.md_5.bungee.config.Configuration;
- import java.io.BufferedReader;
- import java.io.InputStreamReader;
- import java.io.PrintWriter;
- import java.net.ServerSocket;
- import java.net.Socket;
- public class SocketManager {
- private YakoAPI main = YakoAPI.getInstance();
- private ConfigManager cfgm;
- Configuration configcfg;
- private ServerSocket serverSocket;
- private Socket clientSocket;
- private PrintWriter out;
- private BufferedReader in;
- private Parser parser;
- public SocketManager() {
- cfgm = new ConfigManager();
- parser = new Parser();
- }
- public void get(){
- configcfg = cfgm.getConfigcfg();
- }
- public void socketSetup(int port){
- get();
- // setup socket
- try {
- serverSocket = new ServerSocket(port);
- clientSocket = serverSocket.accept();
- out = new PrintWriter(clientSocket.getOutputStream(), true);
- in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
- String message = in.readLine();
- // parse the message
- String final_ret = parser.parse_message(message);
- // output
- if(final_ret == null){
- out.println("null");
- }else{
- out.println(final_ret);
- }
- }catch (Exception e){
- e.printStackTrace();
- }
- }
- public void stop() {
- try {
- in.close();
- out.close();
- clientSocket.close();
- serverSocket.close();
- }catch (Exception e){
- e.printStackTrace();
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement