多线程聊天室实验报告(多线程实验总结)

http://www.itjxue.com  2023-02-11 20:29  来源:未知  点击次数: 

用java编写一个多人聊天室可以 实现私聊,群聊,文件传送的功能

你这就整麻烦了,如果你只是想实现这些功能,不要求速度也不要存储空间,也不要求有界面那还比较简单,实体类序列化所有传送对象,在socket类中用object流直接传和接收所有的东西(包括聊天信息和文件)再用多线程实现群聊.大概两三天可以搞定.

如果你像做得类似于QQ一样,那就不是几天的事情了

多线程聊天室程序,为什么接收框不显示接收到的消息

我也遇到了这一的一个问题,最后发现是在if条件里的条件写错了,把==写成了=,你看看你的程序,希望对你有帮助。

如何在linux下用boost库实现多线程的聊天服务器

首先把Boost库的头文件存放到/usr/include/boost/路径下,再把Lib文件存放到/usr/local/lib/boost/路径下。修改/etc/profile文件,在此文件中增加如下2个环境变量:

BOOST_INCLUDE=/usr/include/boost

export BOOST_INCLUDE

BOOST_LIB=/usr/local/lib/boost

export BOOST_LIB

写一个如下所示的cpp文件。

//samlpe.cpp

#include iostream

#include string

#include boost/thread.hpp

using namespace std;

void threadRoutine(void)

{

boost::xtime time;

time.nsec = 0;

time.sec = 20;

cout "线程函数做一些事情" endl;

boost::thread::sleep(time);

}

linux C语言 TCP 多线程 简易聊天室

你accept得到一个新的连接后,再创建线程(把连接socket传给线程),用这个线程专门接收这个连接的数据,就不会有问题了。

UDP多线程聊天如何实现

如果对楼主有帮助,给个采纳好不,谢谢啦

UDP-聊天-多线程实现

/*UDP-聊天-多线程实现

编写一个聊天程序。

有收数据的部分,和发数据的部分。

这两部分需要同时执行。

那就需要用到多线程技术。

一个线程控制收,一个线程控制发.

因为收和发动作是不一致的,所以要定义两个run方法

而且这两个方法要封装到不同的类中。

*/import java.io.*;

import java.net.*;class Send implements Runnable//实现Runnable接口,可以多线,发送

{

private DatagramSocket ds;//定义Socket为成员

public Send (DatagramSocket ds)//发送的构造方法,以指定的DatagramSocket服务作为参数

{ ? ? ? ?this.ds = ds;

} ? ?public void run()

{ ? ? ? ?try

{

BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in));//读取键盘

String line = null; ? ? ? ? ? ?while ((line = bufr.readLine())!=null)

{ ? ? ? ? ? ? ? ?if ("886".equals(line))//设定输入886为退出

break; ? ? ? ? ? ? ? ?byte[] buf = line.getBytes();//得到数组

DatagramPacket dp = new DatagramPacket(buf,buf.length,InetAddress.getByName("192.168.1.255"),10002); ? ? ? ? ? ? ? ?//DatagramPacket的 实例化new参数(byte[],length)

//DatagramPacket的 实例化new参数(byte[],length,address,port)

//192.168.1.255 末尾255是广播,0是网段

ds.send(dp);

}

} ? ? ? ?catch (Exception e)

{ ? ? ? ? ? ?throw new RuntimeException("发送端失败");

}

}

}class Rece implements Runnable//实现Runnable接口,可以多线程,接收

{

private DatagramSocket ds;//定义Socket为成员

public Rece(DatagramSocket ds)//构造方法,以指定的DatagramSocket服务作为参数

{ ? ? ? ?this.ds = ds;

} ? ?public void run()

{ ? ? ? ?try

{ ? ? ? ? ? ?while (true)

{ ? ? ? ? ? ? ? ?byte[] buf = new byte[1024];//数组作为缓冲区

DatagramPacket dp = new DatagramPacket(buf,buf.length); ? ? ? ? ? ? ? ?//DatagramPacket的 实例化new参数(byte[],length)

//DatagramPacket的 实例化new参数(byte[],length,address,port)

ds.receive(dp);//将接收到的数据存储到定义好的数据包中。调用DatagramSocket的方法receive()

String ip = dp.getAddress().getHostAddress();//ip地址从DatagramPacket数据包中分离出来

String data = new String(dp.getData(),0,dp.getLength());//getData()变数组,参数(byte[],offset,length)

System.out.println(ip+":"+data);

}

} ? ? ? ?catch (Exception e)

{ ? ? ? ? ? ?throw new RuntimeException("接收端失败");

}

}

}class ?ChatDemo{

public static void main(String[] args) throws Exception

{

DatagramSocket sendSocket = new DatagramSocket();//无参数,随机分配端口 发送端的UDP服务

DatagramSocket receSocket = new DatagramSocket(10002);//参数,port指定端口 接收端的UDP服务

//建立多线程对象,要把实现Runnable接口的子类作为参数,传给Thread的构造函数

new Thread(new Send(sendSocket)).start(); ? ? ? ?new Thread(new Rece(receSocket)).start();

//这里new了Thread()的目的就是为了调用start()方法来启动线程

//启动线程的唯一方法就是通过Thread类的start()实例方法。start()方法是一个native方法,它将启动一个新线程,并执行run()方法。

//!-- 为了启动MyThread,需要首先实例化一个Thread,并传入自己的MyThread实例: --

//事实上,当传入一个Runnable target参数给Thread后,Thread的run()方法就会调用target.run()

}

}

多线程如何实现tcp多客户端聊天

这么搞:

客户端主程序

int main()

{

一个单链表的头节点 root;

一个读写锁 //用来控制链表的操作

开始监听

while(1)

{

if监听到了新的tcp连接

{

malloc一个链表节点p

取得写锁

把p加到链表的最后面

启动一个新的线程

xinxiancheng(socketfd,p);//正确的写法大概是这样pthread_create(m_tid,attr,armscHandler,arg)

释放写锁

}

}

}

线程函数这样搞

xinxiancheng(int socket,struct node *p)

{

while(1)

{

读sockt

如果读到了(如果对方关闭了则直接break)

{

获取写锁

把读到的内容写到p里面(struct node 里面一定要有一个存放读到的内容的buff)

释放写锁

}

获取读锁

从root开始读

把所有链表里的内容写到socket里面。

释放读锁

}

}

大概思路就是这样。还有一些细节。比如:node的buff怎么控制,写socket的时候要不要区分谁是谁,读写的方式(推荐非阻塞)等等。这些都可以在上面的基础上进行细化。

(责任编辑:IT教学网)

更多

推荐java认证文章