Java网络编程总结

package com.xykj .server;

import java.io .IOException;

import java.io .InputStream;

import java.io .OutputStream;

import java.net .ServerSocket;

import java.net .Socket;

/**

服务器端继承 Thread

* 可以实现简单的交互

* */

public class Server extends Thread {

// 定义服务器接口 ServerSocket

ServerSocket server = null;

// 定义一个服务器，定义端口

public Server (int port) {

try {

server = new ServerSocket (port);

} catch (IOException e) {

e.printStackTrace ();

}

}

// 发送消息的线程

@Override

public void run() {

super.run();

try {

System.out.println ("服务器在启动中...等待用户的连接");

//一直接收用户的连接，连接之后发送一条短信给用户

while (true){

// 建立 socket 接口，accept 方法是一个阻塞进程,等到有用户连接才往下走

// 定义Socket 类

Socket socket = server.accept ();

//通过socket对象可以获得输出流，用来写数据

OutputStream os = socket.getOutputStream ();

// 向客户端发送消息

os.write ("服务器正在向你发送消息！".getBytes());

// 在服务器上显示连接的上的电脑、

System.out.println (socket.getInetAddress (). getHostAddress ()+ "连接上了！");

// 通过socket对象可以获得输入流，用来读取用户数据

InputStream is = socket.getInputStream ();

//读取数据

int len=0;

byte[] buf = new byte [1024];

while ((len=is.read(buf) ) != -1) {

//直接把获得的数据打印出来

System.out.println ("服务器接收到客户端的数据："+ new String (buf,0,len));

}

}

} catch (IOException e) {

e . printStackTrace();

}

}

}

package com.xykj. server ;

ublic class ServerTest {

public static void main (String [] args) {

// 这里服务器只需要定义一个端口号就可以了，程序会自动获取IP地址

// 但是客户端需要连接这个服务器时，需要知道它的 IP地址还有端口号

// ip地址的查看方法：进入cmd窗口，输入 ipconfig /all可以看到

Server server = new Server (6768);

server.start ();

}

package com.xykj .client;

import java.io .IOException;

import java.io .InputStream;

import java.io .OutputStream;

import java.net .Socket;

import java.net .UnknownHostException;

import java.util .Scanner;

public class Client extends Thread {

//定义一个Socket对象

Socket socket = null;

public Client (String host, int port) {

try {

// 需要服务器的IP地址和端口号，才能获得正确的Socket对象

socket = new Socket (host, port);

} catch (UnknownHostException e) {

e.printStackTrace ();

} catch (IOException e) {

e.printStackTrace ();

}

}

@Override

public void run () {

// 客户端一连接就可以写数据个服务器了

new sendMessThread ().start ();

super.run ();

try {

// 读Sock里面的数据

InputStreams = socket. getInputStream ();

byte [] buf = new byte [1024];

int len = 0;

while ( (len = s.read (buf)) != -1) {

System.out .println (new String(buf, 0, len));

}

} catch (IOException e) {

e.printStackTrace();

}

}

//往Socket里面写数据，需要新开一个线程

class sendMessThread extends Thread {

@Override

public void run () {

super.run();

//写操作

Scanner scanner = null;

OutputStream os = null;

try {

scanner = new Scanner (System.in);

os = socket.getOutputStream ();

String in="";

do {

in = scanner.next ();

os.write (("客户端:"+in).getBytes ());

os.flush();

} while (!in.equals("bye"));

} catch (IOException e) {

e.printStackTrace ();

}

scanner.close ();

try {

os.close ();

} catch (IOException e) {

e.printStackTrace ();

}

}

}

}

package com.xykj .client2;

public class ClientTest2 {

public static void main (String [] args) {

// 需要服务器的正确的IP地址和端口号

Client2 client2 = new Client2("192.168.18.128", 6768);

client2.start ();

}

}

package com.xykj .server2;

import java.io .IOException;

import java.io .InputStream;

import java.io .OutputStream;

import java.net .ServerSocket;

import java.net .Socket;

import java.util .ArrayList;

import java.util .List;

/**

* 可以实现和客户端的相互发送消息的交互 可以是多台电脑

* */

public class Server2 extends Thread {

// 用来存放连接上的用户的socket 对象的值

List list = new ArrayList <>();

// 定义服务器接口 ServerSocket

ServerSocket server = null;

// 定义一个服务器，定义端口

public Server2 (int port) {

try {

server = new ServerSocket (port);

} catch (IOException e) {

e.printStackTrace ();

}

}

// 发送消息的线程

@Override

public void run () {

super.run ();

try {

while (true) {

// 建立socket接口，accept 方法是一个阻塞进程,等到有用户连接才往下走

// 定义Socket类

Socket socket = server.accept();

// 在服务器显示连接的上的电脑、

String message = socket. getInetAddress (). getHost Address () .toString();

System.out.println (message+"连接上了");

// 向用户发送消息

SendMessageToAllUser (message);

// 把连接上的用户添加到集合；里面去

list .add (socket);

//开始新连接用户的线程，用于该可以一直读取数据

new readerThread (socket).start();;

}

} catch (IOException e) {

e.printStackTrace ();

}

}

// 把消息发送给每一个用户，涉及到写的操作 OutStream

private void SendMessageToAllUser (String message) {

// 拿到每一个用户的 socket 对象，对其进行写入数据

for (Socket socket : list) {

// 判读之前保存的连接是否还在

if (socket != null && socket.isConnected() ) {

try {

OutputStream os = socket.getOutputStream ();

os.write (message.getBytes());

os.flush ();// 刷新一下写入的数据，很有必要

} catch (IOException e) {

e.printStackTrace ();

}

}

}

}

// 读取客户端的信息

class readerThread extends Thread {

InputStream is = null;

// 这里传入一个 socket 对象，因为每一个用户都要用一个不同的线程存放的 socket 对象来进行一直读取数据

public readerThread (Socket socket) {

try {

// 获取输入流

is = socket.getInputStream ();

} catch (IOException e) {

e.printStackTrace ();

}

}

@Override

public void run () {

super.run ();

try {

int len = 0;

byte[] buf = new byte [1024];

while ( (len = is.read(buf) ) != -1) {

// 把读取到的数据发送给其他用户

SendMessageToAllUser (new String(buf, 0, len));

}

} catch (IOException e) {

e.printStackTrace ();

}

}

}

}

package com.xykj .server;

public class ServerTest {

public static void main (String[] args) {

// 这里服务器只需要定义一个端口号就可以了，IP地址程序会自动获取

// 但是客户端需要连接这个服务器时，需要知道它的IP地址还有端口号

// ip地址的查看方法：进入cmd窗口，输入ipconfig/all可以看到

Server2 server = new Server2 (6768);

server.start ();

}

}