黑马程序员技术交流社区

标题: 多线程/网络编程 [打印本页]

---

作者: zjj5669436182    时间: 2017-12-22 21:39
标题: 多线程/网络编程

多线程/网络编程

一、线程概述

1、进程：当前正在运行的程序，一个应用程序在内存中的执行区域。

2、线程：线程是进程中的一个执行单元，负责当前进程中程序的执行，一个进程中至少有一个线程。

由进程就可以引出多线程概述：

一个程序运行后至少有一个进程，一个进程中可以包含多个线程

二、多线程的实现方式

实现方式一：继承Thread类

将类声明为 Thread 的子类。该子类应重写 Thread 类的 run 方法。

Thread类属于java.lang包下，所以使用时不需要进行导包

例如：

class Student extends Thread{

@Override

public void run（）{

System.out.println（getName()+“运行”）；

}

}

测试方法

class ThreadDemo{

public static void  mian（String[] args）{

//创建

Student s = new Student（）；

S.getName（）；//获取线程名

S.setName（“线程一”）；//修改线程名

S.start（）；//启动线程

}

}

实现方式二：实现接口Runnable

声明实现 Runnable 接口的类。该类然后实现 run 方法。然后创建Runnable的子类对象，传入到某个线程的构造方法中，开启线程。(此方法为主要的方法,可以和继承配合使用).

创建线程的步骤。

1、定义类实现Runnable接口。

2、覆盖接口中的run方法。。

3、创建Thread类的对象

4、将Runnable接口的子类对象作为参数传递给Thread类的构造函数。

5、调用Thread类的start方法开启线程。

例如:

class Student implements Runnable{

@Override

public void run{

System.out.println(Thread.currentThread().getName()+”运行”)

//currententThread() 返回对当前正在执行的线程对象的引用

}

}

//测试类

class RunnableDemo{

public static void main(String[] args){

Student ss = new Student();

Thread t = new Thread(ss);

t.setName(“线程一”);

t.start();//线程启动

}

}

三、多线程的安全问题解决

同步代码块

synchronized:同步（锁），可以修饰代码块和方法，被修饰的代码块和方法一旦被某个线程访问，则直接锁住，其他的线程将无法访问.

Synchronized(锁对象){

//需要同步的代码块

}

锁对象必须是被线程所共享的对象.例如 Object lock = new Object();

或者字节码对象

所对象的注意事项

非静态同步方法的锁对象是this

静态的同步方法的锁对象是当前类的字节码

四、面向网络

网络编程三要素

1、IP地址有InetV4Address（8字节） & InetV6Address（32字节）

2、端口号

3、通信协议（UDP、TCP）

UDP:不需要建立连接,大小限制64KB以内,传输快,不可靠

TCP:需要建立键连接,传输慢一点,安全可靠;

获取主机名或者IP地址

InetAddress address = InetAddress.getByName("itheima");

                InetAddress address = InetAddress.getByName("192.168.1.107");//ip地址是唯一的                String hostAddress = address.getHostAddress();//192.168.1.107 返回IP地址

                String hostName = address.getHostName();//itheima        返回主机名

UDP格式(客户端)

public class SendDemo {

        public static void main(String[] args) throws IOException  {

                //创建发送端Socket对象

                DatagramSocket ds = new DatagramSocket();

                //创建数据并打包

                /*

                 * DatagramPacket :此类表示数据报包

                 * 数据 byte[]

                 * 设备的地址 ip

                 * 进程的地址  端口号

                   DatagramPacket(byte[] buf, int length, InetAddress address, int port)

                 */

               

                String s = "hello udp,im comming!";

                byte[] bys = s.getBytes();

                int length = bys.length;

                InetAddress address = InetAddress.getByName("itheima");//发送给当前设备

                int port = 8888;

                //打包

                DatagramPacket dp = new DatagramPacket(bys,length,address,port);

                //发送数据

                ds.send(dp);

                //释放资源

                ds.close();

        }

}

UDP(接收端)

public class ReceiveDemo {

        public static void main(String[] args) throws IOException {

                //创建接收端Socket对象

                DatagramSocket ds = new DatagramSocket(8888);

                //接收数据

                //DatagramPacket(byte[] buf, int length)

                byte[] bys = new byte[1024];

                DatagramPacket dp = new DatagramPacket(bys,bys.length);

                               

                System.out.println(1);

                ds.receive(dp);//阻塞

                System.out.println(2);

               

                //解析数据

                //InetAddress getAddress() : 获取发送端的IP对象

                InetAddress address = dp.getAddress();

                //byte[] getData()  ：获取接收到的数据，也可以直接使用创建包对象时的数组

                byte[] data = dp.getData();

                //int getLength()  ：获取具体收到数据的长度

                int length = dp.getLength();

               

               

               

                //输出数据

                System.out.println("sender ---> " + address.getHostAddress());

                //System.out.println(new String(data,0,length));

                System.out.println(new String(bys,0,length));

                //释放资源

                ds.close();

        }

}

注意事项:1/        端口号如果不一致,不会报错,但是接收不到数据

2/接收端的端口不可重复.

TCP(客户端)

public class ClientDemo {

        public static void main(String[] args) throws IOException {

                //创建发送端Socket对象（创建连接）

                Socket s = new Socket(InetAddress.getByName("itheima"),10086);

                //获取输出流对象

                OutputStream os = s.getOutputStream();

                //发送数据

                String str = "hello tcp,im comming!!!";

                os.write(str.getBytes());

                //释放资源

                //os.close();

                s.close();

        }

}

TCP(服务器端)

public class ServerDemo {

        public static void main(String[] args) throws IOException  {

                //创建接收端Socket对象

                ServerSocket ss = new ServerSocket(10086);

                //监听（阻塞）

                Socket s = ss.accept();

                //获取输入流对象

                InputStream is = s.getInputStream();

                //获取数据

                byte[] bys = new byte[1024];

                int len;//用于存储读到的字节个数

                len = is.read(bys);

                //输出数据

                InetAddress address = s.getInetAddress();

                System.out.println("client ---> " + address.getHostName());

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

                //释放资源

                s.close();

                //ss.close();

        }

---

作者: 1414225997    时间: 2017-12-23 09:57
哇

---

作者: 花开的季节    时间: 2017-12-23 10:48
哇，笔记记得很不错哟，继续保持！

---

作者: 陈文老师    时间: 2017-12-23 11:42

---

欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2