package meloServ;

/**
 *
 * @author Chilon
 */
import java.io.*;
import java.util.Scanner;
import java.net.Socket;

public class Conexcciones extends Thread {
    
    Serv ss = new Serv() ;
    Socket s = new Socket();
    
    public Conexcciones() throws IOException{
            System.out.println("# Esperando solicitud de cliente...");
            s = ss.ss.accept();
            System.out.println("# Cliente conectado. Datos." + s.getInetAddress()+"-"+ s.getPort());
    }
    
}

    public void aceptCli()throws IOException{

            Conexcciones con =new Conexcciones();
            con.run();
        
    }

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 = "localhost";
    int port=5000;
    static String oracion;
    static Socket clients;
    int habilitarec = 0;
   
    public clie() {
        initComponents(); //Inicializa los componetes.
    }

    /** This method is called from within the constructor to
     * initialize the form.
     * WARNING: Do NOT modify this code. The content of this method is
     * always regenerated by the Form Editor.
     */
    @SuppressWarnings("unchecked")
  
    void conect(){
        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 btnConectActionPerformed(java.awt.event.ActionEvent evt) {                                          
    conect();
    }                                         
 void recstr(){
        InputStream strrec = null;
        try {
            String mnsjhabla;
            strrec = clients.getInputStream();
            DataInputStream datastrrec = new DataInputStream(strrec);
            mnsjhabla = datastrrec.readUTF();
            txtmnsjrec.setText(mnsjhabla);
        } catch (IOException ex) {
            Logger.getLogger(clie.class.getName()).log(Level.SEVERE, null, ex);
        } finally {
            try {
                strrec.close();
            } catch (IOException ex) {
                Logger.getLogger(clie.class.getName()).log(Level.SEVERE, null, ex);
            }
        }

    }
    private void btnenviarActionPerformed(java.awt.event.ActionEvent evt) {                                          
  
        OutputStream msjenv = null;
        try {
            msjenv = clients.getOutputStream();
            DataOutputStream mnsj = new DataOutputStream(msjenv);
            mnsj.writeUTF(txtenvio.getText());
            habilitarec = 1;
            recstr();
        } 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);

            }});
 
    }


}

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
// import java.util.Vector;
import java.util.logging.Level;
import java.util.logging.Logger;

//SERVIDOR. JAVA. SOCKET1.

class ejrndm {
     static final int PUERTO  = 5000;
        public static void main(String args[]) throws IOException {
        try {
            clas1s miclase = new clas1s();
            String text = "";
            System.out.println("Sirviendo por puerto: " + PUERTO);
            ServerSocket serv = new ServerSocket(PUERTO); //sOCKet del servidor. Espera peticion del cliente.
            System.out.println("----Esperando Cliente---- ");
            Socket nuCli = serv.accept(); //se guarda en un soket cuando se acepta las peticion.
            System.out.println("----Cliente conectado---- ");
           
            while(!text.equals("Salir")){
            InputStream mnsjre = nuCli.getInputStream();
            DataInputStream mnsjr = new DataInputStream(mnsjre);
            System.out.println("Cli << "+ mnsjr.readUTF());

            text = miclase.Ingresar("Serv >> ");
            OutputStream mnsjenv =  nuCli.getOutputStream();
            DataOutputStream mnsjresp = new DataOutputStream(mnsjenv);
            mnsjresp.writeUTF(" "+ text);

            }

            nuCli.close();
            serv.close();
            
        } catch (IOException ex) {
            Logger.getLogger(ejrndm.class.getName()).log(Level.SEVERE, null, ex);
        }
        }
}

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;