Передать сообщение с сервера Bukkit в IRC с помощью плагина

Мой друг попросил меня написать плагин немного назад, и недавно (примерно пять минут назад) он попросил меня добавить функцию, с помощью которой люди могут войти в определенный IRC на esper.net и пообщаться в нем. Все настроено — у меня есть команда, которая позволяет им войти в систему, и она заставит их присоединиться к нику своего имени пользователя в MineCraft. Сервер использует чат-бота для входа пользователей, чтобы они могли общаться в чате, и у меня все настроено так, что при вводе команды (/irc login) они отправляют боту правильное сообщение (в частности, создается впечатление, что они написали /msg идентифицировать в IRC-чате). Что ж, у меня плагин настроил строку, в которой все отформатировано, но мне нужно знать, как на самом деле отправить сообщение в IRC. Ниже приведен мой код (все это срабатывает, когда пользователь вводит команду «/ irc», а «player» — это объект Player, настроенный при вводе любой команды). Я также хотел бы, чтобы какой-нибудь код получал то, что бот отправляет обратно, чтобы я знал, успешно ли игрок вошел в систему или нет.

if(args[0].equalsIgnoreCase("login") && args.length == 3) {
    String msg = "/msg <bot name> login " + args[1] + " " + args[2];
    //args[1] is the username and args[2] is the password
    String userName = args[1];
    //Creating the connection with a nickname of userName
    //Here is where I need to send that message through IRC
}
else {
    String msg;
    for(int i = 0; i <= args.length; i++) {
        msg += args[i] + " ";
    }
}

Кстати, я пока не знаю, как называется бот, так как мой друг все еще пишет для него код. Я полагал, что смогу просто вставить это, когда получу. Кроме того, домен еще предстоит определить, так как ему нужно купить сайт и все это настроить. Любые советы по ускорению работы этого кода также были бы замечательными.


person Fund Monica's Lawsuit    schedule 30.11.2012    source источник


Ответы (2)


Я думаю, вам следует изучить соединения сокетов Java.

но вот базовое IRC-соединение

class IRC
{
      //Connection Details
      String server = "IRC ADDRESS";
      String nick = "NICKNAME";
      String login = "LOGIN";
      String Pass = "PASS";  
      String channel = "CHANNLE";

  //Socket Stuff
  Socket socket;
  BufferedWriter writer;
  BufferedReader reader;


      public void HandleChat() throws Exception 
      {
           socket = new Socket(server, 6667);

           writer = new BufferedWriter(
               new OutputStreamWriter(socket.getOutputStream( )));

           reader = new BufferedReader(
               new InputStreamReader(socket.getInputStream( )));


           // Log on to the server.      
           writer.write("PASS " + Pass + "\r\n");
           writer.write("NICK " + nick + "\r\n");
           writer.write("USER " + login +"\r\n");
           writer.flush( );

           // Read lines from the server until it tells us we have connected.
           String line = null;

           while (((line = reader.readLine( )) != null))
           {
           }            
      }
}
person Dusty    schedule 01.04.2013
comment
Без обид или чего-то еще - это отличный ответ, но было бы неплохо немного раньше :) - person Fund Monica's Lawsuit; 02.04.2013
comment
Кстати, спасибо. Это кажется правильным, и я проверю это через несколько минут. Мне просто нужно снова настроить мой компьютер. Я только что вернулся из отпуска. - person Fund Monica's Lawsuit; 02.04.2013
comment
О, и я просто читаю строки, чтобы получить чат? Как закрыть соединение? Извините, если эти вопросы являются базовыми, но я вообще мало знаю об IRC или сокетах. - person Fund Monica's Lawsuit; 02.04.2013
comment
...Спустя долгое время я понял, что никогда не принимал ответа. Твой кажется лучшим, так что возьми бесплатного представителя. - person Fund Monica's Lawsuit; 05.03.2015

Вот несколько классов, которые могут подключаться к серверу. вы можете использовать это и изменить его в соответствии с вашими потребностями. все, что вам нужно сделать, это создать новый экземпляр ChatClient и задать ему правильные параметры, после чего он подключится к серверу.

ЧатКлеинт

    package com.weebly.foxgenesis.src;
import java.net.*;
import java.io.*;

public final class ChatClient
{  
    private Socket socket = null;
    private DataOutputStream streamOut = null;
    private ChatClientThread client = null;
    private String serverName = "localhost";
    private int serverPort = -1;
    private final ChatReciever output;

/**
 * Create a new ChatClient that connects to a given server and receives UTF-8 encoded messages
 * @param a Client class
 */
public ChatClient(ChatReciever chatReciever)
{ 
    output = chatReciever;
    serverPort = chatReciever.getPort();
    serverName = chatReciever.getHost();
    connect(serverName, serverPort);
}

private void connect(String serverName, int serverPort)
{  
    output.handleLog("Establishing connection. Please wait ...");
    try
    {  
        socket = new Socket(serverName, serverPort);
        output.handle("Connected to chat server");
        open();
    }
    catch(UnknownHostException uhe)
    {  
        output.handleError("Host unknown: " + uhe.getMessage()); 
    }
    catch(IOException ioe)
    {  
        output.handleError("Unexpected exception: " + ioe.getMessage()); 
    } 
}

/**
 * Sends a message to the server through bytes in UTF-8 encoding 
 * @param msg message to send to the server
 */
public void send(String msg) throws IOException
{  
    streamOut.writeUTF(msg); 
    streamOut.flush();
}

/**
 * forces the ChatReciever to listen to a message (NOTE: this does not send anything to the server)
 * @param msg message to send
 */
public void handle(String msg)
{  
    output.handle(msg);
}

private void open() throws IOException
{   
    streamOut = new DataOutputStream(socket.getOutputStream());
    client = new ChatClientThread(this, socket); 
}

/**
 * tries to close 
 */
public void close() throws IOException
{  
    if (streamOut != null)  
        streamOut.close();
    if (socket    != null)  
        socket.close(); 
}

/**
 * closes the client connection
 */
@SuppressWarnings("deprecation")
public void stop()
{
    if(client != null)
        client.stop();
    client = null;
}

/**
 * checks if the ChatClient is currently connected to the server
 * @return Boolean is connected
 */
public boolean isConnected()
{
    return client == null ?(false) : (true);
}
}

ChatServerThread

 package com.weebly.foxgenesis.src;
import java.net.*;
import java.io.*;

public final class ChatClientThread extends Thread
{  
    private Socket           socket   = null;
    private ChatClient       client   = null;
    private DataInputStream  streamIn = null;

    public ChatClientThread(ChatClient _client, Socket _socket)
    {  
        client   = _client;
        socket   = _socket;
        open();  
        start();
    }
    public void open()
    {  
        try
        {  
            streamIn  = new DataInputStream(socket.getInputStream());
        }
        catch(IOException ioe)
        {  
            System.out.println("Error getting input stream: " + ioe);
            client.stop();
        }
    }
    public void close()
    {  
        try
        {  
            if (streamIn != null) streamIn.close();
        }
        catch(IOException ioe)
        {  
            System.out.println("Error closing input stream: " + ioe);
        }
    }
    public void run()
    {  
        while (true)
        {  
            try
            {  
                client.handle(streamIn.readUTF());
            }
            catch(IOException ioe)
            { 
                System.out.println("Listening error: " + ioe.getMessage());
                client.stop();
            }
        }
    }
}

ЧатПолучатель

package com.weebly.foxgenesis.src;

public interface ChatReciever 
{
    /**
     * gets the IP address of the host
     * @return String IP address
     */
    public String getHost();

    /**
     * gets the port of the host
     * @return Integer port of host
     */
    public int getPort();

    /**
     * sends a message from the server to the implementing class
     * @param msg message from the server
     */
    public void handle(String msg);

    /**
     * sends an error to the implementing class
     * @param errorMsg error message
     */
    public void handleError(String errorMsg);

    /**
     * Sends a message to the log
     * @param msg message to send
     */
    public void handleLog(Object msg);
}
person fox_news    schedule 03.01.2014
comment
Две вещи: во-первых, обычно не слишком приятно оживлять мертвые вопросы, но спасибо за ответ. Во-вторых, я нашел хороший фреймворк под названием PircBot, и он отлично работает. На самом деле я должен обновить свой первоначальный вопрос. - person Fund Monica's Lawsuit; 03.01.2014