Java的Socket网络编程以及多线程

简介:
 1.Socket是代表两台机器之间网络连接的对象(java.net.Socket)。
  Socket的建立如下,参数分别是服务器端的IP地址和端口号: Socket socket  =  new Socket("167.5.75.1",5000);
   2.客户端(Client)Socket的使用
  2.1 从Socket读出数据步骤:
// 1.创建Socket连接,告知 Server的IP地址以及端口号
Socket socket = new Socket("127.0.0.1", 4242);
// 2.创建InputStreamReader,用于读取socket输入流
InputStreamReader stream = new InputStreamReader(socket.getInputStream());
// 3.使用BufferedReader链接输入流
BufferedReader br = new BufferedReader(stream);
// 4.读出数据
String line = null;
while ((line = br.readLine()) != null)
{
System.out.println("Today's advice is: " + line);
}
// 5. 关闭输入流BufferedReader
br.close();
  2.2 向Scoket写入数据步骤:
// 1.创建Socket连接,告知Server的IP地址以及端口号
Socket socket = new Socket("127.0.0.1", 4242);
// 2.创建PrintWriter对象,用以接收socket输出流
PrintWriter writer = new PrintWriter(socket.getOutputStream());
// 3.使用PrintWriter对象写出输出数据
String advice ="Today's advice";
writer.println(advice);
// 4. 关闭连接
writer.close();
  3.  服务器端(Server)Socket的使用
// 1.创建一个SercerSocket,使用4242端口监听客户端请求
ServerSocket serverSocket = new ServerSocket(4242);
System.out.println("The server is started, listening on port 4242");
while (true)
{
// 2.ServerSocket的accept()在等待用户连接的时候闲置;在用户连接上来的时候,返回一个Socket来与客户端通信
Socket socket = serverSocket.accept();
// 3.创建PrintWriter对象,用以接收socket输出流
PrintWriter writer = new PrintWriter(socket.getOutputStream());
// 4.使用PrintWriter对象写出输出数据
String advice = "notifier's blog";
writer.println(advice);
// 5. 关闭连接
writer.close();
}

 4.   线程的状态
  线程总共有5种状态:
  1. 新建 (Thread t = new Thread())
  2. 就绪 (t.start())
  3. 运行
  4. 堵塞
  线程被block的原因很多,比如: 等待IO操作, sleep(), 等待被占用对象释放
  5.死亡
   5.解决线程同步化问题的方法是: 对使用到共享对象的方法使用synchronized
  需要注意的是:
  虽说是方法进行了synchronized,但锁不是加在方法上的而是对象上的,也就是说,是synchronized方法获取对象锁。如果对象(类)有两个或者多个synchronized方法,就表示两个线程不能同时进入同一个方法,也不能同时进入不同的方法。 因为同一时间,只有一个方法在占有对象锁。
   6.synchronized代码块
  有时候在一个方法中做了很多事情,但只有一部分逻辑是需要synchronized的,这时候我们可以使用synchronized代码块。如下,其中this表示当前对象:
public void function()
{
doSomething();
//以下方法需要同步化
synchronized (this)
{
doCriticalStuff();
moreCriticalStuff();
}
doSomeOtherThing();
}
   7. 以下是一个Socket简单的例子:
  客户端代码及详细注释:
/**
* @author notifier
* @create 2010-9-25 上午10:12:10
* @version 1.0
*/
public class DailyAdviceClient
{
public static void main(String[] args)
{
DailyAdviceClient client = new DailyAdviceClient();
client.receiveMsg();
}
public void receiveMsg()
{
try
{
// 1.创建Socket连接,告知Server的IP地址以及端口号
Socket socket = new Socket("127.0.0.1", 4242);
// 2.创建InputStreamReader,用于读取socket输入流
InputStreamReader stream = new InputStreamReader(socket
.getInputStream());
// 3.使用BufferedReader链接输入流
BufferedReader br = new BufferedReader(stream);
// 4.读出数据
String line = null;
while ((line = br.readLine()) != null)
{
System.out.println("Today's advice is: " + line);
}
// 5. 关闭输入流BufferedReader
br.close();
} catch (UnknownHostException e)
{
e.printStackTrace();
} catch (IOException e)
{
e.printStackTrace();
}
}
}
 服务器端代码及详细注释:
/**
* @author notifier
* @create 2010-9-25 下午07:06:54
* @version 1.0
*/
public class SimpleChatServer
{
// 保存客户端列表
private ArrayList clientList = new ArrayList();;
public static void main(String[] args)
{
new SimpleChatServer().startUp();
}
/**
* 负责服务器端的启动
*
*/
public void startUp()
{
try
{
// 创建服务器端ServerSocket连接,监听端口号5000
ServerSocket serverSocket = new ServerSocket(5000);
// 轮询等待客户端请求
while(true)
{
// 等待客户端请求,无请求则闲置;有请求到来时,返回一个对该请求的socket连接
Socket clientSocket = serverSocket.accept();
// 将该客户端加入到列表中
PrintWriter writer = new PrintWriter(clientSocket.getOutputStream());
clientList.add(writer);
// 创建ClientHandler对象,通过socket连接通信
Thread t = new Thread(new ClientHandler(clientSocket));
t.start();
System.out.println("有Client连进来");
}
}catch(Exception e)
{
e.printStackTrace();
}
}
/**
* 客户端处理类, 主要负责:
* 1.接收客户端发来的消息
* 2.将消息转发其他客户端
* @author sdniu
* @create 2010-9-26 上午10:00:18
* @version 1.0
*/
public class ClientHandler implements Runnable
{
private BufferedReader reader;
private Socket socket;
/**
* ClientHandler的构造函数
* @param clientSocket
*/
public ClientHandler(Socket clientSocket)
{
try
{
// 得到socket连接
socket = clientSocket;
// 得到客户端发来的消息
InputStreamReader isReader = new InputStreamReader(socket.getInputStream());
reader = new BufferedReader(isReader);
} catch (IOException e)
{
e.printStackTrace();
}
}
public void run()
{
String message;
try
{
while((message = reader.readLine()) != null)
{
System.out.println("客户端消息: " + message);
// 将客户端发来的消息转发所有客户端
notifyAllClients(message);
}
} catch (IOException e)
{
e.printStackTrace();
}
}
}
/**
*
* @param message
*/
public void notifyAllClients(String message)
{
// 得到客户端列表的迭代器,语法格式为 Iterator it = clientList.iterator();
Iterator it = clientList.iterator();
while(it.hasNext())
{
try
{
// 得到的Iterator别忘了强制转换回PrintWriter
PrintWriter writer = (PrintWriter) it.next();
writer.println(message);
writer.flush();
} catch (Exception e)
{
e.printStackTrace();
}
}
}
}
    


最新内容请见作者的GitHub页:http://qaseven.github.io/
   
目录
相关文章
|
15小时前
|
缓存 监控 Java
Java Socket编程最佳实践:优化客户端-服务器通信性能
【6月更文挑战第21天】Java Socket编程优化涉及识别性能瓶颈,如网络延迟和CPU计算。使用非阻塞I/O(NIO)和多路复用技术提升并发处理能力,减少线程上下文切换。缓存利用可减少I/O操作,异步I/O(AIO)进一步提高效率。持续监控系统性能是关键。通过实践这些策略,开发者能构建高效稳定的通信系统。
|
15小时前
|
IDE Java 开发工具
从零开始学Java Socket编程:客户端与服务器通信实战
【6月更文挑战第21天】Java Socket编程教程带你从零开始构建简单的客户端-服务器通信。安装JDK后,在命令行分别运行`SimpleServer`和`SimpleClient`。服务器监听端口,接收并回显客户端消息;客户端连接服务器,发送“Hello, Server!”并显示服务器响应。这是网络通信基础,为更复杂的网络应用打下基础。开始你的Socket编程之旅吧!
|
16小时前
|
Java 数据安全/隐私保护
深入剖析:Java Socket编程原理及客户端-服务器通信机制
【6月更文挑战第21天】Java Socket编程用于构建网络通信,如在线聊天室。服务器通过`ServerSocket`监听,接收客户端`Socket`连接请求。客户端使用`Socket`连接服务器,双方通过`PrintWriter`和`BufferedReader`交换数据。案例展示了服务器如何处理每个新连接并广播消息,以及客户端如何发送和接收消息。此基础为理解更复杂的网络应用奠定了基础。
|
1天前
|
安全 Java
JAVA多线程通信新解:wait()、notify()、notifyAll()的实用技巧
【6月更文挑战第20天】Java多线程中,`wait()`, `notify()`和`notifyAll()`用于线程通信。在生产者-消费者模型示例中,它们确保线程同步。`synchronized`保证安全,`wait()`在循环内防止虚假唤醒,`notifyAll()`避免唤醒单一线程问题。关键技巧包括:循环内调用`wait()`,优先使用`notifyAll()`以保证可靠性,以及确保线程安全和正确处理`InterruptedException`。
|
1天前
|
Java
当JAVA多线程遇上wait()和notify():一场奇妙的邂逅
【6月更文挑战第20天】JAVA多线程中,wait()和notify()是线程通信的关键。wait()让线程释放锁进入等待,直到被notify()或notifyAll()唤醒。它们用于协调如生产者-消费者问题中的线程协作,确保在同步块内调用,并伴随条件检查以防止虚假唤醒。示例代码展示了一个简单的共享队列,其中生产和消费使用wait/notify实现同步。
|
1天前
|
安全 Java
深入解读JAVA多线程:wait()、notify()、notifyAll()的奥秘
【6月更文挑战第20天】JAVA多线程中,wait(), notify(), notifyAll()是Object类的关键同步机制。wait()让线程等待并释放锁,直到被notify()或notifyAll()唤醒或超时。它们必须在同步块中使用,持有锁的线程调用。notify()唤醒一个等待线程,notifyAll()唤醒所有。最佳实践包括:与synchronized结合,循环检查条件,避免循环内notify(),通常优先使用notifyAll()。
|
1天前
|
Java
JAVA多线程通信:为何wait()与notify()如此重要?
【6月更文挑战第20天】Java多线程中,wait()和notify()是关键的通信工具,用于解决并发访问共享资源时的数据一致性。这些方法让线程能等待特定条件并高效唤醒,避免忙等待和响应延迟。例如,在生产者-消费者模型中,它们协调生产者和消费者的活动,当队列满或空时,线程调用wait()休眠,notifyAll()唤醒等待的线程,保证同步和资源有效利用。
|
1天前
|
Java
wait()和notify():JAVA多线程世界的“信号兵”
【6月更文挑战第20天】在Java多线程中,`wait()`和`notify()`作为Object类的方法,扮演着线程间协调者的角色。`wait()`让线程等待并释放锁,`notify()`或`notifyAll()`唤醒等待的线程。在生产者-消费者模型中,它们用于同步访问资源,例如队列。当队列满或空时,线程调用wait()暂停,另一方完成操作后用notify()唤醒。理解并正确使用这些“信号兵”对构建高效的多线程程序至关重要。
|
1天前
|
Java
那些年,我们一起学过的JAVA多线程通信
【6月更文挑战第20天】JAVA多线程通信,如同编程旅途中的一道风景,引导我们探索复杂与魅力。wait()是优雅的暂停,释放锁让其他线程继续;notify()唤醒一个,像老师点名,而notifyAll()唤醒全部。生产者-消费者模型中,wait()与notify()协调线程,教会我们合作与解决问题。那些并肩学习的日子,成为永恒的记忆。
|
16天前
|
缓存 Java 测试技术
Java性能优化(八)-多线程调优-线程池大小设置
Java性能优化(八)-多线程调优-线程池大小设置
16 0

热门文章

最新文章