import java.io.*;
import java.net.*;
import java.util.Scanner;

public class meloCliente {
 
    String ip = "127.0.0.1",usuario, mensajeDis, mensajeDos;
    int port = 6666;
    Socket tcp;
    Scanner sc;
    boolean flag =true;

    
    public void llamEsqueletor() {
        
    }
    
    public void closePort() {
        
    }
    public void getDatain() throws IOException{
            DataInputStream dis = new DataInputStream(tcp.getInputStream());
            mensajeDis = dis.readUTF();
            System.out.println("Msj << "+ mensajeDis);
            
    }
    public void setDataOutPack() throws IOException {
        DataOutputStream dos = new DataOutputStream(tcp.getOutputStream());
        System.out.print(" >> ");
        mensajeDos = this.crateMsj(); 
        String packet = this.usuario + "-" + mensajeDos;
        dos.writeUTF(packet);
        // falta enviarlo...
        
    }
    public String crateMsj(){
        sc = new Scanner(System.in);
        String teclado = sc.nextLine();     
        return teclado;
    }

    public void openConex() throws SocketException, IOException{
        tcp = new Socket(ip, port);
        if(tcp.isConnected()){System.out.println("Cliente <<"+ usuario +">> conectado al Servidor.");}
    }
    public static void main(String[] args) throws IOException, SocketException{
        meloCliente mC = new meloCliente();
        
        mC.LeyendaUsr();
        mC.openConex();
        
        while(mC.flag){
            mC.setDataOutPack();
        }
        
    }
    public void LeyendaUsr() {
        sc = new Scanner(System.in);

        System.out.println("        ·~ Cliente Mensajeria. v0.1 "+ "\n");
        System.out.println("# Apodo de red: \n");
        usuario = sc.nextLine();
    }
}

import java.net.*;
import java.io.*;
import javax.swing.JOptionPane;
import java.util.Scanner;

public class Serv{
    
    ServerSocket ss;
    Socket s ;
    JOptionPane panelDat;
    boolean flag = true;
    Scanner sc;
    int cont =0;
            
    public void openPort() throws IOException{
        System.out.println("# Abriendo puertos.");
        ss = new ServerSocket(6666);
    }
    public void aceptCli() throws IOException{
            System.out.println("# Esperando solicitud de cliente...");
            s = ss.accept();
            cont++;
            System.out.println("# Cliente conectado. Datos." + s.getInetAddress()+"-"+ s.getPort()+ " Cliente Nro:" + cont);
    }
    public void sendPack() throws IOException{
        DataOutputStream dos = new DataOutputStream(s.getOutputStream());
    }    
    
    public void getDatain() throws IOException{
        DataInputStream dis = new DataInputStream(s.getInputStream());
        String mensajeDis = dis.readUTF();
        System.out.println(mensajeDis);
        
    }
    public void closePort() {
        
    }
    public static void main(String[] args)throws IOException {
        Serv sev = new Serv();
        sev.leyenda();
        sev.openPort();
        
        sev.aceptCli();
        while(sev.flag){
        sev.getDatain();
        }
        
        System.out.println("·~ Servidor");
    }
        public void leyenda() {
        System.out.println("      ·~ Servidor Mensajeria v0.1." + "\n");

    }
}

package client;

import java.awt.Color;
import java.io.*;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.logging.Level;
import java.util.logging.Logger;

/**
 *
 * @author
 */
public class clie extends javax.swing.JFrame {
    String conIP;
    int port;
    static byte activ=0;
    static String oracion;
    /** Creates new form clie */
    public clie() {
        initComponents(); //Inicializa los componetes.
    }

     static Socket clients;

    @SuppressWarnings("unchecked")

    private void btnConectActionPerformed(java.awt.event.ActionEvent evt) {                                          
        conIP = txtipconec.getText();
        port = Integer.parseInt(txtportconect.getText());
        activ++;
        try {
            clients = new Socket(conIP, port);
        } catch (UnknownHostException ex) {
            Logger.getLogger(clie.class.getName()).log(Level.SEVERE, null, ex);
        } catch (IOException ex) {
            Logger.getLogger(clie.class.getName()).log(Level.SEVERE, null, ex);
        }
    }                                         

    private void txtenviarActionPerformed(java.awt.event.ActionEvent evt) {                                          
        OutputStream msjenv = null;
        try {
            msjenv = clients.getOutputStream();
            DataOutputStream mnsj = new DataOutputStream(msjenv);
            mnsj.writeUTF(jTextArea1.getText());
        } catch (IOException ex) {
            Logger.getLogger(clie.class.getName()).log(Level.SEVERE, null, ex);
        } finally {
            try {
                msjenv.close();
            } catch (IOException ex) {
                Logger.getLogger(clie.class.getName()).log(Level.SEVERE, null, ex);
            }
        }
    }                                         

    /**
    * @param args the command line arguments
    */
    public static void main(String args[]) throws IOException {
        java.awt.EventQueue.invokeLater(new Runnable() {
            public void run(){
                new clie().setVisible(true);
            }
        });
               InputStream mnsjre = clients.getInputStream();
               DataInputStream mnsjr = new DataInputStream(mnsjre);
               oracion = (String) mnsjr.readUTF();
    }

    // Variables declaration - do not modify
    private javax.swing.JButton btnConect;
    private javax.swing.JLabel jLabel1;
    private javax.swing.JLabel jLabel2;
    private javax.swing.JScrollPane jScrollPane1;
    private javax.swing.JTextArea jTextArea1;
    private javax.swing.JButton txtenviar;
    private javax.swing.JTextField txtipconec;
    private javax.swing.JTextField txtmnsj;
    private javax.swing.JTextField txtportconect;